rocketMQ可以正常启动并连接,也可以正常收发消息,但是MQTT这一块就会有点问题,按照官网执行mvn -Prelease-all -DskipTests clean install -U命令后得到一个名为rocketmq-mqtt-1.0.2-SNAPSHOT的文件夹我直接启动无法启动,但根据个人理解修改了\bin\runserver.sh文件后启动成功,下面我会把文件内容贴出来,但是启动成功后无法连接一直提示下面这两条错误
[DefaultChannelManager] Close Connect of channel [id: 0xab970f62, L:0.0.0.0/0.0.0.0:1883] from SERVER by reason of Auth Failed
[DefaultChannelManager] Close Connect of channel [id: 0xab970f62, L:0.0.0.0/0.0.0.0:1883] from CLIENT by reason of be closed
我目前的环境信息为服务器系统环境为centos7.9,Java环境为 Java 11 ,rocketMQ版本为rocketmq-5.2.0,rocketMQ-mqtt版本为 rocketmq-mqtt-1.0.2-SNAPSHOT。
这是我修改后的runserver.sh文件内容:
runserver.sh.txt
这是启动后检查启动的命令。
[root@localhost ~]# jps -l
16309 org.apache.rocketmq.broker.BrokerStartup
16231 org.apache.rocketmq.namesrv.NamesrvStartup
21128 org.apache.rocketmq.mqtt.meta.starter.MetaStartup
21854 jdk.jcmd/sun.tools.jps.Jps
21391 org.apache.rocketmq.mqtt.cs.starter.Startup
这是rocketmq-mqtt-1.0.2-SNAPSHOT/conf/service.conf的配置信息
service.conf.txt
rocketMQ可以正常启动并连接,也可以正常收发消息,但是MQTT这一块就会有点问题,按照官网执行mvn -Prelease-all -DskipTests clean install -U命令后得到一个名为rocketmq-mqtt-1.0.2-SNAPSHOT的文件夹我直接启动无法启动,但根据个人理解修改了\bin\runserver.sh文件后启动成功,下面我会把文件内容贴出来,但是启动成功后无法连接一直提示下面这两条错误 [DefaultChannelManager] Close Connect of channel [id: 0xab970f62, L:0.0.0.0/0.0.0.0:1883] from SERVER by reason of Auth Failed [DefaultChannelManager] Close Connect of channel [id: 0xab970f62, L:0.0.0.0/0.0.0.0:1883] from CLIENT by reason of be closed 我目前的环境信息为服务器系统环境为centos7.9,Java环境为 Java 11 ,rocketMQ版本为rocketmq-5.2.0,rocketMQ-mqtt版本为 rocketmq-mqtt-1.0.2-SNAPSHOT。 这是我修改后的runserver.sh文件内容: runserver.sh.txt 这是启动后检查启动的命令。 [root@localhost ~]# jps -l 16309 org.apache.rocketmq.broker.BrokerStartup 16231 org.apache.rocketmq.namesrv.NamesrvStartup 21128 org.apache.rocketmq.mqtt.meta.starter.MetaStartup 21854 jdk.jcmd/sun.tools.jps.Jps 21391 org.apache.rocketmq.mqtt.cs.starter.Startup 这是rocketmq-mqtt-1.0.2-SNAPSHOT/conf/service.conf的配置信息 service.conf.txt