java8 stream中Collectors.toMap空指针问题及解决
作者:好大的月亮 时间:2023-01-16 13:05:28
Collectors.toMap空指针问题
在工作中遇到了一个List转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的坑
按照常规思维,往一个map里put一个已经存在的key,会把原有的key对应的value值覆盖,然而通过一次线上问题,发现Java8中的Collectors.toMap反其道而行之,它默认给抛异常,抛异常...
线上业务代码出现Duplicate Key的异常,影响了业务逻辑,查看抛出异常部分的代码,类似以下写法:
Map<Integer, String> map = list.stream().collect(Collectors.toMap(Person::getId, Person::getName));
然后list里面有id相同的对象,结果转map的时候居然直接抛异常了。。查源码发现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已存在,那么就调用传进来的方法。而throwingMerger的做法就是抛了个异常。所以到这里就可以知道写的代码为什么呲了。。
如果不想抛异常的话,自己传进去一个方法即可,上述代码可以改成:
Map<Integer, String> map = list.stream().collect(Collectors.toMap(Person::getId, Person::getName,(oldValue, newValue) -> newValue));
这样就做到了使用新的value替换原有value。
写代码调方法时,多看源码实现,注意踩坑!
来源:https://blog.csdn.net/weixin_43944305/article/details/119913697
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
C#中的位操作小结
Spring IOC与DI核心深入理解
c# 如何实现不同进程之间的通信
c# 生成随机时间的小例子
js 交互在Flutter 中使用 webview_flutter
![](https://img.aspxhome.com/file/2023/5/91785_0s.jpg)
AndroidStudio4.0 New Class的坑(小结)
![](https://img.aspxhome.com/file/2023/6/96006_0s.png)
C# 创建EXCEL图表并保存为图片的实例
![](https://img.aspxhome.com/file/2023/7/81047_0s.png)
android基于SwipeRefreshLayout实现类QQ的侧滑删除
![](https://img.aspxhome.com/file/2023/2/138352_0s.gif)
Java for循环几种写法整理
Android中Fab(FloatingActionButton)实现上下滑动的渐变效果
![](https://img.aspxhome.com/file/2023/1/126661_0s.gif)
MyBatis 如何配置多个别名 typeAliasesPackage
C# 面向对象三大特性:封装、继承、多态
Elasticsearch学习之Terms set 查询
java实现文件归档和还原
![](https://img.aspxhome.com/file/2023/7/102127_0s.jpg)
android使用AsyncTask实现多线程下载实例
![](https://img.aspxhome.com/file/2023/3/138373_0s.png)
Spring boot配置文件加解密详解
![](https://img.aspxhome.com/file/2023/3/59583_0s.jpg)
SpringCloud远程服务调用实战笔记
Java并发编程之volatile与JMM多线程内存模型
![](https://img.aspxhome.com/file/2023/3/62203_0s.png)
Android自定义View实现圆环进度条
![](https://img.aspxhome.com/file/2023/8/137388_0s.gif)
Android开发中TextView 实现右上角跟随文本动态追加圆形红点
![](https://img.aspxhome.com/file/2023/3/139573_0s.gif)