Java Stream 怎样保留分组后每组最大值

如果需求是“每个部门只保留工资最高的员工”，关键不是先排序再截取，而是把分组和组内归约放进同一个收集器：Collectors.groupingBy 负责按部门建组，Collectors.maxBy 负责在每组中按工资比较。这样可以保留完整的 Employee 对象，结果类型会先表现为 Map>。

• 要保留整行员工信息：使用 groupingBy + maxBy。
• 只要每组最大工资：使用下游 mapping 或数值汇总。
• 工资相同：比较器需要补充稳定的次级字段，明确究竟保留谁。

先把“每组最大值”拆成两个结果

这个问题常见的误区是把“最大工资”和“工资最高的员工”当成同一个结果。前者只需要数字，后者还需要姓名、部门、工号等字段。因此代码应先决定结果对象，再决定下游收集器。

下面的示例使用 Java 记录类表达输入数据。代码中的注释只解释关键边界，示例本身不依赖修改原始列表。

import java.util.Comparator;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.stream.Collectors;

record Employee(String name, String department, int salary, int id) {}

List employees = List.of(
    new Employee("林晓", "研发", 18000, 101),
    new Employee("周宁", "研发", 22000, 102),
    new Employee("陈默", "销售", 16000, 201),
    new Employee("许安", "销售", 19000, 202)
);

// 先按部门分组，再在每个组内比较工资，保留完整员工对象。
Comparator bySalary = Comparator.comparingInt(Employee::salary);
Map> groupedMax = employees.stream()
    .collect(Collectors.groupingBy(
        Employee::department,
        Collectors.maxBy(bySalary)
    ));

groupedMax 的逻辑结果是：研发对应周宁，销售对应许安。maxBy 的返回类型是 Optional，这是收集器对“组可能没有元素”这一情况的显式表达；正常的非空输入组可以通过 orElseThrow 或 flatMap 继续转换。

把 Optional 结果整理成可直接使用的 Map

业务代码通常不希望每次读取都处理一层 Optional。可以在收集之后统一转换，也可以把转换放进下游收集器。对于已经确认输入非空的分组，后处理写法更直观：

// 每个部门都来自 employees 的实际分组，因此这里把空值视为数据契约异常。
Map bestByDepartment = groupedMax.entrySet().stream()
    .collect(Collectors.toMap(
        Map.Entry::getKey,
        entry -> entry.getValue().orElseThrow(
            () -> new IllegalStateException("部门没有员工: " + entry.getKey())
        )
    ));

如果只需要每组的最大工资，不需要保留员工对象，可以改成下游映射。但这会丢掉姓名和工号，不能再用它回答“谁的工资最高”。实际项目中建议先确认返回 DTO 的字段，再选择是否降维。

并列最大值怎样避免结果不明确

如果同一部门有两名员工工资相同，只有工资字段的比较器无法表达业务优先级。不要把“先出现的人”当成业务规则，而应在比较器中写出次级条件，例如工资相同后选择工号更小的员工：

// 工资优先；工资相同则用工号作为稳定的次级比较条件。
Comparator bySalaryThenId = Comparator
    .comparingInt(Employee::salary)
    .thenComparing(Comparator.comparingInt(Employee::id).reversed());

Map> deterministicMax = employees.stream()
    .collect(Collectors.groupingBy(
        Employee::department,
        Collectors.maxBy(bySalaryThenId)
    ));

上面的次级比较器表示：工资相同则工号较大的员工胜出。如果业务要求工号较小者胜出，应把次级比较方向调整为升序，并在测试数据中放入一组相同工资记录，避免比较器方向写反。

结果验收与常见误区

验收时先检查 Map 的键是否等于实际部门集合，再检查每个员工的工资是否等于该部门的最大工资。还要注意三点：第一，groupingBy 的分类函数不能返回不符合业务语义的空键；第二，流在终止操作后不能重复消费，若要重新计算应从源集合重新创建流；第三，Lambda 不要修改正在遍历的源集合，也不要用共享可变变量偷偷保存“当前最大值”。

普通 stream() 已经能完成这个任务。只有确实有并行处理需求时才考虑 parallelStream()，并确保比较器、分类函数和数据源满足无干扰、无状态的要求；先把结果规则写清楚，比盲目并行更重要。

常见问题

为什么 maxBy 的结果不是直接的 Employee？

因为收集器需要表达输入为空时没有最大元素，所以返回 Optional。确认数据契约后再用 orElseThrow 转成实体，避免用虚假的默认员工掩盖数据问题。

只想得到每个部门的最大工资怎么办？

使用下游 mapping(Employee::salary, Collectors.maxBy(Integer::compareTo))，但要接受结果只包含数值、不再携带员工其他字段。

工资相同能不能保留所有员工？

不能用单个 maxBy 表达“全部并列最大值”，它只产生一个最大元素。若业务要求保留并列项，应先得到每组最大工资，再按该工资筛选，或改用能累计列表的自定义下游收集器。

参考：https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/stream/package-summary.html、https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/stream/Collectors.html。本文只讨论标准 Stream 收集器完成分组取最大对象的边界。