前言

日常開(kāi)發(fā)中，我們很多時(shí)候需要用到Java 8的Lambda表達(dá)式，它允許把函數(shù)作為一個(gè)方法的參數(shù)，讓我們的代碼更優(yōu)雅、更簡(jiǎn)潔。所以整理了一波工作中，我常用的，有哪些Lambda表達(dá)式。看完一定會(huì)有幫助的。

基于 Spring Boot + MyBatis Plus + Vue & Element 實(shí)現(xiàn)的后臺(tái)管理系統(tǒng) + 用戶小程序，支持 RBAC 動(dòng)態(tài)權(quán)限、多租戶、數(shù)據(jù)權(quán)限、工作流、三方登錄、支付、短信、商城等功能

• 項(xiàng)目地址：https://github.com/YunaiV/ruoyi-vue-pro
• 視頻教程：https://doc.iocoder.cn/video/

1. list 轉(zhuǎn) map

工作中，我們經(jīng)常遇到list轉(zhuǎn)map的案例。Collectors.toMap就可以把一個(gè)list數(shù)組轉(zhuǎn)成一個(gè)Map。代碼如下：

publicclassTestLambda{

publicstaticvoidmain(String[]args){

ListuserInfoList=newArrayList<>();
userInfoList.add(newUserInfo(1L,"芋道源碼",18));
userInfoList.add(newUserInfo(2L,"程序員芋艿",27));
userInfoList.add(newUserInfo(2L,"打代碼的芋艿",26));

/**
*list轉(zhuǎn)map
*使用Collectors.toMap的時(shí)候，如果有可以重復(fù)會(huì)報(bào)錯(cuò)，所以需要加(k1,k2)->k1
*(k1,k2)->k1表示，如果有重復(fù)的key,則保留第一個(gè)，舍棄第二個(gè)
*/
MapuserInfoMap=userInfoList.stream().collect(Collectors.toMap(UserInfo::getUserId,userInfo->userInfo,(k1,k2)->k1));
userInfoMap.values().forEach(a->System.out.println(a.getUserName()));
}
}

//運(yùn)行結(jié)果
芋道源碼
程序員芋艿

類似的，還有Collectors.toList()、Collectors.toSet()，表示把對(duì)應(yīng)的流轉(zhuǎn)化為list或者Set。

基于 Spring Cloud Alibaba + Gateway + Nacos + RocketMQ + Vue & Element 實(shí)現(xiàn)的后臺(tái)管理系統(tǒng) + 用戶小程序，支持 RBAC 動(dòng)態(tài)權(quán)限、多租戶、數(shù)據(jù)權(quán)限、工作流、三方登錄、支付、短信、商城等功能

• 項(xiàng)目地址：https://github.com/YunaiV/yudao-cloud
• 視頻教程：https://doc.iocoder.cn/video/

2. filter（）過(guò)濾

從數(shù)組集合中，過(guò)濾掉不符合條件的元素，留下符合條件的元素。

ListuserInfoList=newArrayList<>();
userInfoList.add(newUserInfo(1L,"芋道源碼",18));
userInfoList.add(newUserInfo(2L,"程序員芋艿",27));
userInfoList.add(newUserInfo(3L,"打代碼的芋艿",26));

/**
*filter過(guò)濾，留下超過(guò)18歲的用戶
*/
ListuserInfoResultList=userInfoList.stream().filter(user->user.getAge()>18).collect(Collectors.toList());
userInfoResultList.forEach(a->System.out.println(a.getUserName()));

//運(yùn)行結(jié)果
程序員芋艿
打代碼的芋艿

3. foreach 遍歷

foreach 遍歷list，遍歷map，真的很絲滑。

/**
*forEach遍歷集合List列表
*/
ListuserNameList=Arrays.asList("芋道源碼","程序員芋艿","艿艿");
userNameList.forEach(System.out::println);

HashMaphashMap=newHashMap<>();
hashMap.put("公眾號(hào)","芋道源碼");
hashMap.put("職業(yè)","程序員芋艿");
hashMap.put("昵稱","艿艿");
/**
*forEach遍歷集合Map
*/
hashMap.forEach((k,v)->System.out.println(k+":	"+v));

//運(yùn)行結(jié)果
芋道源碼
程序員芋艿
打代碼的芋艿
職業(yè):程序員芋艿
公眾號(hào):芋道源碼
昵稱:艿艿

4. groupingBy 分組

提到分組，相信大家都會(huì)想起SQL的group by。我們經(jīng)常需要一個(gè)List做分組操作。比如，按城市分組用戶。在Java8之前，是這么實(shí)現(xiàn)的：

