Java中用Stream流取出分组后每组中最大值对应的对象

Java中用Stream流取出分组后每组中最大值对应的对象

要从分组后的结果中实际取出这些对象（而不是Optional包装的对象），有几种常用的方法：

方法1：直接处理Map中的Optional

Map<String, Optional<Order>> groupedResult = orders.stream()
    .collect(Collectors.groupingBy(
        Order::getCustomerId,
        Collectors.maxBy(Comparator.comparing(Order::getOrderDate))
    ));

// 取出所有对象
List<Order> resultObjects = groupedResult.values().stream()
    .filter(Optional::isPresent)
    .map(Optional::get)
    .collect(Collectors.toList());

方法2：使用collectingAndThen去除Optional

Map<String, Order> resultMap = orders.stream()
    .collect(Collectors.groupingBy(
        Order::getCustomerId,
        Collectors.collectingAndThen(
            Collectors.maxBy(Comparator.comparing(Order::getOrderDate)),
            opt -> opt.orElse(null)
        )
    ));

// 取出所有非null对象
List<Order> resultObjects = resultMap.values().stream()
    .filter(Objects::nonNull)
    .collect(Collectors.toList());

方法3：直接收集到List（Java 12+）

List<Order> resultObjects = orders.stream()
    .collect(Collectors.groupingBy(
        Order::getCustomerId,
        Collectors.maxBy(Comparator.comparing(Order::getOrderDate))
    ))
    .values().stream()
    .flatMap(opt -> opt.map(Stream::of).orElseGet(Stream::empty))
    .collect(Collectors.toList());

方法4：自定义收集器（更高效）

List<Order> resultObjects = orders.stream()
    .collect(Collectors.collectingAndThen(
        Collectors.groupingBy(
            Order::getCustomerId,
            Collectors.maxBy(Comparator.comparing(Order::getOrderDate))
        ),
        map -> map.values().stream()
            .filter(Optional::isPresent)
            .map(Optional::get)
            .collect(Collectors.toList())
    ));

完整工作示例

List<Order> orders = Arrays.asList(
    new Order("C1", LocalDate.of(2023, 1, 10), 100.0),
    new Order("C1", LocalDate.of(2023, 2, 15), 150.0),
    new Order("C2", LocalDate.of(2023, 1, 5), 200.0),
    new Order("C2", LocalDate.of(2023, 3, 20), 250.0),
    new Order("C3", LocalDate.of(2023, 2, 1), 300.0)
);

// 找出每个客户最近的订单并收集到List
List<Order> latestOrders = orders.stream()
    .collect(Collectors.groupingBy(
        Order::getCustomerId,
        Collectors.maxBy(Comparator.comparing(Order::getOrderDate))
    ))
    .values().stream()
    .filter(Optional::isPresent)
    .map(Optional::get)
    .collect(Collectors.toList());

// 打印结果
latestOrders.forEach(order -> System.out.println(
    "客户 " + order.getCustomerId() + 
    " 最近的订单日期: " + order.getOrderDate() + 
    " 金额: " + order.getAmount()
));

输出结果示例

客户 C1 最近的订单日期: 2023-02-15 金额: 150.0
客户 C2 最近的订单日期: 2023-03-20 金额: 250.0
客户 C3 最近的订单日期: 2023-02-01 金额: 300.0

关键点总结

1. groupingBy + maxBy 会产生 Map<K, Optional<T>> 结构
2. 需要额外处理Optional才能得到实际对象
3. 推荐使用方法2或方法4，它们在性能和可读性上表现较好
4. 如果确定每组都有值，可以使用orElseThrow()替代orElse(null)