Java8Stream统计属性出现次数详解

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

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

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

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

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

为了更好地演示，我们将原始的List>数据结构转换为更符合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()）。

2. 实现计数逻辑

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

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 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 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来存储结构化数据。POJO提供了编译时类型检查、更好的代码可读性、IDE自动补全支持以及更强的可维护性。如果数据源确实是List>，你可以在处理前将其转换为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中处理数据聚合任务的效率。

今天带大家了解了的相关知识，希望对你有所帮助；关于文章的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~