使用groupingby的lambda表达式一个错误小计

最新推荐文章于 2024-07-07 16:34:58 发布
最新推荐文章于 2024-07-07 16:34:58 发布
阅读量885 收藏
点赞数 1
分类专栏： java+
版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
本文链接：https://blog.csdn.net/sky_jiangcheng/article/details/108656208
版权
本文通过一个实际案例，探讨了使用Java Stream API结合Lambda表达式进行数据处理时可能遇到的NullPointerException异常，并详细分析了异常产生的原因及解决办法。

摘要生成于 C知道 ，由 DeepSeek-R1 满血版支持， 前往体验 >

使用lambda表达式方便，开发速度加快了很多，但是容易出现问题不好定位的情况，这里简单记一下今天晚上遇到的一个问题，是要提醒自己，使用lambda表达式，先做好校验，如果出了错，一般就要从数据上查找原因。写一个测试用例：

List<AllocateVO> alllocates = list.stream()
                .map(e -> {
                    AllocateVO vo = new AllocateVO();
                    vo.setDepartmentCode(e.getDeptCode());
                    vo.setDepartmentName(e.getDeptName());
                    vo.setAttr(e.getDeptAttr());
                    vo.setInstruction(e.getInstruction());
                    return vo;
                }).collect(Collectors.toList());

        Map allocateMap = alllocates.stream().collect(Collectors.groupingBy(AllocateVO::getProcessId));

上面这段代码就出现了一个错误，报错日志如下：

java.lang.NullPointerException: element cannot be mapped to a null key
        at java.util.Objects.requireNonNull(Objects.java:228)
        at java.util.stream.Collectors.lambda$groupingBy$45(Collectors.java:907)
        at java.util.stream.ReduceOps$3ReducingSink.accept(ReduceOps.java:169)
        at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
        at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1374)
        at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481)
        at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471)
        at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
        at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
        at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499)
        at cn.gov.nantong.backend.service.impl.GovLinkageIntEventServiceImpl.getInnerProcess(GovLinkageIntEventServiceImpl.java:624)
        at cn.gov.nantong.backend.service.impl.GovLinkageIntEventServiceImpl.eventDetail(GovLinkageIntEventServiceImpl.java:512)
        at cn.gov.nantong.backend.service.impl.GovLinkageIntEventServiceImpl$$FastClassBySpringCGLIB$$bc714e3a.invoke(<generated>)
        at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)
        at org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:749)
        at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)
        at org.springframework.aop.interceptor.ExposeInvocationInterceptor.invoke(ExposeInvocationInterceptor.java:93)
        at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)
        at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688)
        at cn.gov.nantong.backend.service.impl.GovLinkageIntEventServiceImpl$$EnhancerBySpringCGLIB$$53d4bd88.eventDetail(<generated>)
        at cn.gov.nantong.backend.controller.GovLinkageIntEventController.getEventDetail(GovLinkageIntEventController.java:80)
        at sun.reflect.GeneratedMethodAccessor721.invoke(Unknown Source)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:190)
        at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:138)
        at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:104)
        at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:892)
        at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:797)
        at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)
        at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1039)
        at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:942)
        at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1005)
        at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:897)
        at javax.servlet.http.HttpServlet.service(HttpServlet.java:634)
        at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:882)
        at javax.servlet.http.HttpServlet.service(HttpServlet.java:741)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
        at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
        at org.springframework.boot.actuate.web.trace.servlet.HttpTraceFilter.doFilterInternal(HttpTraceFilter.java:88)
        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:118)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
        at cn.gov.nantong.backend.base.filter.CorsFilter.doFilter(CorsFilter.java:57)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
        at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:99)
        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:118)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
        at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:92)
        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:118)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
        at org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:93)
        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:118)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
        at org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.filterAndRecordMetrics(WebMvcMetricsFilter.java:114)
        at org.springframework.boot.actuate.metrics.web.servlet.WebMvcMetricsFilter.doFilterInternal(WebMvcMetricsFilter.java:104)
        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:118)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
        at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:200)
        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:118)
        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
        at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:202)
        at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96)
        at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:526)
        at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:139)
        at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92)
        at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74)
        at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343)
        at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:408)
        at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66)
        at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:860)
        at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1587)
        at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
        at java.lang.Thread.run(Thread.java:748)

