如何使用 Java Streams 对成功与失败项进行分组并按需排序显示

本文介绍如何利用 Java Streams 的 partitioningBy 将结果列表按 success 字段分为失败（false）和成功（true）两组，并保持原始顺序，最终实现“失败项置顶、成功项合并为单条汇总消息”的定制化输出。

本文介绍如何利用 Java Streams 的 partitioningBy 将结果列表按 success 字段分为失败（false）和成功（true）两组，并保持原始顺序，最终实现“失败项置顶、成功项合并为单条汇总消息”的定制化输出。

在实际业务中，我们常需对操作结果进行语义化聚合展示：例如批量处理后，将所有失败详情逐条列出以供排查，而成功项仅需一句简洁汇总（如“其余 X 项执行成功”），既提升可读性，又避免冗余输出。Java Streams 提供了高效、声明式的解决方案。

✅ 推荐方案：Collectors.partitioningBy

相比通用的 groupingBy，partitioningBy 是专为布尔条件设计的优化工具——它固定生成 Map>，天然保证 key 仅为 true/false，且保留原始插入顺序（因底层使用 LinkedHashMap），完美契合本场景需求。

// 假设 Result 类已定义 public boolean getSuccess() 方法
Map> partitioned = resultSet.stream()
    .collect(Collectors.partitioningBy(Result::getSuccess));

该映射中：

• partitioned.get(false) → 所有失败项（按原始顺序排列）
• partitioned.get(true) → 所有成功项（同样保持原始顺序）

? 构建最终输出列表

根据需求“失败项完整展示 + 成功项仅汇总一条”，我们无需遍历全部成功项，只需提取失败列表，再追加一条统一的成功提示：

List outputLines = new ArrayList<>();
// 1. 添加所有失败消息（保持原始顺序）
partitioned.getOrDefault(false, Collections.emptyList())
    .forEach(result -> outputLines.add(result.getMessage()));
// 2. 添加单条成功汇总（可选：附带成功数量）
long successCount = partitioned.getOrDefault(true, Collections.emptyList()).size();
outputLines.add("Success summary: " + successCount + " item(s) succeeded.");

若需直接打印（不存入集合）：

// 仅输出失败详情
partitioned.getOrDefault(false, Collections.emptyList())
    .forEach(r -> System.out.println(r.getMessage()));
// 输出统一成功提示
long successTotal = partitioned.getOrDefault(true, Collections.emptyList()).size();
System.out.println("All other " + successTotal + " operations succeeded.");

⚠️ 注意事项与最佳实践

• Getter 方法必需：Result::getSuccess 要求类中存在符合 JavaBean 规范的 public boolean getSuccess() 方法（而非直接访问字段 success）。
• 空值安全：使用 getOrDefault(key, Collections.emptyList()) 避免 NullPointerException（如全成功时 get(false) 返回 null）。
• 性能考量：partitioningBy 时间复杂度为 O(n)，无额外排序开销，优于先 sorted() 再分组。
• 扩展性提示：若未来需支持多状态（如 PENDING/ERROR/TIMEOUT），应改用 groupingBy + 枚举分类，而非布尔分区。

通过以上方式，你既能充分利用 Stream API 的函数式表达力，又能精准满足业务侧对结果展示逻辑的定制要求——清晰、高效、可维护。