使用Java 8 Stream统计集合中特定属性的出现次数-java教程-PHP中文网

使用Java 8 Stream统计集合中特定属性的出现次数

霞舞

发布： 2025-07-16 20:22:28

原创

764人浏览过

使用Java 8 Stream统计集合中特定属性的出现次数

在日常数据处理中，我们经常需要统计集合中特定类型或属性的出现频率。例如，在一个包含家庭成员信息的列表中，我们可能需要知道有多少个“兄弟姐妹”、多少个“孩子”等。对于原始数据可能以 List<Map<String, String>> 形式存在的情况，Java 8 Stream API 提供了一种优雅且高效的解决方案。本教程将重点介绍如何利用 Collectors.groupingBy 和 Collectors.counting 来实现这一目标，并推荐使用更具结构化的POJO（Plain Old Java Object）来提升代码的可读性和可维护性。

核心概念：Java 8 Stream API的分组与计数

java 8引入的stream api为集合操作带来了极大的便利。要统计集合中特定属性的出现次数，我们主要依赖以下两个collectors：

Collectors.groupingBy(Function classifier): 这个收集器根据提供的分类函数对流中的元素进行分组。分类函数的返回值将作为结果Map的键，而值则是一个包含所有属于该组的元素的列表（或进一步处理后的结果）。
Collectors.counting(): 这是一个下游收集器，通常与groupingBy结合使用。它计算每个分组中的元素数量。

当两者结合使用时，groupingBy会根据分类函数将元素分组，然后counting会统计每个分组中的元素个数，最终返回一个Map<K, Long>，其中K是分类键，Long是对应的计数。

示例实现：统计家庭成员类型

为了更好地演示，我们将原始的List<Map<String, String>>数据结构转换为更符合Java编程习惯的POJO。这不仅提高了类型安全性，也使代码更易于理解和维护。

1. 定义数据模型（POJO）

首先，创建一个FamilyMember类来表示每个家庭成员的详细信息。

import java.time.LocalDate;

public class FamilyMember {
    private String memberType; // 家庭成员类型，如"Sibling", "Child", "Spouse"
    private String fullName;
    private LocalDate dateOfBirth;
    private String gender;

    public FamilyMember(String memberType, String fullName, 
                        LocalDate dateOfBirth, String gender) {
        this.memberType = memberType;
        this.fullName = fullName;
        this.dateOfBirth = dateOfBirth;
        this.gender = gender;
    }

    // Getters for all fields are essential for Stream operations
    public String getMemberType() {
        return memberType;
    }

    public String getFullName() {
        return fullName;
    }

    public LocalDate getDateOfBirth() {
        return dateOfBirth;
    }

    public String getGender() {
        return gender;
    }

    // Setters can be added if needed, but not strictly for this counting example
}

登录后复制

说明： FamilyMember类封装了家庭成员的属性。其中，memberType是我们希望进行计数的关键属性。为了让Collectors.groupingBy能够访问到这个属性，必须提供相应的getter方法（getMemberType()）。

立即学习“Java免费学习笔记（深入）”；

2. 实现计数逻辑

接下来，在主程序中创建FamilyMember对象列表，并使用Stream API进行计数。

SpeakingPass-打造你的专属雅思口语语料

使用chatGPT帮你快速备考雅思口语，提升分数

查看详情

import java.time.LocalDate;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

public class MemberCounter {

    public static void main(String[] args) {
        // 模拟数据：创建家庭成员列表
        List<FamilyMember> listOfFamilyMember = Arrays.asList(
            new FamilyMember("Sibling", "Sibling name", LocalDate.of(1990, 12, 12), "Male"),
            new FamilyMember("Sibling", "Sibling name2", LocalDate.of(1990, 12, 12), "Male"),
            new FamilyMember("Sibling", "Sibling name3", LocalDate.of(1990, 12, 12), "Male"),
            new FamilyMember("Child", "Child name", LocalDate.of(2010, 12, 12), "Male"),
            new FamilyMember("Child", "Child name2", LocalDate.of(2000, 12, 12), "Female"),
            new FamilyMember("Spouse", "Spouse name", LocalDate.of(1990, 12, 12), "Male")
        );

        // 使用Stream API统计各类家庭成员的数量
        Map<String, Long> countMembers = listOfFamilyMember.stream()
            .collect(Collectors.groupingBy(FamilyMember::getMemberType, Collectors.counting()));

        // 打印结果
        System.out.println("家庭成员类型统计结果: " + countMembers);
    }
}

登录后复制

代码解析：

listOfFamilyMember.stream(): 将List转换为一个流，以便进行链式操作。
.collect(...): 这是一个终端操作，用于将流中的元素收集到一个结果容器中。
Collectors.groupingBy(FamilyMember::getMemberType, Collectors.counting()): 这是核心部分。
- FamilyMember::getMemberType: 这是一个方法引用，作为分类函数。它告诉groupingBy根据每个FamilyMember对象的memberType属性进行分组。
- Collectors.counting(): 作为groupingBy的下游收集器，它负责计算每个分组中元素的数量。

运行结果

执行上述代码，将得到如下输出：

家庭成员类型统计结果: {Spouse=1, Sibling=3, Child=2}

登录后复制

这个Map清晰地展示了每种家庭成员类型的出现次数。

注意事项与最佳实践

数据结构选择： 强烈推荐使用POJO而非Map<String, String>来存储结构化数据。POJO提供了编译时类型检查、更好的代码可读性、IDE自动补全支持以及更强的可维护性。如果数据源确实是List<Map<String, String>>，你可以在处理前将其转换为POJO列表。如果无法转换，也可以直接使用Lambda表达式作为分类函数，例如 listOfMaps.stream().collect(Collectors.groupingBy(map -> map.get("Add_Family_Member"), Collectors.counting()));，但这种方式会失去类型安全性，且在键不存在时可能返回null。
Null值处理： 如果分类函数返回null，groupingBy会将所有null值归为一组，并以null作为该组的键。在实际应用中，你可能需要在使用前对数据进行清洗或添加null检查，例如使用Objects.requireNonNull或filter操作。
可读性与维护性： Stream API的链式操作使得代码意图清晰，易于阅读和理解。结合方法引用（如FamilyMember::getMemberType）进一步提高了代码的简洁性。
性能： Stream API在内部进行了优化，对于大多数数据集，其性能表现良好。但在处理超大规模数据集时，仍需考虑内存消耗和并发处理，必要时可使用并行流（parallelStream()）。

总结

Java 8 Stream API结合Collectors.groupingBy和Collectors.counting为统计集合中特定属性的出现次数提供了一个强大、简洁且富有表达力的解决方案。通过采用POJO作为数据模型，可以进一步提升代码的健壮性和可维护性。掌握这一模式，将极大地提高你在Java中处理数据聚合任务的效率。

以上就是使用Java 8 Stream统计集合中特定属性的出现次数的详细内容，更多请关注php中文网其它相关文章！