日志中很容易看出来是空指针，结果截取日志，写了一个用例找到原因了，因为list对象里的processId没有赋值，

又是一个粗心大意出现的错误，感觉学到了新知识~

java中收集器分组函数 Collectors.groupingBy() 的用法详解
hkl_Forever的博客
01-01 4118
【2】推荐写法二，Collectors.toMap() 会使用 Function.identity() 或 o -> o 确定使用对象，BinaryOperator.minBy()或maxBy() 则用来规定比较属性，例如按分数、id等取最大或最小的那条数据。java的 stream 流是非常重要的特性，在开发中是必备的技能，这里着重分析一下 Collectors.groupingBy() 的各种用法。1、代码示例，在第六步的基础上优化。【1】以上二种写法是等效的。
Java Lambda表达式多场景下使用详解
最新发布
qu1210的博客
03-23 1148
Lambda表达式是Java 8引入的一个重要特性，它允许我们以更简洁的方式表示匿名函数。本教程将详细介绍Java Lambda表达式的语法、用法和应用场景。Java Lambda表达式的基本语法如下： 参数列表：可以为空或包含多个参数，类型可以显式声明或由编译器推断 箭头操作符： 将参数列表与Lambda体分开 Lambda体：包含表达式或语句块 1.2 简化规则 Lambda表达式可以根据以下规则进行简化： 2. 函数式接口 Lambda表达式需要与函数式接口配合使用。函数式接口是只包含一个抽象方法
java8 lambada使用Collectors.groupingBy分组顺序错误
weixin_38987366的博客
05-29 1344
最近有个需求就是按照stations(工位) 分组排序但是一直数据都是错乱的，后来查了资料 可以看到有三个参数，第一个参数就是key的Function了，第二个参数是一个map工厂，也就是最终结果的容器，一般默认的是采用的HashMap::new，最后一个参数很重要是一个downstream，类型是Collector，也是一个收集器，那就是说，这三个参数其实就是为了解决分组问题的 第一个参数：分组按照什么分类 第二个参数：分组最后用什么容器保存返回 第三个参数：按照第一个参数分类后，对应的分类...
JAVA8 LAMBDA表达式 GROUPINGBY 分组操作
az44yao的专栏
05-17 6164
https://www.cnblogs.com/doudou2018/p/11107071.html 实体类 package utill; /** * @author YangTao * @date 2019/6/17 21:06 */ public class Student { int age; String username; String code; public Student() { } public Student(int age
Lambda表达式之map reduce & groupingBy
Jeff 的专栏
09-28 3040
1. map & reduce reduce操作可以实现从一组值中生成一个值。count、min、max方法，因为常用而被纳入到标准库中。事实上，这些方法都是reduce操作。 2. 使用收集器 前面使用过collect(toList())在流中生成Lst，但是有时人们还希望从流中生成其他集合（如：Set或Map），或者你希望定制一个类将你想要的东西抽象出来。 这就是“收集器”，只
java8 lambda groupingby 分组保持原来顺序
weixin_45942583的博客
09-13 744
returnRemindList.stream() .collect(Collectors.groupingBy(TopicRemindSettingBO::getRemindPhone, LinkedHashMap::new, Collectors.toCollection(ArrayList::new))); returnRemindList 是已经排序好序的集合，groupingBy 分组后map是不保持有序， 加入如下2个参数可以保持原来的顺序输出 LinkedHashMap::new,.
编译器说 Lambda 表达式中的变量必须是 final 的，我偏不信
12-22
当尝试在Lambda表达式内部修改一个变量时，编译器会报错，提示“variable used in lambda expression should be final or effectively final”。 这个限制源于Java规范，规定Lambda表达式中引用的任何局部变量、...
lambda表达式 java求和_Lambda【1】-- List相关Lambda表达式使用（上篇）
weixin_39716264的博客
02-28 1949
Lambda在jdk1.8里面已经很好用了，在这里不讲底层的实现，只有简单的用法，会继续补全。首先一个list我们要使用lambda的话，需要使用它的stream()方法，获取流，才能使用后续的方法。基础类User.javapublic class User {public long userId;public User() {}public User(long userId, String na...
Lambda表达式 & Stream流
异侠
07-07 935
Lambda表达式 & Stream流
Java8实战：集合、CompletableFuture、lambda表达式与ForkJoin
- **新的收集器**：Collectors类提供了一系列方便的收集器，如groupingBy、partitioningBy等，使得数据分组、分区变得非常方便。 ### CompletableFuture CompletableFuture是Java 8引入的一个用于异步编程的类，...
Java8 Lambda - groupingBy 后再排序、累加、计数、查找...
noob_can的博客
05-10 4061
java8 groupingBy的Lambda写法
java 8 lambda表达式 distinct、groupingBy、filter、forEach、map、sorted、limit、max、anyMatch、allMatch、noneMatch
努力努力，努力努力的博客
07-22 4002
java 8 lambda表达式 distinct、groupingBy、filter、forEach、map、sorted、limit、max、min、anyMatch、allMatch、noneMatch
Java解决stream流Collectors.groupingBy 分组统计可能报空指针异常
Java学习
09-22 5015
在使用stream流的Collectors.groupingBy做分组统计时（示例代码如下）解决方法为在统计之前增加一个filter方法将null值事先过滤掉。如果统计的字段userName有null值则会报如下错误。
记一波Lambda表达式中List转Map使用groupingby进行分组遇到的问题（附解决方案）
askwill的博客
10-09 5301
在把查询出来的数据进行筛选排序之后，需要对获取的数据进行排序时，使用lambda中的groupingBy进行数据分组转成map，这个时候发觉map内的分组顺序并不是按照自己list的顺序来进行分组的，在经过排查后，最终发现在封装的groupingby方法中，使用的是hashmap进行存储，由于HashMap的特性限制，效率快但他封装数据时并不记录数据的插入顺序，因此出现了排序被打乱的情况. 最后经...
lambda 流操作归纳
皮球
08-06 492
今天来学习最后一个操作方法collect 日常流式操作后，需要对结果处理，则可以用这个方法来实现。 collect(Collector<? super P_OUT, A, R> collector) 这里我们首先要学一下Collectors这个类，这个类里有个静态内部类是Collector的实现类，也就是说，Collectors类里的静态方法内部实现都是基于Collector的实现类 Collectors.toCollection(Supplier collectionFactory) 这个方法
java8 lambda中stream、collectors
hao_hl1314的博客
05-23 719
使用map加reduce操作符实现 List&lt;String&gt; list=Arrays.asList(new String[]{"1.0","3","2","5.2","4"}); Double total=list.stream().map(BigDecimal::new).reduce((sum,item)-&gt;sum.add(item)).map(BigDeci
java8 lambada表达式Collectors.groupingBy分组顺序无序
以爱护甲,爱满枫林。
11-25 2812
代码： package com.java; import java.util.ArrayList; import java.util.Comparator; import java.util.List; import java.util.Map; import java.util.concurrent.TimeUnit; import java.util.stream.Collectors...
lambda$groupingBy 空指针问题
spumetime1的博客
10-14 3260
开发功能时，用到了stream的collect(Collectors.groupingBy)方法，一直报NullPorintException，废了一些时间来定位问题，虽然最后其实比较简单。 记录一下，以下代码会报空指针 public static void main( String[] args ) { List<Student> list=new ArrayList<>(); list.add(new Student("A",
Java 8中Collectors.groupingBy方法空指针异常源码分析
ranxiaotop的博客
08-01 3773
Collectors.groupingBy()方法是如何产生空指针的呢？本文通过源码的方式来分析具体的原因，同时给出常见的解决方式
评论 1
添加红包

请填写红包祝福语或标题

个

红包个数最小为10个

元

红包金额最低5元

当前余额3.43元 前往充值 >
需支付：10.00元
成就一亿技术人!
领取后你会自动成为博主和红包主的粉丝 规则
hope_wisdom
发出的红包
实付元
使用余额支付
点击重新获取
扫码支付
钱包余额 0

抵扣说明：

1.余额是钱包充值的虚拟货币，按照1:1的比例进行支付金额的抵扣。
2.余额无法直接购买下载，可以购买VIP、付费专栏及课程。

余额充值