Java8 Stream教程之collect()的技巧

更新时间：2022年10月14日 11:18:36 作者：小目标青年

Java8引入了全新的Stream API,这里的Stream和I/O流不同,它更像具有Iterable的集合类,但行为和集合类又有所不同,下面这篇文章主要给大家介绍了关于Java8 Stream教程之collect()的技巧,需要的朋友可以参考下

前言

本身我是一个比较偏向少使用Stream的人，因为调试比较不方便。

但是, 不得不说，stream确实会给我们编码带来便捷。

正文

Stream流其实操作分三大块：

创建
处理
收集

我今天想分享的是收集这part的玩法。

OK，开始结合代码示例一起玩下：

lombok依赖引入，代码简洁一点：

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.20</version>
            <scope>compile</scope>
        </dependency>

准备一个UserDTO.java

/**
 * @Author: JCccc
 * @Date: 2022-9-20 01:25
 * @Description:
 */
@Data
public class UserDTO {
 
    /**
     * 姓名
     */
    private  String name;
    /**
     * 年龄
     */
    private  Integer age;
    /**
     * 性别
     */
    private  String sex;
    /**
     * 是否有方向
     */
    private  Boolean hasOrientation;
}

准备一个模拟获取List的函数：

    private static List<UserDTO> getUserList() {
        UserDTO userDTO = new UserDTO();
        userDTO.setName("小冬");
        userDTO.setAge(18);
        userDTO.setSex("男");
        userDTO.setHasOrientation(false);
        UserDTO userDTO2 = new UserDTO();
        userDTO2.setName("小秋");
        userDTO2.setAge(30);
        userDTO2.setSex("男");
        userDTO2.setHasOrientation(true);
        UserDTO userDTO3 = new UserDTO();
        userDTO3.setName("春");
        userDTO3.setAge(18);
        userDTO3.setSex("女");
        userDTO3.setHasOrientation(true);
        List<UserDTO> userList = new ArrayList<>();
        userList.add(userDTO);
        userList.add(userDTO2);
        userList.add(userDTO3);
        return userList;
    }

第一个小玩法将集合通过Stream.collect() 转换成其他集合/数组：

现在拿List<UserDTO> 做例子

转成 HashSet<UserDTO> ：

        List<UserDTO> userList = getUserList();
        Stream<UserDTO> usersStream = userList.stream();
        HashSet<UserDTO> usersHashSet = usersStream.collect(Collectors.toCollection(HashSet::new));

转成 Set<UserDTO> usersSet ：

        List<UserDTO> userList = getUserList();
        Stream<UserDTO> usersStream = userList.stream();
        Set<UserDTO> usersSet = usersStream.collect(Collectors.toSet());

转成 ArrayList<UserDTO> ：

        List<UserDTO> userList = getUserList();
        Stream<UserDTO> usersStream = userList.stream();
        ArrayList<UserDTO> usersArrayList = usersStream.collect(Collectors.toCollection(ArrayList::new));

转成 Object[] objects ：

        List<UserDTO> userList = getUserList();
        Stream<UserDTO> usersStream = userList.stream();
        Object[] objects = usersStream.toArray();

转成 UserDTO[] users ：

        List<UserDTO> userList = getUserList();
        Stream<UserDTO> usersStream = userList.stream();
        UserDTO[] users = usersStream.toArray(UserDTO[]::new);
        for (UserDTO user : users) {
            System.out.println(user.toString());
        }

第二个小玩法聚合（求和、最小、最大、平均值、分组）

找出年龄最大：

stream.max（）

写法 1：

List<UserDTO> userList = getUserList();
Stream<UserDTO> usersStream = userList.stream();
Optional<UserDTO> maxUserOptional = 
        usersStream.max((s1, s2) -> s1.getAge() - s2.getAge());
if (maxUserOptional.isPresent()) {
    UserDTO masUser = maxUserOptional.get();
    System.out.println(masUser.toString());
}

写法2：

List<UserDTO> userList = getUserList(); Stream<UserDTO> usersStream = userList.stream();
Optional<UserDTO> maxUserOptionalNew = usersStream.max(Comparator.comparingInt(UserDTO::getAge));
if (maxUserOptionalNew.isPresent()) {
    UserDTO masUser = maxUserOptionalNew.get();
    System.out.println(masUser.toString());
}

效果：

输出：

UserDTO(name=小秋, age=30, sex=男, hasOrientation=true)

找出年龄最小：

stream.min（）

写法 1：

