RocketMQ MQTT 快速搭建验证

来自业务的需求，需要快速搭建一套支持 MQTT 协议的消息系统。

前期准备：

官方地址：https://github.com/apache/rocketmq-mqtt
RocketMQ从4.9.3 版本开始才支持该功能，所以需要先检查 RocketMQ 的版本是否满足。
RocketMQ 部署参考：https://rocketmq.apache.org/zh/docs/4.x/deployment/01deploy
JDK 版本： 1.8.x
在 RockerMQ Broker 的配置中增加如下配置，开启多队列分发特性：

enableLmq = true 
enableMultiDispatch = true

RocketMQ 的部署忽略（网上文章很多），下面开始 RocketMQ MQTT 的部署、验证

构建 RocketMQ MQTT

下载工程：
最新代码：

git clone https://github.com/apache/rocketmq-mqtt

发布版本：
https://github.com/apache/rocketmq-mqtt/releases

构建工程：
进入到代码根目录，执行 mvn 命令

cd rocketmq-mqtt
mvn -Prelease-all -DskipTests clean install -U

配置 RocketMQ MQTT：

cd distribution/target/xxx

target 目录一直往下，看到
在这里插入图片描述
进入 conf:

cd conf

配置 meta.conf
在这里插入图片描述
selfAddress 部署 meta 的地址
memberAddress 可以是一组部署了 meta 的地址
我这里都是单节点

配置 service.conf
在这里插入图片描述
username 和 secretKey 在发布、订阅时认证需要
NAMESRV_ADDR ns 地址
eventNotifyRetryTopic 事件通知消息重试 Topic，提前创建
clientRetryTopic 客户端消息重试 Topic，提前创建
metaAddr 就用 meta.conf 中的地址

创建 Topic:

mqadmin updateTopic -n 10.22.34.179:9876 -c DefaultCluster -t eventNotifyRetryTopic
mqadmin updateTopic -n 10.22.34.179:9876 -c DefaultCluster -t clientRetryTopic
mqadmin updateTopic -n 10.22.34.179:9876 -c DefaultCluster -t testTopic

初始化元数据：
配置网关：

mqadmin updateKvConfig -s LMQ -k LMQ_CONNECT_NODES -v 10.22.34.179 -n 10.22.34.179:9876

配置一级 Topic:

mqadmin updateKvConfig -s LMQ -k ALL_FIRST_TOPICS -v eventNotifyRetryTopic,clientRetryTopic,testTopic -n 10.22.34.179:9876

配置每个一级 Topic 的通配符:

mqadmin updateKvConfig -s LMQ -k eventNotifyRetryTopic -v testTopic/+ -n 10.22.34.179:9876
mqadmin updateKvConfig -s LMQ -k clientRetryTopic -v testTopic/+ -n 10.22.34.179:9876
mqadmin updateKvConfig -s LMQ -k testTopic -v testTopic/+ -n 10.22.34.179:9876

踩坑一： 后面新增的 Topic 没走配置一级 Topic 这步，mqtt 消费订阅发布不正常。
注意： 后期新增 Topic，首先需要创建、然后配置一级 Topic、然后配置一级 Topic 的通配符，否则会出现发布订阅预期外的情况。
以上步骤走完后，就可以启动工程了。

启动 RocketMQ MQTT：

cd bin
sh meta.sh start
sh mqtt.sh start

命令执行后确认是否执行成功：
jps -l 可以看到下面两个进程：
org.apache.rocketmq.mqtt.cs.starter.Startup
org.apache.rocketmq.mqtt.meta.starter.MetaStartup
查看端口是否被监听：
meta: 25000
mqtt: 1883

如果端口没被监听或者发布订阅有报错，到 $HOME/logs/xx.log 查看具体日志。
在这里插入图片描述
踩坑二： 进程存在，1883 一直没被监听，看启动日志是连 ns 出现了超时。
踩坑三： 部署到服务器上，发布时用户名和密码填正确的也报错。

原因：执行命令后，需要使用到 $JAVA_HOME/jre/lib/ext/ 文件夹下的相关 jar 包，但是由于系统的原因，无法使用该包下的 jar 包
解决：手动将 $JAVA_HOME/jre/lib/ext/ 下 sunjce_provider.jar 包复制到 target/xx/lib 目录下即可

调试 RocketMQ MQTT：

示例代码：https://github.com/apache/rocketmq-mqtt/tree/main/mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
发布消息：
在这里插入图片描述
订阅消息：

客户端调试工具：MQTTX
MQTTX 发布订阅消息：