search

apache / rocketmq-mqtt

Apache rocketmq
https://rocketmq.apache.org/
Apache License 2.0
183 stars 64 forks source link

一直写java.lang.NullPointerException: null日志，每天产生60G日志 #221

Open vinnyyou opened 11 months ago

vinnyyou commented 11 months ago

一直在写如下日志，每天产生60G消息，请问这是什么问题 java.lang.NullPointerException: null at org.apache.rocketmq.mqtt.common.util.TopicUtils.decode(TopicUtils.java:116) at org.apache.rocketmq.mqtt.cs.session.match.MatchAction.matchClients(MatchAction.java:54) at org.apache.rocketmq.mqtt.cs.session.notify.MessageNotifyAction.notify(MessageNotifyAction.java:60) at org.apache.rocketmq.mqtt.cs.protocol.rpc.RpcPacketDispatcher.doNotify(RpcPacketDispatcher.java:75) at org.apache.rocketmq.mqtt.cs.protocol.rpc.RpcPacketDispatcher.processRequest(RpcPacketDispatcher.java:56) at org.apache.rocketmq.remoting.netty.NettyRemotingAbstract$1.run(NettyRemotingAbstract.java:229) at org.apache.rocketmq.remoting.netty.RequestTask.run(RequestTask.java:80) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) 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)

DongyuanPan commented 11 months ago

哪个版本的？

vinnyyou commented 11 months ago

版本号rocketmq-4.9.7， rocketket-mqtt 1.0.1

leizhiyuan commented 11 months ago

可以debug，或者arthas看一下，这个消息体

image

这里的分支覆盖不全，看着确实如果没有mqtt的属性，就不会设置topic，就会导致为null

ShiXulu commented 11 months ago

消息无法消费，产生大量的retry消息，然后走到这儿又不被认为是mqtt消息（因为检查user property中没有PROPERTY_ORIGIN_MQTT_TOPIC属性）。

ShiXulu commented 11 months ago

消息无法消费，产生大量的retry消息，然后走到这儿又不被认为是mqtt消息（因为检查user property中没有PROPERTY_ORIGIN_MQTT_TOPIC属性）。

然后，也没有PROPERTY_INNER_MULTI_DISPATCH这个属性，最终event中的topic为空。 另一线程处理event，跑到matchClients这里，TopicUtils.decode(topic)里面未做空判断，直接NPE。

话说回来，消息为啥消费不了？跑的example里面的consumer，依然无法消费。 还有mqttx死活都连不上去，就算用example里面的签名方法处理之后，一样不行。

DongyuanPan commented 10 months ago

消息无法消费，产生大量的retry消息，然后走到这儿又不被认为是mqtt消息（因为检查user property中没有PROPERTY_ORIGIN_MQTT_TOPIC属性）。

然后，也没有PROPERTY_INNER_MULTI_DISPATCH这个属性，最终event中的topic为空。 另一线程处理event，跑到matchClients这里，TopicUtils.decode(topic)里面未做空判断，直接NPE。

话说回来，消息为啥消费不了？跑的example里面的consumer，依然无法消费。 还有mqttx死活都连不上去，就算用example里面的签名方法处理之后，一样不行。

这个问题应该是RMQ没有开启LMQ这个特性导致的；用example里面的签名方法处理之后应该是需要Base64字符串才能使用在mqttx上。 image 只需要取前半部分的就可以了，不要输入toCharArray的。mqttx会对字符串再求一次