java8 stream中Collectors.toMap空指針問題及解決
Collectors.toMap空指針問題
在工作中遇到了一個List轉(zhuǎn)Map的時候的一個NullPointException.
情形很簡單，問題出在Collectors.toMap，當key值沖突的時候理論上會按照我們的代碼來替換value，但是這里有個小坑
list.stream().collect(Collectors.toMap(it -> it.getCategoryId(), it -> it.getCategoryImage() ,(k1,k2) -> k2));
可以看到map在key值沖突merge的時候會要求新的value不能為null.
這意味著，只要傳入了(k1,k2) -> k2處理key沖突的function，那么當value里存在Null的時候必然會拋NullPointException
Collectors.toMap的坑
按照常規(guī)思維，往一個map里put一個已經(jīng)存在的key，會把原有的key對應的value值覆蓋，然而通過一次線上問題，發(fā)現(xiàn)Java8中的Collectors.toMap反其道而行之，它默認給拋異常，拋異常...
線上業(yè)務代碼出現(xiàn)Duplicate Key的異常，影響了業(yè)務邏輯，查看拋出異常部分的代碼，類似以下寫法：
Map<Integer, String> map = list.stream().collect(Collectors.toMap(Person::getId, Person::getName));
然后list里面有id相同的對象，結(jié)果轉(zhuǎn)map的時候居然直接拋異常了。。查源碼發(fā)現(xiàn)toMap方法默認使用了個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)); };
}那么這個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);
}這里傳進去的是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)用傳進來的方法。而throwingMerger的做法就是拋了個異常。所以到這里就可以知道寫的代碼為什么呲了。。
如果不想拋異常的話，自己傳進去一個方法即可，上述代碼可以改成：
Map<Integer, String> map = list.stream().collect(Collectors.toMap(Person::getId, Person::getName,(oldValue, newValue) -> newValue));
這樣就做到了使用新的value替換原有value。
寫代碼調(diào)方法時，多看源碼實現(xiàn)，注意踩坑！
以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。
相關(guān)文章
SpringBoot解析指定Yaml配置文件的實現(xiàn)過程
這篇文章主要介紹了SpringBoot解析指定Yaml配置文件,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2023-03-03
Enumeration和Iterator接口功能相似，而且Iterator的功能還比Enumeration多，那么為什么還要使用Enumeration2013-09-09
這篇文章主要介紹了java多線程編程之Synchronized塊同步方法，synchronized關(guān)鍵字又稱同步鎖，當方法執(zhí)行完后，會自動釋放鎖鎖，只有一個線程能進入此方法，看看下文中各種例子對synchronized的詳細解釋2015-12-12
最近將IDEA 升級到 IntelliJ IDEA 2021.3.2，在將maven項目導入IDEA后，maven build時報異常，這個問題是IntelliJ IDEA 2021.3.2 不兼容導致的，下面小編給大家?guī)砹薸dea?與?maven?使用過程中遇到的問題及解決方案，感興趣的朋友一起看看吧2022-05-05
本篇文章主要介紹了深入理解Java嵌套類和內(nèi)部類，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2021-07-07
這篇文章主要介紹了淺談spring 線程異步執(zhí)行，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-07-07
這篇文章主要為大家介紹了java哈夫曼樹實例代碼，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2016-08-08
java實現(xiàn)pgsql自動更新創(chuàng)建時間與更新時間的兩種方式小結(jié)
本文主要介紹了java實現(xiàn)pgsql自動更新創(chuàng)建時間與更新時間的兩種方式小結(jié),主要包括通過數(shù)據(jù)庫自身實現(xiàn)以及通過mybatisplus的TableField注解添加,具有一定的參考價值,感興趣的可以了解一下2024-01-01
這篇文章主要介紹了Java實現(xiàn)的mysql事務處理操作,結(jié)合實例形式較為詳細的分析了Java基于JDBC操作mysql數(shù)據(jù)庫實現(xiàn)事務處理的相關(guān)概念、操作技巧與注意事項,需要的朋友可以參考下2018-08-08
java比較器Comparable接口與Comaprator接口的深入分析
本篇文章是對java比較器Comparable接口與Comaprator接口進行了詳細的分析介紹，需要的朋友參考下2013-06-06