Stream API 遍历列表生成库存响应映射

本文讲解如何正确使用 Java Stream API 对请求列表进行处理，结合库存 Map 判断商品是否可下单，并安全地构建结果 Map，避免在流中直接修改外部集合。

在 Java 8+ 开发中，利用 Stream API 实现声明式数据处理已成为最佳实践。但初学者常误在 map() 或 forEach() 中直接修改外部 Map（如 responseMap.put(...)），这不仅违背函数式编程原则，更可能导致并发问题、难以调试，且在并行流中完全不可靠。

正确的做法是：让 Stream 负责“转换”和“收集”，而非“副作用操作”。即：将每个 ProductInStockRequest 映射为一个键值对（Map.Entry<String, String>），再通过 Collectors.toMap() 统一聚合为最终的 Map<String, String>。

以下是完整、线程安全、符合函数式风格的实现：

Map<String, String> responseMap = requestList.stream()
    .map(requestedItem -> {
        String productId = requestedItem.getProductId();
        Integer dbQuantity = productInDbMap.get(productId); // 注意空值处理（见下方说明）

        // 若数据库中无该产品，可设为 0 或抛异常，此处按 0 处理
        int quantity = (dbQuantity != null) ? dbQuantity : 0;
        int requested = requestedItem.getRequestedQuantity();

        if (quantity >= requested) {
            return new AbstractMap.SimpleEntry<>(productId, "order-able");
        } else {
            int deficit = requested - quantity; // 注意：原文中 `availableQuantity = quantity - requested` 逻辑有误，应为缺货量（负值）或剩余可订量（需明确业务语义）
            return new AbstractMap.SimpleEntry<>(productId, String.valueOf(-deficit)); // 示例：返回负数表示短缺数量
        }
    })
    .collect(Collectors.toMap(
        Map.Entry::getKey,
        Map.Entry::getValue,
        (existing, replacement) -> existing // 冲突解决策略（此处假设 productId 唯一，可忽略）
    ));

✅ 关键要点说明：

• ✅ 禁止流内修改外部状态：responseMap.put(...) 属于副作用，破坏流的纯性与可并行性；Collectors.toMap() 是唯一推荐的聚合方式。
• ✅ 空值防护：productInDbMap.get(productId) 可能返回 null，务必判空，避免 NullPointerException。
• ✅ 业务逻辑校验：原问题中 quantity - requestedQuantity 实际计算的是“剩余库存”，但语义上更合理的是返回“是否可订”或“短缺数量”。示例已修正为 requested - quantity（负值表示缺货量），请根据实际需求调整字符串内容（如 "out-of-stock: -2"）。
• ✅ 键冲突处理：Collectors.toMap 第三个参数用于处理重复 key（如 requestList 中存在相同 productId），本例中假设请求 ID 唯一，可保留默认策略或显式指定。

? 进阶建议：

• 使用 Map.ofEntries(...)（Java 9+）或 Collectors.toUnmodifiableMap(...)（Java 10+）提升不可变性与安全性；
• 若需结构化响应（如含状态码、消息），建议封装为 Map<String, ResponseResult>，其中 ResponseResult 为自定义 POJO；
• 对高吞吐场景，可考虑 parallelStream()，但需确保 productInDbMap 线程安全（如 ConcurrentHashMap）且 requestList 无状态共享。

遵循以上模式，即可写出清晰、健壮、可维护的 Stream 处理逻辑。