【发布时间】：2021-04-12 23:27:43
【问题描述】：
我有一个 RabbitMq 生产者和消费者。我正在使用带有 gen-server 的 Erlang 编程语言从生产者向消费者发送消息。如何将消费者的回复发送回生产者？
【问题讨论】：
标签： rabbitmq erlang gen-server
【发布时间】：2021-04-12 23:27:43
【问题描述】：
您必须使用 rabbitmq 队列来实现远程过程调用 (RPC) 模式。为了接收响应，客户端需要随请求发送一个“回调”队列地址。 基本步骤：
- 在您的客户端应用程序中创建一个队列以获取响应并订阅它。
- 为您希望获得响应的每个 rabbitmq 消息添加其他属性：reply_to - 发送响应的队列名称（第 1 页中的队列名称），correlation_id - 用于区分您的请求的 id（在 erlang 中它可以是 pid） .
- 服务器应用程序处理消息并将响应从 p.1 发布到具有相同关联 ID 的队列。
- 客户端应用程序队列侦听器获取响应并从相关 ID 向 pid 发送 erlang 消息。
- 您的 gen_server 收到响应消息。
关联 ID 使您能够仅创建一个响应队列。 您可以在文档https://www.rabbitmq.com/tutorials/tutorial-six-elixir.html
中详细阅读【讨论】：
-
任何可用的例子。如何在 Erlang 中实现它