【Java8系列08】Java8中reducing妙用

💝💝💝欢迎来到我的博客，很高兴能够在这里和您见面！希望您在这里可以感受到一份轻松愉快的氛围，不仅可以获得有趣的内容和知识，也可以畅所欲言、分享您的想法和见解。

推荐:kwan 的首页,持续学习,不断总结,共同进步,活到老学到老
导航
檀越剑指大厂系列:全面总结 java 核心技术点,如集合,jvm,并发编程 redis,kafka,Spring,微服务,Netty 等
常用开发工具系列:罗列常用的开发工具,如 IDEA,Mac,Alfred,electerm,Git,typora,apifox 等
数据库系列:详细总结了常用数据库 mysql 技术点,以及工作中遇到的 mysql 问题等
懒人运维系列:总结好用的命令,解放双手不香吗?能用一个命令完成绝不用两个操作
数据结构与算法系列:总结数据结构和算法,不同类型针对性训练,提升编程思维,剑指大厂

非常期待和您一起在这个小小的网络世界里共同探索、学习和成长。💝💝💝 ✨✨ 欢迎订阅本专栏 ✨✨

博客目录

- 1.什么是 reducing?
- 2.使用示例?
- 3.使用优化
- 4.复杂规约
- 5.实战应用?

1.什么是 reducing?

在 Java 8 中，Collectors.reducing 是Collectors类提供的一个强大的工具，用于进行归约操作。它用于将流中的元素按照某种规则进行累积，最终生成一个汇总结果。

Collectors.reducing(identity, op)

identity：归约操作的初始值，也是流中没有元素时的默认值。
op：一个二元操作符，用于将两个元素结合起来，执行归约操作。

2.使用示例?

下面是一个具体的例子，假设有一个包含整数的列表，我们希望对这些整数求和：

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);

// 使用Collectors.reducing进行求和
Optional<Integer> sum = numbers.stream()
    .collect(Collectors.reducing((x, y) -> x + y));

// 打印结果
System.out.println("Sum: " + sum.orElse(0));

这个例子中，Collectors.reducing 接受一个 Lambda 表达式 (x, y) -> x + y 作为参数，表示对两个元素执行求和操作。sum 是一个Optional<Integer>，它包含了最终的求和结果。如果流为空，orElse(0) 将返回默认值 0。

3.使用优化

这个例子也可以通过方法引用来简化：

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);

// 使用方法引用进行求和
int sum = numbers.stream()
    .collect(Collectors.reducing(0, Integer::sum));

// 打印结果
System.out.println("Sum: " + sum);

在这里，Integer::sum 是一个方法引用，表示执行整数求和操作。

4.复杂规约

Collectors.reducing 还可以用于更复杂的归约操作，例如查找最大值或最小值。下面是一个查找最大值的例子：

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);

// 使用Collectors.reducing查找最大值
Optional<Integer> max = numbers.stream()
    .collect(Collectors.reducing(Integer::max));

// 打印结果
System.out.println("Max: " + max.orElse(0));

在这个例子中，Integer::max 是一个方法引用，表示执行整数的最大值操作。

5.实战应用?

有一个集合 storeReports,希望求不同分组策略下汇总值

先根据不同的策略进行分组
在 groupingBy 的内部进行 reducing 操作
new DTO()是初始值
后面的函数是规约的具体逻辑

reducing实战:

Map<String, DTO> resultMap  = storeReports.stream()
                    .collect(Collectors.groupingBy(storeReportDTO -> isTotal ? storeReportDTO.groupKeyTotal() : storeReportDTO.groupKey(),
                            Collectors.reducing(new DTO(),
                                    (s1, s2) -> new DTO(
                                            s2.getName1(),
                                            s2.getKey(),
                                            s2.getYearName(),
                                            s2.getSeasonName(),
                                            Optional.ofNullable(s1.getSalQty()).orElse(0L) + Optional.ofNullable(s2.getSalQty()).orElse(0L),
                                            BigDecimal.ZERO,
                                            BigDecimal.ZERO,
                                            BigDecimal.ZERO,
                                            s2.getWeekOrMonth(),
                                            s2.getYear()
                                    )
                            )
                    ));

分组

public String groupKey() {
    return year + ":_:" + weekOrMonth + ":_:" + key + ":_:" + yearName + ":_:" + seasonName;
}
public String groupKeyTotal() {
    return year + ":_:" + weekOrMonth + ":_:" + key;
}