RocketMQ MQTT Windows10 环境启动
- 参考
- 环境和软件版本
- 下载资源
- 启动RocketMQ
- 启动RocketMQ MQTT
参考
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。
-
解压
RocketMQ
-
配置环境变量
- 配置
broker.properties
在RocketMQ_HOME/conf目录下创建broker.properties文件，加入配置，等号前后不要后空格
enableLmq=true
enableMultiDispatch=true
- 启动
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不会被启动。文件路径是绝对路径
- 创建主题
这里就按照参考博客里面的命令。
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:25000service.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
然后运行两个类。