Optional<UserDTO> minUserOptional = usersStream.min(Comparator.comparingInt(UserDTO::getAge));
if (minUserOptional.isPresent()) {
    UserDTO minUser = minUserOptional.get();
    System.out.println(minUser.toString());
}

写法2：

Optional<UserDTO> min = usersStream.collect(Collectors.minBy((s1, s2) -> s1.getAge() - s2.getAge()));

求平均值：

List<UserDTO> userList = getUserList();
Stream<UserDTO> usersStream = userList.stream();
Double avgScore = usersStream.collect(Collectors.averagingInt(UserDTO::getAge));

效果：

求和：

写法1：

Integer reduceAgeSum = usersStream.map(UserDTO::getAge).reduce(0, Integer::sum);

写法2：

int ageSumNew = usersStream.mapToInt(UserDTO::getAge).sum();

统计数量：

long countNew = usersStream.count();

简单分组：

按照具体年龄分组:

//按照具体年龄分组
Map<Integer, List<UserDTO>> ageGroupMap = usersStream.collect(Collectors.groupingBy((UserDTO::getAge)));

效果：

分组过程加写判断逻辑：

//按照性别 分为"男"一组  "女"一组
Map<Integer, List<UserDTO>> groupMap = usersStream.collect(Collectors.groupingBy(s -> {
    if (s.getSex().equals("男")) {
        return 1;
    } else {
        return 0;
    }
}));

效果：

多级复杂分组：

//多级分组
// 1.先根据年龄分组
// 2.然后再根据性别分组
Map<Integer, Map<String, Map<Integer, List<UserDTO>>>> moreGroupMap = usersStream.collect(Collectors.groupingBy(

        //1.KEY(Integer)             VALUE (Map<String, Map<Integer, List<UserDTO>>)
        UserDTO::getAge, Collectors.groupingBy(
                //2.KEY(String)             VALUE (Map<Integer, List<UserDTO>>)
                UserDTO::getSex, Collectors.groupingBy((userDTO) -> {
                    if (userDTO.getSex().equals("男")) {
                        return 1;
                    } else {
                        return 0;
                    }
                }))));

效果：

总结

到此这篇关于Java8 Stream教程之collect()技巧的文章就介绍到这了,更多相关Java8 Stream collect()技巧内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

Spring Boot通过Redis实现防止重复提交
表单提交是一个非常常见的功能,如果不加控制,容易因为用户的误操作或网络延迟导致同一请求被发送多次,本文主要介绍了Spring Boot通过Redis实现防止重复提交,具有一定的参考价值,感兴趣的可以了解一下
2024-06-06
Flink部署集群整体架构源码分析
这篇文章主要为大家介绍了Flink部署集群及整体架构示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-12-12
Java中数组复制的三种方式小结
在Java中,数组复制是一种常见的操作,它允许开发人员在不修改原始数组的情况下创建一个新的数组,本文就来介绍三种方法,具有一定的参考价值,感兴趣的可以了解一下
2024-02-02
解决Springboot项目打包后的页面丢失问题(thymeleaf报错)
这篇文章主要介绍了解决Springboot项目打包后的页面丢失问题(thymeleaf报错)，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-11-11
java正则表达式解析html示例分享
这篇文章主要介绍了java正则表达式解析html示例,用到获取url的正则表达式,获取图片的正则表达式，需要的朋友可以参考下
2014-02-02
详解J2EE开发的网站部署到阿里云服务器的方法
这篇文章主要介绍了详解J2EE开发的网站部署到阿里云服务器的方法,需要的朋友可以参考下
2018-01-01
Spring MVC 请求参数绑定实现方式
Spring MVC 是一个用于构建 Web 应用程序的框架,它提供了一种方便的方式来处理 HTTP 请求和响应,Spring MVC 提供了多种方式来实现请求参数绑定,本文结合实例代码给大家介绍的非常详细,需要的朋友跟随小编一起看看吧
2023-09-09
Java 流的高级使用之收集数据解析
这篇文章主要介绍了Java 流的高级使用之收集数据解析，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-08-08
springboot的application.yml配置port不生效的解决方案
这篇文章主要介绍了springboot的application.yml配置port不生效的解决方案,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
2024-07-07
Mybatis-Plus3.x的创建步骤及使用教程
MyBatis-Plus是一个 MyBatis 的增强工具，在 MyBatis 的基础上只做增强不做改变，为简化开发、提高效率而生，这篇文章主要介绍了Mybatis-Plus3.x的使用,需要的朋友可以参考下
2023-10-10