Spring Amqp 内部 NullPointerException on RabbitTemplate convertAndSend-解网

问：

我在尝试使用 RabbitTemplate.convertAndSend 发布消息时随机遇到 NullPointerException

我尝试了spring-amqp：1.7.6和spring-amqp：1.7.8，这应该是我的依赖树的相关部分：

[INFO] | +- org.springframework.amqp:spring-rabbit:jar:1.7.4.RELEASE:compile
[INFO] | | +- com.rabbitmq:http-client:jar:1.1.1.RELEASE:compile
[INFO] | | \- com.rabbitmq:amqp-client:jar:4.0.3:compile

这是异常的堆栈跟踪

org.springframework.amqp.UncategorizedAmqpException: java.lang.NullPointerException
        at org.springframework.amqp.rabbit.support.RabbitExceptionTranslator.convertRabbitAccessException(RabbitExceptionTranslator.java:83)
        at org.springframework.amqp.rabbit.connection.RabbitAccessor.convertRabbitAccessException(RabbitAccessor.java:113)
        at org.springframework.amqp.rabbit.core.RabbitTemplate.doExecute(RabbitTemplate.java:1461)
        at org.springframework.amqp.rabbit.core.RabbitTemplate.execute(RabbitTemplate.java:1411)
        at org.springframework.amqp.rabbit.core.RabbitTemplate.send(RabbitTemplate.java:712)
        at org.springframework.amqp.rabbit.core.RabbitTemplate.convertAndSend(RabbitTemplate.java:813)
        at org.springframework.amqp.rabbit.core.RabbitTemplate.convertAndSend(RabbitTemplate.java:791)

        at io.reactivex.internal.operators.completable.CompletableFromAction.subscribeActual(CompletableFromAction.java:34)
        at io.reactivex.Completable.subscribe(Completable.java:1635)
        at io.reactivex.internal.operators.completable.CompletableCache.subscribeActual(CompletableCache.java:59)
        at io.reactivex.Completable.subscribe(Completable.java:1635)
        at io.reactivex.internal.operators.completable.CompletableSubscribeOn$SubscribeOnObserver.run(CompletableSubscribeOn.java:64)
        at io.reactivex.Scheduler$DisposeTask.run(Scheduler.java:452)
        at io.reactivex.internal.schedulers.ScheduledRunnable.run(ScheduledRunnable.java:61)
        at io.reactivex.internal.schedulers.ScheduledRunnable.call(ScheduledRunnable.java:52)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
        at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.NullPointerException: null
        at sun.reflect.GeneratedMethodAccessor487.invoke(Unknown Source)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at org.springframework.amqp.rabbit.connection.CachingConnectionFactory$CachedChannelInvocationHandler.invoke(CachingConnectionFactory.java:980)
        at com.sun.proxy.$Proxy174.basicPublish(Unknown Source)
        at org.springframework.amqp.rabbit.core.RabbitTemplate.doSend(RabbitTemplate.java:1532)
        at org.springframework.amqp.rabbit.core.RabbitTemplate$3.doInRabbit(RabbitTemplate.java:716)
        at org.springframework.amqp.rabbit.core.RabbitTemplate.doExecute(RabbitTemplate.java:1455)
        ... 19 common frames omitted

关于可能导致这种情况的原因的任何线索？

编辑：附加信息

起初我没有注意到 spring-rabbit 和 spring-amqp 之间的区别，但是在 jar 内部查看我有这些依赖项：

128356 Tue May 29 17:50:46 CEST 2018 lib/spring-amqp-1.7.8.RELEASE.jar
469867 Mon Sep 11 15:28:04 CEST 2017 lib/spring-rabbit-1.7.4.RELEASE.jar
481919 Wed Jun 07 15:25:06 CEST 2017 lib/amqp-client-4.0.3.jar

java nullpointerexception rabbitmq spring-amqp spring-rabbit

synchronized (this.targetMonitor) {
                if (this.target == null) {
                    this.target = createBareChannel(this.theConnection, this.transactional);
                }
                Object result = method.invoke(this.target, args);
                if (this.transactional) {
                    if (txStarts.contains(methodName)) {
                        this.txStarted = true;
                    }
                    else if (txEnds.contains(methodName)) {
                        this.txStarted = false;
                    }
                }
                return result;
            }

注意和进入 .在这些操作之间，可能变成 .这就是下面块的事实：我们在 .因此，其他一些线程可能会导致此属性的争用条件。if (this.target == null) {method.invoke(this.target, args);this.targetnullcatch (InvocationTargetException ex) {this.target = null;synchronized (this.targetMonitor) {target

这就是我对这个问题的意思，这是一个如何解决的建议。NPE

现在我们需要了解不同的线程如何访问相同的线程来导致这样的竞争条件......也许通道的缓存仍然存在一些缺陷。ChannelProxy

当然，如果您尝试使用最新的解决方案，那就太好了，因为您的依赖项仍然将其显示为 .spring-rabbit-1.7.81.7.4

我将尝试在一个简单的项目中重现，但是 ATM 我什至无法在实际项目的测试中重现，它只出现在实时环境中......查看我的代码，我只直接处理连接以创建队列，然后我不关闭该连接，我不确定这是否会在某个时候导致我看到的 NPE。

0赞 Vinay Kumar 5/31/2019 #2

我在实时环境中随机发布时遇到了同样的错误，这是由于创建频道而不是关闭它们。Rabbitmq 的限制为 5000 个通道。这在测试环境中不容易重现，因为它需要打开 5k 通道。

上一个：RuntimeException 无法映射到响应，重新抛出到 HTTP 容器 java.lang.NullPointerException

下一个：Android react 原生 java 空指针异常

Spring Amqp 内部 NullPointerException on RabbitTemplate convertAndSend

Spring Amqp internal NullPointerException on RabbitTemplate convertAndSend

评论

评论