Stack Overflow上有个问题被浏览了47万次：怎么用Java Stream按字段去重。高赞回答的代码片段被复制粘贴了12.7万次，但评论区里有条留言很扎心——"用了半年才发现内存泄漏"。
这不是API不熟，是根本没理解Stream的设计哲学。
我翻了Pudari Madhavi在Medium上的完整教程，发现8个场景能把"我会Stream"的自信碾碎。最狠的是第3个：合并两个Map时，90%的人写的代码在数据量过百万时会直接卡死。
去重陷阱：你以为的优雅，可能是内存炸弹
按对象字段去重是后台最常见的需求。用户导入Excel，邮箱重复只保留第一条；订单列表里同一商品合并数量。新手的第一反应是`distinct()`，然后发现这玩意儿只能比整个对象。
Madhavi给的解法是用`Collectors.toMap`，把email当key，遇到重复时保留旧值：
`users.stream().collect(toMap(User::getEmail, identity(), (existing, replacement) -> existing))`
这行代码的评论区常年吵架。一方说简洁，另一方贴出OOM崩溃日志——当数据量到百万级，toMap底层用的HashMap会直接把堆内存吃光。Java 8文档里其实埋了条注释：此方法不适用于并行流，且对大数据集需谨慎。
更隐蔽的坑是`identity()`。有人为了"性能"改成`u -> u`，结果编译器推断类型时报错报得莫名其妙。Madhavi特意标注：这里的函数式接口是`Function`，lambda的返回类型必须匹配key类型，否则类型推导会翻车。
她给的替代方案是`Collectors.groupingBy`配合`mapValues`，用Stream做二次处理。代码长了4行，但能接`parallelStream()`，且内存占用可控。很多团队代码库里搜不到这个写法——因为Stack Overflow的高赞回答没提。
Map合并：那个"一行搞定"的写法，生产环境别用
两个Map合并，key冲突时保留旧值或新值，这是配置中心、缓存更新的日常。Madhavi列出的"标准答案"是`map1.putAll(map2)`，然后手动处理冲突。
Stream派的写法更骚：`map2.forEach((k, v) -> map1.merge(k, v, (oldVal, newVal) -> oldVal))`。看起来是函数式编程的胜利，直到你在G1垃圾收集器的日志里看到Allocation Failure。
问题出在`merge`的第三个参数。Madhavi指出，这个BiFunction每次都会创建，即使key不冲突。在百万级Map的场景下，这等于白白构造了几十万个lambda实例。JDK源码里，`merge`的实现是先get再put，冲突时才调用函数——但lambda的捕获变量分析在JIT编译前就已经完成，逃逸分析救不了场。
她推荐的`Collectors.toMap`版本更惨：并发场景下`ConcurrentHashMap`的merge操作会锁分段，而Stream的并行收集器默认用`ConcurrentHashMap`做合并。结果就是，你以为的并行优化，变成了锁竞争地狱。
有个细节很多人漏看：Madhavi的示例代码里，`toMap`的第四个参数是`HashMap::new`。这意味着你可以换成`LinkedHashMap::new`保留插入顺序，或者`ConcurrentHashMap::new`强行并发——但后者在并行流里会触发额外的线程安全开销，性能反而比单线程慢40%。
分组与规约：当Stream遇见数据库思维
`groupingBy`是Stream里最像SQL GROUP BY的操作。Madhavi的第5个案例直击痛点：按部门分组后，要的是每个部门工资最高的员工，不是工资列表。
常见错误是先`groupingBy(Department::getName)`，然后对每个List做`stream().max(Comparator.comparing(Employee::getSalary))`。这相当于数据库里先GROUP BY再子查询，但Stream的执行模型是物化中间结果——每个部门的员工列表会先全部装进内存。
她的解法是用`groupingBy`的重载版，直接指定下游收集器：`groupingBy(Employee::getDepartment, maxBy(comparing(Employee::getSalary)))`。这里`maxBy`返回`Optional`，省去二次遍历。
但`Optional`的坑又来了。有人直接`.get()`，遇到空组抛NoSuchElementException。Madhavi的代码里用了`orElse(null)`，评论区有人抗议这是"破坏函数式纯度"。她的回应很直接：「生产代码里，null比异常堆栈便宜」。
规约操作`reduce`是另一个重灾区。Madhavi举的例子是求所有订单的总金额，很多人写成`orders.stream().map(Order::getAmount).reduce(0, Integer::sum)`。这在大数据量下会反复装箱拆箱，性能比`mapToInt(Order::getAmount).sum()`差一个数量级。
更隐蔽的是并行流的`reduce`：必须满足结合律，且初始值不能是0——如果求乘积，初始值1在空流时会错误返回1而非空。Madhavi标注了JDK文档的警告，但文档本身藏在一级菜单里。
调试与异常：Stream的"黑盒"诅咒
Madhavi的第7个案例让我破防了：Stream链里抛异常，堆栈信息指向lambda的行号，但你看不到中间值。她给的解法是`peek(System.out::println)`，但强调这是"调试期的临时手段"。
生产环境的标准做法是拆分流式操作，或者引入日志框架的lambda支持。有个评论提到IntelliJ的Stream Trace功能，能可视化每个元素的流转——但Madhavi回复：「这功能在并行流里是残废的」。
异常处理方面，她对比了两种模式。一种是包装`try-catch`在lambda里，代码丑且丢失原始异常类型；另一种是使用`Either`模式或`vavr`库的函数式异常处理。但后者引入第三方依赖，在保守的企业架构里很难推进。
最讽刺的是第8个案例：用Stream处理IO操作。Madhavi明确说"不要这么做"，因为Stream的延迟执行特性会让资源关闭时机变得不可控。但GitHub上搜`Files.lines().filter().map()`的代码有23万条结果，其中大部分没加`try-with-resources`。
她引用的一个生产事故：某金融系统用Stream处理CSV导入，文件句柄泄漏导致Linux达到`ulimit`上限，整个服务拒绝连接。日志里没有任何异常，只是响应越来越慢——直到运维发现`/proc/{pid}/fd`下有4万个未关闭的文件描述符。
Stream的`onClose`方法可以注册关闭钩子，但Madhavi的测试显示，只有当Stream被正确消费完毕时才会触发。如果中途`findFirst()`短路返回，或者抛异常中断，钩子不会执行。JDK 9新增的`takeWhile`和`dropWhile`让这个问题更复杂：短路条件满足时，后续元素的关闭逻辑被跳过。
Madhavi在文末的总结很克制：Stream不是银弹，它是"声明式语法糖包裹的迭代器"。理解这一点的人，会在代码评审时多问一句——这个Stream链，如果数据量翻100倍，还跑得动吗？
她没回答的问题是：当Project Valhalla的原始类型泛型落地，当Vector API开始替代自动向量化，Stream的这些陷阱会被填平，还是会被新特性掩盖得更深？
热门跟贴