私は既存のRabittMQサーバーをセットアップしており、MQTTプラグインがmqttメッセージをパブリッシュ/サブスクライブできるようにしました。 既存のキューメッセージを処理するpikaクライアントがあります。今、私は同じpika on_message()ハンドラを使ってmqttメッセージを処理したいと考えています。 eclipse pahoクライアント上でmqttメッセージを発行して購読することができます。既存のRabittMQクライアント(pika)を使用したいと考えています。 MQTTプラグインは、デフォルトでamq.topic exchangeにパブリッシュされます。自分の取引所に同じメッセージを公開したい。私に教えてください、どのようにこれを取得する。pika(pythonクライアント)を使用してRabbitMQでMQTTメッセージをパブリッシュ/サブスクライブする
0
A
答えて
1
RabbitMQチームはthis mailing listを監視し、時々StackOverflowに関する質問に答えます。
Pikaライブラリーを使用しているコンシューマーが、MQTTメッセージを受信するためには、コンシューマーはMQTTメッセージが発行される適切なキューにサブスクライブする必要があります。 MQTTとAMQPの相互運用方法に関する包括的なドキュメントはhereです。
次に、「私は自分の交換に同じメッセージを公開したい」と言う。 amq.topic
の代わりに独自の取引所を使用する場合は、this documentの「カスタム取引」セクションをご覧ください。 rabbitmq.config
ファイルに交換の名前を指定し、メッセージを発行する前に交換を作成する必要があります。このカスタム交換はでなければならないことに注意してください。
RabbitMQのドキュメントは良いリソースであり、質問があるときにそこを検索することをお勧めします。
ありがとうございます。私は正常にmqttクライアントからメッセージを公開し、RabbitMQで受信しています。私は設定ファイルでカスタム交換を設定しました。 – JavaUser
よろしくお願いします。あなたが気にしないなら、私の回答を受け入れられた答えとしてマークしてください。ありがとうございました。 –