RocketMQ MQTT Windows10 环境启动

参考

https://blog.csdn.net/weixin_43114058/article/details/140043257

https://blog.csdn.net/yangxiaovip/article/details/138355443

环境和软件版本

操作系统：Win10
IDEA、JDK1.8、Rocket MQTT 1,0,2-SNAPSHOT、RocketMQ 5.1.3

下载资源

从RocketMQ官网下载对应的RocketMQ版本

把源码和二进制文件都下载下来，二进制在本机跑，看源码协助配置。

下载RocketMQ MQTT，从https://gitcode.com/gh_mirrors/roc/rocketmq-mqtt/overview

直接下载zip文件即可。

启动RocketMQ

按照参考文章里面的配置启动RocketMQ。

1. 解压RocketMQ
   

2. 配置环境变量

3. 配置broker.properties
   在RocketMQ_HOME/conf目录下创建broker.properties文件，加入配置，等号前后不要后空格

enableLmq=true 
enableMultiDispatch=true

4. 启动nameserver和broker

到RocketMQ_HOME/bin目录下，双击mqnamesrv.cmd。

依然在RocketMQ/bin目录下，启动broker

mqbroker.cmd -n localhost:9876 -c D:\soft\RocketMQ\rocketmq-all-5.1.3-bin-release\conf\broker.properties

这里要指定配置文件，否则LMQ不会被启动。文件路径是绝对路径

5. 创建主题
   这里就按照参考博客里面的命令。

mqadmin.cmd updateTopic -n localhost:9876 -c DefaultCluster -t eventNotifyRetryTopic
mqadmin.cmd updateTopic -n localhost:9876 -c DefaultCluster -t clientRetryTopic
mqadmin.cmd updateTopic -n localhost:9876 -c DefaultCluster -t testTopicmqadmin.cmd updateKvConfig -s LMQ -k LMQ_CONNECT_NODES -v localhost -n localhost:9876
mqadmin.cmd updateKvConfig -s LMQ -k ALL_FIRST_TOPICS -v eventNotifyRetryTopic,clientRetryTopic,testTopic -n localhost:9876mqadmin.cmd updateKvConfig -s LMQ -k eventNotifyRetryTopic -v testTopic/# -n localhost:9876
mqadmin.cmd updateKvConfig -s LMQ -k clientRetryTopic -v testTopic/# -n localhost:9876
mqadmin.cmd updateKvConfig -s LMQ -k testTopic -v testTopic/# -n localhost:9876

启动RocketMQ MQTT

用idea打开下载好的rocketmq-mqtt项目。勾选release-allmaven选项，安装依赖到本地。

把distribution/conf加入classpath。加入模块mqtt-meta和mqtt-cs。

依照参考博客，修改distribution/conf下的三个文件。

connect.conf

mqttPort=1883enablePrometheus=true

meta.conf

selfAddress=127.0.0.1:25000
membersAddress=127.0.0.1:25000

service.conf

username=test
secretKey=testNAMESRV_ADDR=localhost:9876
eventNotifyRetryTopic=eventNotifyRetryTopic
clientRetryTopic=clientRetryTopicmetaAddr=127.0.0.1:25000

然后先启动mqtt-meta模块下的类org.apache.rocketmq.mqtt.meta.starter.MetaStartup

再启动模块mqtt-cs的类org.apache.rocketmq.mqtt.cs.starter.Startup

打开mqtt-example模块，修改类MqttProducer
修改brokerUrl、主题、账号密码


同样，修改MqttConsumer
然后运行两个类。