pika (python 클라이언트)를 사용하여 RabbitMQ에서 MQTT 메시지 게시/구독

Question

기존 RabittMQ 서버 설정이 있고 MQTT 플러그인이 mqtt 메시지를 게시/구독 할 수 있도록 설정했습니다. 기존 대기열 메시지를 처리 ​​할 pika 클라이언트가 있습니다. 지금 당장은 동일한 pika on_message() 핸들러를 사용하여 mqtt 메시지를 처리하려고합니다. eclipse paho 클라이언트를 통해 mqtt 메시지를 게시하고 구독 할 수 있습니다. 우리는 기존 RabittMQ 클라이언트 (pika)를 사용하고자합니다. MQTT 플러그인은 기본적으로 amq.topic exchange에 게시합니다. 나는 내 자신의 교환에 같은 메시지를 게시하고 싶다. 저에게 이걸 어떻게 얻을 수 있는지 알려주세요.

Answer 1

RabbitMQ 팀은 this mailing list을 모니터링하며 때때로 StackOverflow에 대한 질문에만 답변합니다.

Pika 라이브러리를 사용하는 소비자가 MQTT 메시지를 수신하도록하려면 소비자가 MQTT 메시지가 게시 될 적절한 대기열에 등록해야합니다. MQTT와 AMQP가 상호 운용 될 수있는 방법에 대한 포괄적 인 문서는 here입니다.

그런 다음 "내 메시지를 내 교환기에 게시하고 싶습니다."라고 말합니다. amq.topic 대신 자신의 교환기를 사용하려면 this document의 "맞춤 교환"섹션을 참조하십시오. rabbitmq.config 파일에 교환의 이름을 지정하고 메시지를 게시하기 전에 교환을 생성해야합니다. 이 사용자 정의 교환 은 주제 교환이되어야합니다.

RabbitMQ 문서는 좋은 자료이며 질문이있을 때 거기에서 검색하는 것이 좋습니다.