メインコンテンツにスキップ
バージョン: 5.0

RocketMQ MQTT クイックスタート

システム要件​

  • 64ビットOS、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

最後に、メタサービスとmqttブローカーを起動します。distribution/target/binディレクトリに移動して、プロセスを開始します。

sh meta.sh start
sh mqtt.sh start

例の記述​

基本コードはプロジェクトのエンジニアリングコードに記載されています。コード exampleを参照してください。

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