RabbitMQ (MQTT) как отправить ответное сообщение от потребителя издателю?

Question

[kondratev-ad]

Я пытаюсь найти информацию о том, как отправить ответ издателю. Я хочу использовать протокол MQTT. Есть ли какой-нибудь способ сделать это? Мне нужно, чтобы publisher отправил сообщение RabbitMQ, consumer получил его, обработал и отправил результат работы обратно publisher`y.

В протоколе AMQP это реализуется с помощью удаленного вызова процедуры (RPC)

Пример для AMQP:

result = channel.queue_declare(queue='', exclusive=True)
callback_queue = result.method.queue

channel.basic_publish(exchange='',
                      routing_key='rpc_queue',
                      properties=pika.BasicProperties(
                            reply_to = callback_queue,
                            ),
                      body=request)

Comments

[d'Ivan]

А почему не создать новую очередь для отправки сообщений в обратную сторону?

[kondratev-ad]

Роман Мирр, а если несколько publisher`ов и несколько consumer`ов, то как узнать какому publisher`у нужно вернуть сообщение?

[d'Ivan]

kondratev-ad, сначала получить от издателя сообщение с его идентификатором, а затем использовать его при отправке обратно, в другой очереди.

[kondratev-ad]

Роман Мирр, вариант, но интересно, нет ли более изящного способа, типо как с amqt

Answer 1

[Alexandr M.]

странный подход. ты хочешь заставить буферное звено отвечать за гарантированную доставку. Может посмотреть в сторону кафки, тогда с таким подходом?
Суть кролика, из пункта А сообщение кинули в кролика, из пункта Б подключились к кролику и забрали сообщение из кролика. Кролик тут банально выполняет функцию полки(поставили/забрали книгу)