本文讲解如何利用 java stream api 正确、函数式地遍历 `list`，对照库存 `map` 判断商品是否可下单，并生成结果 `map`，避免在流中直接修改外部集合的常见错误。
在 Java 8+ 开发中，使用 Stream API 替代传统 for 循环处理集合是推荐实践，但需严格遵循无副作用（side-effect-free） 原则：即不应在 map、filter 等中间操作中修改外部状态（如向外部 HashMap 调用 put()）。您原始代码中在 map() 内直接调用 responseMap.put(...) 虽能编译通过，但属于不安全的可变操作——不仅违背函数式编程思想，更可能在并行流（parallelStream()）下引发竞态条件、数据丢失或 ConcurrentModificationException。
✅ 正确做法是：将每项请求转换为键值对（如 Map.Entry），再通过 Collectors.toMap() 统一收集为最终 Map。以下是完整、健壮的实现：
Map responseMap = requestList.stream()
.map(requestedItem -> {
String productId = requestedItem.getProductId();
Integer dbQuantity = productInDbMap.get(productId); // 注意空值安全
// 处理 productId 不在库存 Map 中的情况（建议防御性编程）
if (dbQuantity == null) {
return new AbstractMap.SimpleEntry<>(productId, "product-not-found");
}
int requestedQty = requestedItem.getRequestedQuantity();
if (dbQuantity >= requestedQty) {
return new AbstractMap.SimpleEntry<>(productId, "order-able");
} else {
int shortfall = requestedQty - dbQuantity; // 注意：此处应为“缺货量”，非“剩余量”
return new AbstractMap.SimpleEntry<>(productId, String.valueOf(shortfall));
}
})
.collect(Collectors.toMap(
Map.Entry::getKey,
Map.Entry::getValue,
(existing, replacement) -> existing // 解决 key 冲突（此处理论上不会发生，因 productId 唯一）
));
? 关键要点说明：
- ✅ 零副作用：全程未修改任何外部变量，所有中间结果均由 Stream 自动传递；
- ✅ 空值防护：显式检查 productInDbMap.get(productId) 是否为 null，避免 NullPointerException；
- ✅ 语义准确：shortfall = requestedQty - dbQuantity 表示“还差多少才能满足订单”，比原文 quantity - requestedQuantity（可能为负数且含义模糊）更符合业务逻辑；
- ✅ 冲突处理：toMap 第三个参数 (existing, replacement) -> existing 确保当意外出现重复 productId 时保留首个结果（也可根据需求抛出异常）；
- ⚠️ 性能提示：若 requestList 极大且 productInDbMap 是 HashMap，该方案时间复杂度为 O(n)，高效可靠；避免在 map 中反复调用 productInDbMap::get 以外的耗时操作。
? 进
阶建议：
- 可封装为静态工具方法，提升复用性；
- 若需返回结构化对象（如 Map），可定义枚举 OrderStatus { ORDERABLE, SHORTAGE(int), NOT_FOUND }，增强类型安全与可读性；
- 对于高并发场景，可考虑 ConcurrentHashMap + computeIfAbsent，但 Stream 方案本身已天然支持并行化（.parallelStream()）。
遵循此模式，您将写出更清晰、更安全、更易测试和维护的 Java 函数式代码。
