如何使用Java Stream Collectors合并列表中同ID的A对象？

当然可以用Java Stream的Collectors工具类来优雅完成这个需求！核心思路是先按A的ID分组，再对每组内的A对象合并它们的B列表，下面给你两种常用的实现方式，附带代码示例和细节说明：

前提假设 #

先定义下我们用到的实体类结构（你可以根据实际情况调整）：

class A {
    private Long id;
    private List<B> bList;

    // 全参构造器
    public A(Long id, List<B> bList) {
        this.id = id;
        this.bList = new ArrayList<>(bList); // 初始化时复制列表，避免外部修改
    }

    // Getter方法
    public Long getId() { return id; }
    public List<B> getBList() { return bList; }

    // 可选：用于合并的工具方法
    public A merge(A another) {
        this.bList.addAll(another.getBList());
        return this;
    }
}

class B {
    // 示例字段，根据你的实际类调整
    private String content;

    public B(String content) { this.content = content; }
}

方法一：使用Collectors.toMap（推荐，代码更简洁） #

toMap可以直接指定键、值以及冲突时的合并逻辑，非常适合这种按ID去重合并的场景：

List<A> originalList = ...; // 你的已填充好的A对象列表

List<A> mergedList = new ArrayList<>(originalList.stream()
    .collect(Collectors.toMap(
        A::getId, // 分组的键：A的ID
        a -> new A(a.getId(), a.getBList()), // 值：基于原A创建新对象，避免修改原数据
        (existingA, incomingA) -> {
            // 合并逻辑：把新A的B列表追加到已有A的B列表中
            existingA.getBList().addAll(incomingA.getBList());
            return existingA;
        }
    ))
    .values()); // 把Map中的值（合并后的A）转成List

关键点说明： #

• 为什么要新建A对象？如果直接使用原A实例，合并时会修改原列表中的对象，可能导致意外的副作用，新建对象能保证原数据的完整性。
• 合并函数(existingA, incomingA)会在遇到相同ID的A时触发，我们只需要把后者的B列表追加到前者即可。

方法二：使用Collectors.groupingBy + reduce #

如果你更习惯先分组再处理的逻辑，可以用groupingBy先把同ID的A归到一组，再用reduce合并每组内的对象：

List<A> mergedList = originalList.stream()
    // 第一步：按ID分组，得到Map<Long, List<A>>
    .collect(Collectors.groupingBy(A::getId))
    // 第二步：遍历每个分组，合并组内的A对象
    .values()
    .stream()
    .map(group -> group.stream()
        .reduce((a1, a2) -> {
            // 合并两个A的B列表，生成新的A对象
            List<B> combinedBList = new ArrayList<>(a1.getBList());
            combinedBList.addAll(a2.getBList());
            return new A(a1.getId(), combinedBList);
        })
        .orElseThrow()) // 每个分组至少有一个元素，所以不会抛出异常
    .collect(Collectors.toList());

关键点说明： #

• reduce会迭代组内的所有A，逐步合并它们的B列表，最终生成一个合并后的A对象。
• 如果你的A对象还有其他需要保留的字段（比如创建时间、描述等），可以在reduce时把这些字段也保留下来（比如取组内第一个A的字段值）。

额外注意事项 #

• 线程安全：如果使用并行流（parallelStream()），要确保合并逻辑是线程安全的，比如避免直接修改共享的集合，建议在合并时始终创建新的List。
• 字段一致性：假设同ID的A对象除了B列表外，其他字段都是一致的；如果不一致，你需要在合并逻辑中明确处理（比如取第一个对象的字段，或者做特殊合并）。

内容的提问来源于stack exchange，提问作者obdoyuran