文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

使用stream的Collectors.toMap()方法常见问题如何解决

2023-07-05 09:51

关注

本篇内容介绍了“使用stream的Collectors.toMap()方法常见问题如何解决”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!

使用stream的Collectors.toMap()方法常见问题

java8开始的流式编程很大程度上简化了我们的代码,提高了开发效率。

我们经常会使用到stream的Collectors.toMap()来将List转换Map

在使用过程中有两个小坑需要注意

java.lang.IllegalStateException: Duplicate key

java.lang.NullPointerException

第一个是由于在List转Map过程中Map集合的key重复导致的;

第二个是由于在List转Map过程中Map集合的value有null导致的(当存在value值为空时,使用Collectors.toMap()会报NPE,因为底层调用了Map的merge方法,而map方法规定了此处的vlue不能为null,从而抛出空指针异常);

解决方案

Collectors.toMap(dto ->key值 , dto -> dto,(v1,v2) -> v1)

在后面添加(v1,v2)->v1 指定选取第一个值 当key值重复的时候,根据情况而定选取第一个还是第二个)

自定义一个Map来接收,不使用Collectors.toMap()

使用stream的Collectors.toMap()方法常见问题如何解决

第一种情况示例:

import com.google.common.collect.Lists;import java.util.List;import java.util.Map;import java.util.stream.Collectors;import lombok.Data; public class Test {     private static List<User> userList = Lists.newArrayList();     @Data    public static class User {        private String userCode;        private String userName;    }         public static void initData() {        User user1 = new User();        user1.setUserCode("10001");        user1.setUserName("张三");         User user2 = new User();        user2.setUserCode("10002");        user2.setUserName("李四");         User user3 = new User();        user3.setUserCode("10002");        user3.setUserName("王五");         userList.add(user1);        userList.add(user2);        userList.add(user3);    }     public static void main(String[] args) {        initData();        //反例      //  Map<String, String> userMap = userList.stream().collect(Collectors.toMap(User::getUserCode, User::getUserName));         //正例,在后面添加(u1,u2)->u1 指定选取第一个值 当key值重复的时候,根据情况而定选取第一个还是第二个        Map<String, String> userMap = userList.stream().collect(Collectors.toMap(User::getUserCode, User::getUserName, (u1, u2) -> u1));         System.out.println(userMap);    }}

第二种情况示例:

import com.google.common.collect.Lists;import java.util.HashMap;import java.util.List;import java.util.Map;import java.util.stream.Collectors;import lombok.Data; public class Test {     private static List<User> userList = Lists.newArrayList();     @Data    public static class User {        private String userCode;        private String userName;    }         public static void initData() {        User user1 = new User();        user1.setUserCode("10001");        user1.setUserName("张三");         User user2 = new User();        user2.setUserCode("10002");        user2.setUserName("李四");         User user3 = new User();        user3.setUserCode("10003");        user3.setUserName(null);         userList.add(user1);        userList.add(user2);        userList.add(user3);    }     public static void main(String[] args) {        initData();        //反例       // Map<String, String> userMap = userList.stream().collect(Collectors.toMap(User::getUserCode, User::getUserName));         //正例 (如果对转换后的顺序有要求,这里还可以使用LinkedHashMap)        Map<String, String> userMap = userList.stream().collect(HashMap::new, (map, user) -> map.put(user.getUserCode(), user.getUserName()), HashMap::putAll);         System.out.println(userMap);    } }

Stream ToMap(Collectors.toMap) 实践

Requirements

List TO Map

List Stream 转换 Map时向collect()方法中传递Collector对象,对象由Collectors.toMap()方法返回。

如下实现List转换为Map

List<GroupBrandCateBO> list = new ArrayList<>(      Arrays.asList(              new GroupBrandCateBO("v1", "g1", "b1"),              new GroupBrandCateBO("v1", "g1", "b1"),              new GroupBrandCateBO("v3", "g3", "b3")      ));Map<String, String> map = list.stream().collect(Collectors.toMap(item -> item.getVersion(), item -> item.getGroupCode(), (oldVal, currVal) -> oldVal, LinkedHashMap::new)); System.out.println(map.getClass());Map<String, String> map0 = list.stream().collect(Collectors.toMap(item -> item.getVersion(), item -> item.getGroupCode(), (oldVal, currVal) -> oldVal));System.out.println(map0.getClass());System.out.println(map0.toString());Map<String, String> map1 = list.stream().collect(Collectors.toMap(GroupBrandCateBO::getVersion, GroupBrandCateBO::getGroupCode));System.out.println(map1.toString());

Console
class java.util.LinkedHashMap
class java.util.HashMap
{v1=g1, v3=g3}
Exception in thread “main” java.lang.IllegalStateException: Duplicate key g1
at java.util.stream.Collectors.lambda$throwingMerger$0(Collectors.java:133)
&hellip;

问题分析

toMap()函数重载:

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);}public static <T, K, U>Collector<T, ?, Map<K,U>> toMap(Function<? super T, ? extends K> keyMapper,                                Function<? super T, ? extends U> valueMapper,                                BinaryOperator<U> mergeFunction) {    return toMap(keyMapper, valueMapper, mergeFunction, HashMap::new);}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);}private static <T> BinaryOperator<T> throwingMerger() {    return (u,v) -> { throw new IllegalStateException(String.format("Duplicate key %s", u)); };}

补充

关于合并函数

List<GroupBrandCateBO> list = new ArrayList<>(       Arrays.asList(               new GroupBrandCateBO("v1", "g1", "b1"),               new GroupBrandCateBO("v1", "g2", "b2"),               new GroupBrandCateBO("v1", "g2", "b2"),               new GroupBrandCateBO("v3", "g3", "b3")       ));Map<String, String> map00 = list.stream().collect(Collectors.toMap(item -> item.getVersion(), item -> item.getGroupCode(), (oldVal, currVal) -> currVal));Map<String, String> map01 = list.stream().collect(Collectors.toMap(item -> item.getVersion(), item -> item.getGroupCode(), (oldVal, currVal) -> oldVal + currVal));System.out.println(map00.toString());System.out.println(map01.toString());

Console
{v1=g2, v3=g3}
{v1=g1g2g2, v3=g3}

传入Lambda表达式将转化为BinaryOperator<U> mergeFunction对象,合并处理value,非Key!!!

比如:

(oldVal, currVal) -> currVal) // key相同时当前值替换原始值(oldVal, currVal) -> oldVal + currVal //key相同时保留原始值和当前值

“使用stream的Collectors.toMap()方法常见问题如何解决”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注编程网网站,小编将为大家输出更多高质量的实用文章!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     801人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     348人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     311人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     432人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     220人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