跳至主要內容
版本：5.0

RocketMQ MQTT 快速入門

系統需求​

  • 建議使用 64 位元作業系統，Linux/Unix/macOS
  • 64 位元 JDK 1.8+

部署說明​

由於 RocketMQ-MQTT 專案依賴於 RocketMQ 的底層多佇列分佈，RocketMQ 從 4.9.3 版本開始支援此功能，因此您需要確認 RocketMQ 版本已升級至 4.9.3 或更新版本，並確保已啟用下列設定項目

enableLmq = true 
enableMultiDispatch = true

有關 RocketMQ-MQTT 的部署，請參閱專案說明，下載專案發布版本或直接從原始碼建置。

git clone https://github.com/apache/rocketmq-mqtt
cd rocketmq-mqtt 
mvn -Prelease-all -DskipTests clean install -U 
cd distribution/target/

建置原始碼後，編輯 conf/service.conf 以完成與 MQTT 相關的設定，如下所示

username=xxx    // Authorization verification account configuration
secretKey=xxx    // Authorization verification account configuration
NAMESRV_ADDR=xxx  //namesrv access point
eventNotifyRetryTopic=xx   //notify retry topic, created in advance
clientRetryTopic=xx  //Client message retry topic, created in advance

其他啟動設定和前置步驟參考專案 README.md

最後啟動 meta 服務，然後啟動 mqtt 代理程式。前往 distribution/target/bin 目錄並啟動程序。

sh meta.sh start
sh mqtt.sh start

範例說明​

專案工程碼中提供了基本程式碼，請參閱程式碼 範例

MqttConsumer.java  // MQTT client initiates subscription message
MqttProducer.java   // MQTT client starts publishing messages
RocketMQConsumer.java // RocketMQ client starts subscription message
RocketMQProducer.java  // RocketMQ client starts publishing messages