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

Posted 2023-03-15

【中文标题】如何使用 gen-server 将来自 rabbitmq 消费者的响应发送到 Erlang 中的生产者

【英文标题】：How to send response from rabbitmq consumer to producer in Erlang with gen-server

【发布时间】：2021-04-12 23:27:43

【问题描述】：

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

【参考方案1】：

您必须使用 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 中实现它