ListoriginUserInfoList=newArrayList<>();
originUserInfoList.add(newUserInfo(1L,"芋道源碼",18,"深圳"));

originUserInfoList.add(newUserInfo(3L,"打代碼的芋艿",26,"湛江"));
originUserInfoList.add(newUserInfo(2L,"程序員芋艿",27,"深圳"));
Map>result=newHashMap<>();
for(UserInfouserInfo:originUserInfoList){
Stringcity=userInfo.getCity();
ListuserInfos=result.get(city);
if(userInfos==null){
userInfos=newArrayList<>();
result.put(city,userInfos);
}
userInfos.add(userInfo);
}

而使用Java8的groupingBy分組器，清爽無(wú)比:

Map>result=originUserInfoList.stream()
.collect(Collectors.groupingBy(UserInfo::getCity));

5. sorted+Comparator 排序

工作中，排序的需求比較多，使用sorted+Comparator排序，真的很香。

ListuserInfoList=newArrayList<>();
userInfoList.add(newUserInfo(1L,"芋道源碼",18));
userInfoList.add(newUserInfo(3L,"打代碼的芋艿",26));
userInfoList.add(newUserInfo(2L,"程序員芋艿",27));

/**
*sorted+Comparator.comparing排序列表，
*/
userInfoList=userInfoList.stream().sorted(Comparator.comparing(UserInfo::getAge)).collect(Collectors.toList());
userInfoList.forEach(a->System.out.println(a.toString()));

System.out.println("開(kāi)始降序排序");

/**
*如果想降序排序，則可以使用加reversed()
*/
userInfoList=userInfoList.stream().sorted(Comparator.comparing(UserInfo::getAge).reversed()).collect(Collectors.toList());
userInfoList.forEach(a->System.out.println(a.toString()));

//運(yùn)行結(jié)果
UserInfo{userId=1,userName='芋道源碼',age=18}
UserInfo{userId=3,userName='打代碼的芋艿',age=26}
UserInfo{userId=2,userName='程序員芋艿',age=27}
開(kāi)始降序排序
UserInfo{userId=2,userName='程序員芋艿',age=27}
UserInfo{userId=3,userName='打代碼的芋艿',age=26}
UserInfo{userId=1,userName='芋道源碼',age=18}

6.distinct 去重

distinct可以去除重復(fù)的元素:

Listlist=Arrays.asList("A","B","F","A","C");
Listtemp=list.stream().distinct().collect(Collectors.toList());
temp.forEach(System.out::println);

7. findFirst 返回第一個(gè)

findFirst 很多業(yè)務(wù)場(chǎng)景，我們只需要返回集合的第一個(gè)元素即可：

Listlist=Arrays.asList("A","B","F","A","C");
list.stream().findFirst().ifPresent(System.out::println);

8. anyMatch 是否至少匹配一個(gè)元素

anyMatch 檢查流是否包含至少一個(gè)滿足給定謂詞的元素。

Streamstream=Stream.of("A","B","C","D");
booleanmatch=stream.anyMatch(s->s.contains("C"));
System.out.println(match);
//輸出
true

9. allMatch 匹配所有元素

allMatch 檢查流是否所有都滿足給定謂詞的元素。

Streamstream=Stream.of("A","B","C","D");
booleanmatch=stream.allMatch(s->s.contains("C"));
System.out.println(match);
//輸出
false

10. map 轉(zhuǎn)換

map方法可以幫我們做元素轉(zhuǎn)換，比如一個(gè)元素所有字母轉(zhuǎn)化為大寫(xiě)，又或者把獲取一個(gè)元素對(duì)象的某個(gè)屬性，demo如下：

Listlist=Arrays.asList("jay","tianluo");
//轉(zhuǎn)化為大寫(xiě)
ListupperCaselist=list.stream().map(String::toUpperCase).collect(Collectors.toList());
upperCaselist.forEach(System.out::println);

11. Reduce

Reduce可以合并流的元素，并生成一個(gè)值

intsum=Stream.of(1,2,3,4).reduce(0,(a,b)->a+b);
System.out.println(sum);

12. peek 打印個(gè)日志

peek()方法是一個(gè)中間Stream操作，有時(shí)候我們可以使用peek來(lái)打印日志。

Listresult=Stream.of("程序員芋艿","芋道源碼","打代碼的芋艿")
.filter(a->a.contains("芋艿"))
.peek(a->System.out.println("關(guān)注公眾號(hào):"+a)).collect(Collectors.toList());
System.out.println(result);
//運(yùn)行結(jié)果
關(guān)注公眾號(hào):程序員芋艿
關(guān)注公眾號(hào):芋道源碼
[程序員芋艿,芋道源碼]

