17370845950

本文讲解如何利用 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 函数式代码。