Java Stream 怎样合并两路聚合结果

Java Stream 可以在一次 collect 中使用 Collectors.teeing，把同一批元素交给两个下游收集器，再用 merger 合并两路结果。它不是把输入一分为二，也不是拼接两条 Stream；每个输入元素都会参与两边的收集。

teeing 从 Java 12 起提供，本文完整示例使用 JDK 25 和 record 结果类型。官方地址：https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/stream/Collectors.html。

用一个collect得到总量和最大项

假设需要给一组批次生成报告：既要总数量，也要保留数量最多的那条完整记录。相比只求最大数值，这两个结果的类型和用途不同，适合用组合收集器表达。下面是本次原创的独立示例，可保存为 TwoAggregates.java；本文没有编译或运行它。

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

public class TwoAggregates {
    record Batch(String name, int units) {}
    record Report(long totalUnits, Optional largest) {}

    static Collector reportCollector() {
        // 同一批输入：一路求总量，一路保留数量最多的完整对象。
        return Collectors.teeing(
                Collectors.summingLong(Batch::units),
                Collectors.maxBy(Comparator.comparingInt(Batch::units)),
                // merger接收的是两个下游的完成结果，不是每一个输入元素。
                Report::new);
    }

    public static void main(String[] args) {
        List batches = List.of(
                new Batch("north", 4),
                new Batch("west", 9),
                new Batch("east", 6));

        Report report = batches.stream().collect(reportCollector());
        System.out.println("total=" + report.totalUnits());
        // 空流时maxBy返回Optional.empty，不要无条件get。
        System.out.println("largest=" + report.largest()
                .map(Batch::name).orElse("(none)"));

        Report empty = List.of().stream().collect(reportCollector());
        System.out.println("emptyTotal=" + empty.totalUnits());
        System.out.println("emptyLargest=" + empty.largest().isEmpty());
    }
}

按示例数据推导，总数量为19，最大项名称为west；空输入的总量为0，largest为空。代码最后一行打印的是 isEmpty()，因此 emptyLargest 对应的预期布尔值是 true。这些是逻辑推导，不是实测输出。

两个下游与合并函数各管什么

这里可以把 teeing 看作“两项独立归约的组合”。输入批次包含 name 和 units；总量收集器 summingLong 使用 units，最大项收集器 maxBy 用 units 比较并保留 Batch 对象，merger 则把两路完成结果装进 Report。merger 并不负责逐条处理输入。

两路可以有不同结果类型，但必须能消费同一个输入类型。若只希望一边统计某类元素，可以在该下游组合 filtering 等收集器；不能把 teeing 理解成自动按条件分配两路数据。也不要在两个下游中重复执行有副作用的外部调用。

空流和并行收集要保留什么约定

空流仍按各下游的定义产生完成结果。本例总量结果由 summingLong 给出0，最大项结果由 maxBy 给出 Optional.empty；Report保留这两种含义，而不是人为造一条“默认最大记录”。Report的 totalUnits 来自总量结果，largest 来自最大项结果，空值约定属于各自字段。

并行 Stream 不等于 teeing 为两个下游各开一条线程。收集框架会按照下游的容器、累积和组合约定执行归约；teeing 只有在两个下游都具备 CONCURRENT 特征时才具有该特征，UNORDERED 也同样要求两边都具备。没有 CONCURRENT 不意味着收集器不能用于并行流，也不意味着它会并发更新同一个结果容器。

自定义下游还须满足 Collector 的结合性及非并发容器隔离等契约，不能让两个下游偷偷共享一个可变集合。Collector 文档：https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/stream/Collector.html。

哪些情况没必要使用teeing

如果只需要同一个数值字段的数量、总和、最小值与最大值，现有 summarizingLong 等汇总收集器可能更直接。teeing 的价值在于组合不同类型的结果，而不是把任何聚合都写成嵌套树。

也不能对同一 Stream 先调用一次求和、再调用一次求最大；Stream 不应被重复操作。若数据源是可重复遍历的集合，分别新建两条流可以表达两次独立计算，但这与teeing组合收集不是同一组织方式。Stream约定：https://docs.oracle.com/en/java/javase/25/docs/api/java.base/java/util/stream/Stream.html。

选择时可以问三件事：两路是否面对同一批输入；下游是否已经能独立表达结果；最终是否只需一个清楚的组合函数。若答案都是肯定，teeing通常比外部可变计数器更清楚。它不会保证减半耗时，下游计算仍然都要完成，本文也没有性能测量。

两路能否分别得到List和Map？

可以，只要对应下游消费的输入类型兼容，且Map收集需要的重复键规则已经明确。两路结果类型不必相同。

空流时merger可以直接取Optional.get吗？

不应无条件这样做。本例保留Optional，展示层使用map与orElse表达没有最大项的情况。

最大值相同会选哪条？

若业务需要稳定且明确的选择，应给比较器增加业务认可的次级比较字段；不要只比较units却对并列项身份作额外承诺。

简要记法是：同一输入、两个下游、一个结果合并函数。先明确结果类型与空输入含义，再考虑是否并行执行。