本文介绍如何利用 Java 8 的 Stream API 和 Collectors 对 Employee 对象列表按 ID 去重，并将相同 ID 的 compensation 值合并求和，最终生成新的聚合列表。
本文介绍如何利用 java 8 的 stream api 和 collectors 对 `employee` 对象列表按 id 去重，并将相同 id 的 `compensation` 值合并求和，最终生成新的聚合列表。
在实际业务中（如薪资结算、报表汇总），常需对具有相同标识（如员工 ID）的对象集合进行分组聚合。针对 Employee 类型列表，核心目标是：按 id 分组 → 合并同组 compensation → 构造新 Employee 实例。推荐使用函数式风格的 Stream 流处理，简洁高效且线程安全。
以下是完整实现方案：
import java.util.*;
import java.util.stream.Collectors;
class Employee {
private final String id;
private final float compensation; // 建议设为 final，保证不可变性（与聚合逻辑更契合）
public Employee(String id, float compensation) {
this.id = Objects.requireNonNull(id);
this.compensation = compensation;
}
public String getId() { return id; }
public float getCompensation() { return compensation; }
@Override
public String toString() {
return "Employee{id='" + id + "', compensation=" + compensation + "}";
}
}
public class EmployeeAggregator {
/**
* 按员工 ID 去重并聚合薪酬（求和）
* @param employees 原始员工列表（允许 null 元素，但建议预校验）
* @return 新的聚合后员工列表，ID 唯一，compensation 为同 ID 所有值之和
*/
public static List<Employee> aggregateByEmployeeId(List<Employee> employees) {
if (employees == null || employees.isEmpty()) {
return Collections.emptyList();
}
return employees.stream()
.filter(Objects::nonNull) // 过滤 null 元素，避免空指针
.collect(Collectors.groupingBy(
Employee::getId,
Collectors.summingDouble(Employee::getCompensation)
))
.entrySet().stream()
.map(entry -> new Employee(entry.getKey(), entry.getValue().floatValue()))
.sorted(Comparator.comparing(Employee::getId)) // 可选：按 ID 排序提升可读性
.collect(Collectors.toList());
}
}调用示例：
Java注释规范Skills
下载
当用户要求为 Java 代码添加注释、修改注释、审查注释、整理注释格式，或要求按照代码注释规范处理 Java 文件时，使用本技能。本技能用于统一生成和维护 Java 类注释模板、按 Git 对比 release 判断版本号、补充每行代码上方中文块注释、调整注释空行规则，并保持 Java 文件 UTF-8 无 BOM 编码。典型触发场景包括：补充类注释、更新 @version、检查 @author 来源、整理行尾注释、把注释放到代码上一行、检查注释是否符合规范、构建前检查 Java 注释风格。
public class Main {
public static void main(String[] args) {
List<Employee> payment = Arrays.asList(
new Employee("1", 3000.00f),
new Employee("1", 6000.00f),
new Employee("2", 5000.00f),
new Employee("3", 4000.00f)
);
List<Employee> aggregated = EmployeeAggregator.aggregateByEmployeeId(payment);
aggregated.forEach(System.out::println);
// 输出：
// Employee{id='1', compensation=9000.0}
// Employee{id='2', compensation=5000.0}
// Employee{id='3', compensation=4000.0}
}
}✅ 关键注意事项：
立即学习“Java免费学习笔记（深入）”；
- compensation 字段建议声明为 final，确保对象不可变，避免后续误修改影响聚合结果一致性；
- 使用 Collectors.summingDouble 而非 summingFloat（JDK 不提供后者），再通过 .floatValue() 安全转换，规避浮点精度累积误差（如需更高精度，应改用 BigDecimal）；
- 显式添加 Objects::nonNull 过滤和空列表判空处理，增强鲁棒性；
- 若原始列表极大，可考虑使用 parallelStream() 提升性能，但需确保 Employee 类无共享可变状态；
- 如需保留原始顺序（而非按键排序），可省略 .sorted(...) 步骤——groupingBy 默认不保证 entrySet 遍历顺序，但 LinkedHashMap 作为默认实现会维持插入顺序（JDK 8+），故多数场景下无需额外排序。
该方案兼具可读性、扩展性与工程实践性，是 Java 8+ 环境下处理此类分组聚合任务的标准范式。
