免费创一个网站活动推广文案
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: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
然后运行两个类。


