如何使用gen-server将rabbitmq消费者的响应发送到Erlang中的生产者

如何解决如何使用gen-server将rabbitmq消费者的响应发送到Erlang中的生产者

我有一个 RabbitMq 生产者和消费者。我正在使用带有 gen-server 的 Erlang 编程语言从生产者向消费者发送消息。消费者如何将回复发送回生产者？

解决方法

您必须使用 rabbitmq 队列实现远程过程调用 (RPC) 模式。为了接收响应，客户端需要随请求发送“回调”队列地址。 基本步骤：

1. 在您的客户端应用中创建一个队列以获取响应并订阅它。
2. 为您想要获得响应的每个 rabbitmq 消息添加其他属性：reply_to - 发送响应的队列名称（第 1 页中的队列名称），correlation_id - id 以区分您的请求（在 erlang 中它可以是一个 pid） .
3. 服务器应用处理消息并将响应从 p.1 发布到具有相同关联 ID 的队列。
4. 客户端应用程序队列侦听器收到响应并从correlation_id 向pid 发送erlang 消息。
5. 您的 gen_server 收到响应消息。

关联 ID 使您能够仅创建一个响应队列。 您可以在文档 https://www.rabbitmq.com/tutorials/tutorial-six-elixir.html

中详细阅读