13. Max，Min 最大最小

使用lambda流求最大，最小值，非常方便。

ListuserInfoList=newArrayList<>();
userInfoList.add(newUserInfo(1L,"芋道源碼",18));
userInfoList.add(newUserInfo(3L,"打代碼的芋艿",26));
userInfoList.add(newUserInfo(2L,"程序員芋艿",27));

OptionalmaxAgeUserInfoOpt=userInfoList.stream().max(Comparator.comparing(UserInfo::getAge));
maxAgeUserInfoOpt.ifPresent(userInfo->System.out.println("maxageuser:"+userInfo));

OptionalminAgeUserInfoOpt=userInfoList.stream().min(Comparator.comparing(UserInfo::getAge));
minAgeUserInfoOpt.ifPresent(userInfo->System.out.println("minageuser:"+userInfo));

//運(yùn)行結(jié)果
maxageuser:UserInfo{userId=2,userName='程序員芋艿',age=27}
minageuser:UserInfo{userId=1,userName='芋道源碼',age=18}

14. count 統(tǒng)計(jì)

一般count()表示獲取流數(shù)據(jù)元素總數(shù)。

ListuserInfoList=newArrayList<>();
userInfoList.add(newUserInfo(1L,"芋道源碼",18));
userInfoList.add(newUserInfo(3L,"打代碼的芋艿",26));
userInfoList.add(newUserInfo(2L,"程序員芋艿",27));

longcount=userInfoList.stream().filter(user->user.getAge()>18).count();
System.out.println("大于18歲的用戶:"+count);
//輸出
大于18歲的用戶:2

15. 常用函數(shù)式接口

其實(shí)lambda離不開(kāi)函數(shù)式接口，我們來(lái)看下JDK8常用的幾個(gè)函數(shù)式接口：

• Function（轉(zhuǎn)換型）: 接受一個(gè)輸入?yún)?shù)，返回一個(gè)結(jié)果
• Consumer （消費(fèi)型）: 接收一個(gè)輸入?yún)?shù)，并且無(wú)返回操作
• Predicate （判斷型）: 接收一個(gè)輸入?yún)?shù)，并且返回布爾值結(jié)果
• Supplier （供給型）: 無(wú)參數(shù)，返回結(jié)果

Function 是一個(gè)功能轉(zhuǎn)換型的接口，可以把將一種類型的數(shù)據(jù)轉(zhuǎn)化為另外一種類型的數(shù)據(jù)

privatevoidtestFunction(){
//獲取每個(gè)字符串的長(zhǎng)度，并且返回
Functionfunction=String::length;
Streamstream=Stream.of("程序員芋艿","芋道源碼","打代碼的芋艿");
StreamresultStream=stream.map(function);
resultStream.forEach(System.out::println);
}

Consumer是一個(gè)消費(fèi)性接口，通過(guò)傳入?yún)?shù)，并且無(wú)返回的操作

privatevoidtestComsumer(){
//獲取每個(gè)字符串的長(zhǎng)度，并且返回
Consumercomsumer=System.out::println;
Streamstream=Stream.of("程序員芋艿","芋道源碼","打代碼的芋艿");
stream.forEach(comsumer);
}

Predicate是一個(gè)判斷型接口,并且返回布爾值結(jié)果.

privatevoidtestPredicate(){
//獲取每個(gè)字符串的長(zhǎng)度，并且返回
Predicatepredicate=a->a>18;
UserInfouserInfo=newUserInfo(2L,"程序員芋艿",27);
System.out.println(predicate.test(userInfo.getAge()));
}

Supplier是一個(gè)供給型接口,無(wú)參數(shù)，有返回結(jié)果。

privatevoidtestSupplier(){
Suppliersupplier=()->Integer.valueOf("666");
System.out.println(supplier.get());
}

這幾個(gè)函數(shù)在日常開(kāi)發(fā)中，也是可以靈活應(yīng)用的，比如我們DAO操作完數(shù)據(jù)庫(kù)，是會(huì)有個(gè)result的整型結(jié)果返回。我們就可以用Supplier來(lái)統(tǒng)一判斷是否操作成功。如下：

privatevoidsaveDb(Suppliersupplier){
if(supplier.get()>0){
System.out.println("插入數(shù)據(jù)庫(kù)成功");
}else{
System.out.println("插入數(shù)據(jù)庫(kù)失敗");
}
}

@Test
publicvoidadd()throwsException{
Coursecourse=newCourse();
course.setCname("java");
course.setUserId(100L);
course.setCstatus("Normal");
saveDb(()->courseMapper.insert(course));
}

審核編輯 ：李倩