java8 stream中Collectors.toMap空指針問題及解決
Collectors.toMap空指針問題
在工作中遇到了一個(gè)List轉(zhuǎn)Map的時(shí)候的一個(gè)NullPointException.
情形很簡(jiǎn)單，問題出在Collectors.toMap，當(dāng)key值沖突的時(shí)候理論上會(huì)按照我們的代碼來(lái)替換value，但是這里有個(gè)小坑
list.stream().collect(Collectors.toMap(it -> it.getCategoryId(), it -> it.getCategoryImage() ,(k1,k2) -> k2));
可以看到map在key值沖突merge的時(shí)候會(huì)要求新的value不能為null.
這意味著，只要傳入了(k1,k2) -> k2處理key沖突的function，那么當(dāng)value里存在Null的時(shí)候必然會(huì)拋NullPointException
Collectors.toMap的坑
按照常規(guī)思維，往一個(gè)map里put一個(gè)已經(jīng)存在的key，會(huì)把原有的key對(duì)應(yīng)的value值覆蓋，然而通過一次線上問題，發(fā)現(xiàn)Java8中的Collectors.toMap反其道而行之，它默認(rèn)給拋異常，拋異常...
線上業(yè)務(wù)代碼出現(xiàn)Duplicate Key的異常，影響了業(yè)務(wù)邏輯，查看拋出異常部分的代碼，類似以下寫法：
Map<Integer, String> map = list.stream().collect(Collectors.toMap(Person::getId, Person::getName));
然后list里面有id相同的對(duì)象，結(jié)果轉(zhuǎn)map的時(shí)候居然直接拋異常了。。查源碼發(fā)現(xiàn)toMap方法默認(rèn)使用了個(gè)throwingMerger
public static <T, K, U>
Collector<T, ?, Map<K,U>> toMap(Function<? super T, ? extends K> keyMapper,
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? Function<? super T, ? extends U> valueMapper) {
? ? return toMap(keyMapper, valueMapper, throwingMerger(), HashMap::new);
}
?
?
private static <T> BinaryOperator<T> throwingMerger() {
? ? return (u,v) -> { throw new IllegalStateException(String.format("Duplicate key %s", u)); };
}那么這個(gè)throwingMerger是哪里用的呢？
public static <T, K, U, M extends Map<K, U>>
Collector<T, ?, M> toMap(Function<? super T, ? extends K> keyMapper,
? ? ? ? ? ? ? ? ? ? ? ? ? ? Function<? super T, ? extends U> valueMapper,
? ? ? ? ? ? ? ? ? ? ? ? ? ? BinaryOperator<U> mergeFunction,
? ? ? ? ? ? ? ? ? ? ? ? ? ? Supplier<M> mapSupplier) {
? ? BiConsumer<M, T> accumulator
? ? ? ? ? ? = (map, element) -> map.merge(keyMapper.apply(element),
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? valueMapper.apply(element), mergeFunction);
? ? return new CollectorImpl<>(mapSupplier, accumulator, mapMerger(mergeFunction), CH_ID);
}這里傳進(jìn)去的是HashMap，所以最終走的是HashMap的merge方法。merge方法里面有這么一段代碼：
if (old != null) {
? ? V v;
? ? if (old.value != null)
? ? ? ? v = remappingFunction.apply(old.value, value);
? ? else
? ? ? ? v = value;
? ? if (v != null) {
? ? ? ? old.value = v;
? ? ? ? afterNodeAccess(old);
? ? }
? ? else
? ? ? ? removeNode(hash, key, null, false, true);
? ? return v;
}相信只看變量名就能知道這段代碼啥意思了。。如果要put的key已存在，那么就調(diào)用傳進(jìn)來(lái)的方法。而throwingMerger的做法就是拋了個(gè)異常。所以到這里就可以知道寫的代碼為什么呲了。。
如果不想拋異常的話，自己傳進(jìn)去一個(gè)方法即可，上述代碼可以改成：
Map<Integer, String> map = list.stream().collect(Collectors.toMap(Person::getId, Person::getName,(oldValue, newValue) -> newValue));
這樣就做到了使用新的value替換原有value。
寫代碼調(diào)方法時(shí)，多看源碼實(shí)現(xiàn)，注意踩坑！
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
MybatisPlus自定義Sql實(shí)現(xiàn)多表查詢的示例
這篇文章主要介紹了MybatisPlus自定義Sql實(shí)現(xiàn)多表查詢的示例，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-08-08
Quartz是一個(gè)開源的任務(wù)調(diào)度框架?；诙〞r(shí)、定期的策略來(lái)執(zhí)行任務(wù)是它的核心功能，比如x年x月的每個(gè)星期五上午8點(diǎn)到9點(diǎn)，每隔10分鐘執(zhí)行1次，本文重點(diǎn)給大家介紹springboot整合quartz的實(shí)例代碼，感興趣的朋友一起看看吧2022-02-02
SpringBoot實(shí)現(xiàn)權(quán)限驗(yàn)證的示例步驟
權(quán)限驗(yàn)證是一種用于控制對(duì)系統(tǒng)資源和操作的訪問的機(jī)制。它允許開發(fā)人員定義誰(shuí)可以執(zhí)行特定操作或訪問特定資源，并確保只有經(jīng)過授權(quán)的用戶才能執(zhí)行這些操作，這篇文章主要介紹了SpringBoot實(shí)現(xiàn)權(quán)限驗(yàn)證,需要的朋友可以參考下2023-08-08
springboot集成PageHelper分頁(yè)失效的原因及解決
項(xiàng)目啟動(dòng)初期,在集成mybatis的分頁(yè)插件,自定義封裝了一個(gè)分頁(yè)的工具類,方便后期項(xiàng)目的擴(kuò)展,結(jié)果無(wú)法分頁(yè)了,怎么設(shè)置搞都沒辦法正常分頁(yè),所以本文將給大家介紹一下springboot集成PageHelper分頁(yè)失效的原因及解決,需要的朋友可以參考下2023-10-10
詳解如何在SpringBoot中實(shí)現(xiàn)優(yōu)雅關(guān)閉
這篇文章主要介紹了如何在SpringBoot中實(shí)現(xiàn)優(yōu)雅關(guān)閉,SpringBoot應(yīng)用程序的關(guān)閉可以是崩潰,也可以是手動(dòng)關(guān)閉的,Shutdown、Crash 和 Graceful 之間的區(qū)別在于,它控制決定了我們可以用這個(gè)事件做什么,本文中,一起研究下Spring Boot提供的開箱即用功能之一：優(yōu)雅關(guān)閉2024-09-09
本文給大家分享的是一則根據(jù)網(wǎng)友的代碼改編的2048小游戲的源碼，個(gè)人認(rèn)為已經(jīng)非常完美了，推薦給大家，有需要的小伙伴可以參考下。2015-03-03
在本文中我們給大家整理了關(guān)于Java透明窗體的設(shè)置方法以及需要注意的地方，需要的朋友們學(xué)習(xí)參考下。2019-03-03
Java設(shè)計(jì)模式之責(zé)任鏈模式的示例詳解
責(zé)任鏈模式是將鏈中的每一個(gè)節(jié)點(diǎn)看做是一個(gè)對(duì)象，每個(gè)節(jié)點(diǎn)處理的請(qǐng)求均不相同，且內(nèi)部自動(dòng)維護(hù)下一個(gè)節(jié)點(diǎn)對(duì)象，當(dāng)一個(gè)請(qǐng)求從鏈?zhǔn)降氖锥伟l(fā)出時(shí)，會(huì)沿著鏈的路徑依次傳遞給每一個(gè)節(jié)點(diǎn)對(duì)象。本文將通過示例和大家詳細(xì)聊聊責(zé)任鏈模式，需要的可以參考一下2022-11-11
基于SpringBoot實(shí)現(xiàn)自定義插件的流程詳解
在SpringBoot中，插件是一種擴(kuò)展機(jī)制，它可以幫助我們?cè)趹?yīng)用程序中快速地添加一些額外的功能，在本文中，我們將介紹如何使用 SpringBoot實(shí)現(xiàn)自定義插件,需要的朋友可以參考下2023-06-06
Spring Boot整合MybatisPlus逆向工程(MySQL/PostgreSQL)
MyBatis-Plus是MyBatis的增強(qiáng)工具，本文主要介紹了Spring Boot整合MybatisPlus逆向工程(MySQL/PostgreSQL)，具有一定的參考價(jià)值，感興趣的可以了解一下2021-07-07