Java 8 Stream API：高效统计列表中特定属性的出现次数

统计列表中元素出现次数的需求分析

在日常的java开发中，我们经常会遇到需要对列表中的复杂数据结构进行分类统计的需求。例如，给定一个包含家庭成员信息的列表，每个成员都有一个“成员类型”（如兄弟姐妹、子女、配偶），我们需要统计不同成员类型的数量。原始数据可能以list

面对这类需求，传统的遍历和手动计数方式虽然可行，但在数据量较大或逻辑复杂时，代码会显得冗长且不易维护。Java 8引入的Stream API为这类数据处理提供了强大而简洁的解决方案。

优化数据结构：从Map到POJO

尽管原始问题中数据以List

1. 类型安全： POJO的属性有明确的类型定义，编译器可以在编译阶段捕获类型错误，而不是在运行时才发现。
2. 代码可读性： 通过POJO的属性名可以直接了解数据的含义，无需记忆Map中字符串键。
3. IDE支持： IDE可以提供自动补全、重构等功能，提高开发效率。
4. 易于维护： 数据结构清晰，便于团队协作和后续维护。

因此，在进行统计之前，我们首先将Map数据转换为POJO。以下是表示家庭成员的FamilyMember POJO类定义：

import java.time.LocalDate;

public class FamilyMember {

    private String memberType;
    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;
    }

    // Getter 方法
    public String getMemberType() {
        return memberType;
    }

    public String getFullName() {
        return fullName;
    }

    public LocalDate getDateOfBirth() {
        return dateOfBirth;
    }

    public String getGender() {
        return gender;
    }

    // Setter 方法 (如果需要，可添加)
    public void setMemberType(String memberType) {
        this.memberType = memberType;
    }

    public void setFullName(String fullName) {
        this.fullName = fullName;
    }

    public void setDateOfBirth(LocalDate dateOfBirth) {
        this.dateOfBirth = dateOfBirth;
    }

    public void setGender(String gender) {
        this.gender = gender;
    }

    @Override
    public String toString() {
        return "FamilyMember{" +
               "memberType='" + memberType + '\'' +
               ", fullName='" + fullName + '\'' +
               ", dateOfBirth=" + dateOfBirth +
               ", gender='" + gender + '\'' +
               '}';
    }
}

使用Java 8 Stream API进行分组计数

有了FamilyMember POJO，我们可以利用Java 8 Stream API的Collectors.groupingBy和Collectors.counting方法来实现高效的分类计数。

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

Collectors.groupingBy()：这是一个强大的收集器，用于根据某个分类函数对流中的元素进行分组。它返回一个Map，其中键是分类函数的结果，值是对应分组的元素列表（或经过下游收集器处理的结果）。

Collectors.counting()：这是一个下游收集器，通常与groupingBy结合使用。它简单地统计每个分组中的元素数量，并返回一个Long类型的值。

MCP官网

Model Context Protocol（模型上下文协议）

下载

以下是实现家庭成员类型计数的完整示例代码：

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

public class TestFamilyMemberCounting {

    public static void main(String[] args) {
        // 1. 准备示例数据（使用POJO）
        FamilyMember member1 = new FamilyMember("Sibling", "Sibling name",
                LocalDate.of(1990, 12, 12), "Male");
        FamilyMember member2 = new FamilyMember("Sibling", "Sibling name2",
                LocalDate.of(1990, 12, 12), "Male");
        FamilyMember member3 = new FamilyMember("Sibling", "Sibling name3",
                LocalDate.of(1990, 12, 12), "Male");
        FamilyMember member4 = new FamilyMember("Child", "Child name",
                LocalDate.of(2010, 12, 12), "Male");
        FamilyMember member5 = new FamilyMember("Child", "Child name2",
                LocalDate.of(2000, 12, 12), "Female");
        FamilyMember member6 = new FamilyMember("Spouse", "Spouse name",
                LocalDate.of(1990, 12, 12), "Male");

        List listOfFamilyMember = Arrays.asList(member1, member2,
                member3, member4, member5, member6);

        // 2. 使用Stream API进行分组计数
        Map countMembers = listOfFamilyMember.stream()
                .collect(Collectors.groupingBy(FamilyMember::getMemberType, // 根据memberType字段进行分组
                        Collectors.counting())); // 对每个分组的元素进行计数

        // 3. 打印结果
        System.out.println(countMembers);
    }
}

代码解析：

1. 数据准备： 我们创建了一个List，其中包含了不同类型的家庭成员数据。
2. 创建Stream： listOfFamilyMember.stream()将列表转换为一个Stream对象，使得我们可以链式调用Stream API的方法。
3. collect()操作： collect()是一个终端操作，用于将Stream中的元素聚合为结果数据结构。
4. Collectors.groupingBy(FamilyMember::getMemberType, ...)： 这是核心的分组操作。
   • FamilyMember::getMemberType 是一个方法引用，它作为分类函数，告诉groupingBy根据FamilyMember对象的memberType属性值进行分组。
   • Collectors.counting() 是一个下游收集器，它作用于每个分组，计算该分组中元素的数量。
5. 结果： collect()方法最终返回一个Map，其中键是memberType（例如"Sibling", "Child", "Spouse"），值是对应类型的成员数量。

运行结果

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

{Spouse=1, Sibling=3, Child=2}

这清晰地显示了每种家庭成员类型的出现次数，符合我们的预期。

注意事项与最佳实践

• 选择合适的数据结构： 尽管本教程从List
• Stream API的优势： Java 8 Stream API提供了声明式的数据处理方式，使得代码更加简洁、易读，并且在多核处理器上能够更好地进行并行处理（通过parallelStream()）。
• 灵活性： groupingBy可以接受不同的下游收集器，例如Collectors.summingInt()、Collectors.averagingDouble()、Collectors.mapping()等，可以实现更复杂的聚合操作。
• 空值处理： 在实际应用中，如果用于分组的字段可能为null，需要考虑如何处理。groupingBy默认会将null作为单独的一个分组键。

总结

通过本教程，我们学习了如何利用Java 8 Stream API的groupingBy和counting收集器，高效地统计列表中特定属性值的出现次数。这种方法不仅代码简洁，而且可读性强，是处理此类数据聚合任务的推荐方式。同时，我们也强调了在面向对象编程中，使用POJO来表示复杂数据实体的重要性，它能够显著提升代码质量和开发效率。掌握Stream API的这一用法，将有助于您编写更现代、更高效的Java代码。