Java8?Stream教程之collect()的技巧
前言
本身我是一個比較偏向少使用Stream的人,因為調(diào)試比較不方便。
但是, 不得不說,stream確實會給我們編碼帶來便捷。
正文
Stream流 其實操作分三大塊 :
- 創(chuàng)建
- 處理
- 收集
我今天想分享的是 收集 這part的玩法。
OK,開始結(jié)合代碼示例一起玩下:
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的函數(shù):
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() 轉(zhuǎn)換成其他集合/數(shù)組:
現(xiàn)在拿List<UserDTO> 做例子
轉(zhuǎn)成 HashSet<UserDTO> :
List<UserDTO> userList = getUserList(); Stream<UserDTO> usersStream = userList.stream(); HashSet<UserDTO> usersHashSet = usersStream.collect(Collectors.toCollection(HashSet::new));
轉(zhuǎn)成 Set<UserDTO> usersSet :
List<UserDTO> userList = getUserList(); Stream<UserDTO> usersStream = userList.stream(); Set<UserDTO> usersSet = usersStream.collect(Collectors.toSet());
轉(zhuǎn)成 ArrayList<UserDTO> :
List<UserDTO> userList = getUserList(); Stream<UserDTO> usersStream = userList.stream(); ArrayList<UserDTO> usersArrayList = usersStream.collect(Collectors.toCollection(ArrayList::new));
轉(zhuǎn)成 Object[] objects :
List<UserDTO> userList = getUserList(); Stream<UserDTO> usersStream = userList.stream(); Object[] objects = usersStream.toArray();
轉(zhuǎn)成 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)
找出年齡最?。?/strong>
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();
統(tǒng)計數(shù)量:
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; } }));
效果:
多級復(fù)雜分組:
//多級分組 // 1.先根據(jù)年齡分組 // 2.然后再根據(jù)性別分組 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; } }))));
效果:
總結(jié)
到此這篇關(guān)于Java8 Stream教程之collect()技巧的文章就介紹到這了,更多相關(guān)Java8 Stream collect()技巧內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Spring Boot通過Redis實現(xiàn)防止重復(fù)提交
表單提交是一個非常常見的功能,如果不加控制,容易因為用戶的誤操作或網(wǎng)絡(luò)延遲導(dǎo)致同一請求被發(fā)送多次,本文主要介紹了Spring Boot通過Redis實現(xiàn)防止重復(fù)提交,具有一定的參考價值,感興趣的可以了解一下2024-06-06Java中數(shù)組復(fù)制的三種方式小結(jié)
在Java中,數(shù)組復(fù)制是一種常見的操作,它允許開發(fā)人員在不修改原始數(shù)組的情況下創(chuàng)建一個新的數(shù)組,本文就來介紹三種方法,具有一定的參考價值,感興趣的可以了解一下2024-02-02解決Springboot項目打包后的頁面丟失問題(thymeleaf報錯)
這篇文章主要介紹了解決Springboot項目打包后的頁面丟失問題(thymeleaf報錯),具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-11-11詳解J2EE開發(fā)的網(wǎng)站部署到阿里云服務(wù)器的方法
這篇文章主要介紹了詳解J2EE開發(fā)的網(wǎng)站部署到阿里云服務(wù)器的方法,需要的朋友可以參考下2018-01-01Spring MVC 請求參數(shù)綁定實現(xiàn)方式
Spring MVC 是一個用于構(gòu)建 Web 應(yīng)用程序的框架,它提供了一種方便的方式來處理 HTTP 請求和響應(yīng),Spring MVC 提供了多種方式來實現(xiàn)請求參數(shù)綁定,本文結(jié)合實例代碼給大家介紹的非常詳細,需要的朋友跟隨小編一起看看吧2023-09-09springboot的application.yml配置port不生效的解決方案
這篇文章主要介紹了springboot的application.yml配置port不生效的解決方案,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-07-07Mybatis-Plus3.x的創(chuàng)建步驟及使用教程
MyBatis-Plus是一個?MyBatis?的增強工具,在?MyBatis?的基礎(chǔ)上只做增強不做改變,為?簡化開發(fā)、提高效率而生,這篇文章主要介紹了Mybatis-Plus3.x的使用,需要的朋友可以參考下2023-10-10