Java 8 Stream 之 collect() 的奇技淫巧

简介: Java 8 Stream 之 collect() 的奇技淫巧

前言



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


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


所以还是忍不住想分享一些奇技淫巧。


正文



Stream流 其实操作分三大块 :


创建

处理

收集



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


image.png


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 做例子


转成  HashSet :


   

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


转成  Set usersSet :


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


转成  ArrayList :


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


写法2:


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


效果:


image.png


输出:


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


找出年龄最小:


stream.min()


写法 1:


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


写法2:


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


求平均值:


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


效果:


image.png


求和:


写法1:


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


写法2:


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


统计数量:


long countNew = usersStream.count();


简单分组:


按照具体年龄分组:


//按照具体年龄分组


Map> ageGroupMap = usersStream.collect(Collectors.groupingBy((UserDTO::getAge)));


效果:


image.png


分组过程加写判断逻辑:


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


效果:


image.png


多级复杂分组:


//多级分组
// 1.先根据年龄分组
// 2.然后再根据性别分组
Map>>> moreGroupMap = usersStream.collect(Collectors.groupingBy(
        //1.KEY(Integer)             VALUE (Map>)
        UserDTO::getAge, Collectors.groupingBy(
                //2.KEY(String)             VALUE (Map>)
                UserDTO::getSex, Collectors.groupingBy((userDTO) -> {
                    if (userDTO.getSex().equals("男")) {
                        return 1;
                    } else {
                        return 0;
                    }
                }))));


效果:


image.png

目录
打赏
0
0
0
0
34
分享
相关文章
|
7天前
|
Java 中 `toList()` 与 `collect(Collectors.toList())` 的微妙差异:别再乱用了!
Java 中 `toList()` 与 `collect(Collectors.toList())` 的微妙差异:别再乱用了!
掌握Java Stream API:高效集合处理的利器
掌握Java Stream API:高效集合处理的利器
153 80
Java 8 Stream API:高效集合处理的利器
Java 8 Stream API:高效集合处理的利器
167 83
|
21天前
|
Java 8 + 中 Lambda 表达式与 Stream API 的应用解析
摘要:本文介绍了Java 8+核心新特性,包括Lambda表达式与Stream API的集合操作(如过滤统计)、函数式接口的自定义实现、Optional类的空值安全处理、接口默认方法与静态方法的扩展能力,以及Java 9模块化系统的组件管理。每个特性均配有典型应用场景和代码示例,如使用Stream统计字符串长度、Optional处理Map取值、模块化项目的依赖声明等,帮助开发者掌握现代Java的高效编程范式。(150字)
38 1
Java代码优化:for、foreach、stream使用法则与性能比较
总结起来,for、foreach和stream各自都有其适用性和优势,在面对不同的情况时,有意识的选择更合适的工具,能帮助我们更好的解决问题。记住,没有哪个方法在所有情况下都是最优的,关键在于理解它们各自的特性和适用场景。
161 23
Java 开发中Stream的toMap与Map 使用技巧
本文深入解析了 Java 中 `toMap()` 方法的三大问题:重复键抛出异常、`null` 值带来的风险以及并行流中的性能陷阱,并提供了多种替代方案,如使用 `groupingBy`、`toConcurrentMap` 及自定义收集器,帮助开发者更安全高效地进行数据处理。
Java 8 新特性之 Stream API:函数式编程风格的数据处理范式
Java 8 引入的 Stream API 提供了一种新的数据处理方式,支持函数式编程风格,能够高效、简洁地处理集合数据,实现过滤、映射、聚合等操作。
212 6
Java Stream 使用指南
本文介绍了Java中Stream流的使用方法,包括如何创建Stream流、中间操作(如map、filter、sorted等)和终结操作(如collect、forEach等)。此外,还讲解了并行流的概念及其可能带来的线程安全问题,并给出了示例代码。
563 0
Java8中stream流处理数据21个小案例(学习使用)
Java8中stream流处理数据21个小案例(学习使用)
137 0
【Java技术指南】「Java8技术盲区」在奔向Java13的同时,也让我们仔细研究一下Stream的学习认知!
【Java技术指南】「Java8技术盲区」在奔向Java13的同时,也让我们仔细研究一下Stream的学习认知!
196 0
【Java技术指南】「Java8技术盲区」在奔向Java13的同时,也让我们仔细研究一下Stream的学习认知!
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问