Collectors.maxBy和minBy需配合groupingBy使用,返回Optional类型,须用orElse等安全解包;可用collectingAndThen简化为非Optional值,并支持复合比较器。

用 Collectors.maxBy 和 Collectors.minBy 在分组后提取每组的极值对象,关键在于配合 Collectors.groupingBy 使用,并传入合适的比较器(Comparator)。
理解 maxBy/minBy 的返回类型
maxBy 和 minBy 返回的是 Optional<t></t>,不是直接的 T。这意味着分组后每个键对应的值是 Optional,需注意空值处理。
- 若某组为空(比如过滤后无元素),对应值为
Optional.empty() - 使用
.orElse(null)或.orElseThrow()显式解包 - 不建议直接调用
.get(),容易触发NoSuchElementException
基础分组取极值:按分类找最贵/最便宜商品
假设有一组 Product 对象:
record Product(String category, String name, double price) {}
要按 category 分组,每组取价格最高的商品:
Map<String, Optional<Product>> maxPerCategory = products.stream()
.collect(Collectors.groupingBy(
Product::category,
Collectors.maxBy(Comparator.comparingDouble(Product::price))
));
结果中 maxPerCategory.get("electronics") 是 Optional<product></product>,可安全展开:
Product topElectronics = maxPerCategory.get("electronics")
.orElse(new Product("electronics", "default", 0.0));
避免 Optional 嵌套:用 collectingAndThen 简化结构
如果希望 Map 的 value 类型直接是 Product(而非 Optional<product></product>),可用 Collectors.collectingAndThen 预先解包:
Map<String, Product> maxPerCategoryClean = products.stream()
.collect(Collectors.groupingBy(
Product::category,
Collectors.collectingAndThen(
Collectors.maxBy(Comparator.comparingDouble(Product::price)),
opt -> opt.orElse(null) // 或提供默认实例
)
));
- 这样 map 的 value 就是
Product,null 表示该组无元素 - 注意:若业务不允许 null,建议用
opt.orElseThrow(() -> new IllegalStateException("Empty group: " + category))
复合条件与自定义比较器
极值逻辑不只限于单字段。例如“同价格下取名称字典序最小者”:
Comparator<Product> comp = Comparator.comparingDouble(Product::price)
.thenComparing(Product::name); // 先比价格升序,再比名称升序
// 取最便宜且名称最小的
Map<String, Optional<Product>> cheapestAndFirst = products.stream()
.collect(Collectors.groupingBy(
Product::category,
Collectors.minBy(comp)
));
也可用 lambda 写更灵活逻辑,比如优先非空描述、再比时间:
Collectors.maxBy((a, b) -> {
if (a.description() == null && b.description() != null) return -1;
if (a.description() != null && b.description() == null) return 1;
return a.createdAt().compareTo(b.createdAt());
});
不复杂但容易忽略:maxBy/minBy 本质是归约操作,必须搭配 groupingBy 的下游收集器;它不会自动跳过 null 字段,比较器里要主动防护;多线程流中行为一致,无需额外同步。

















