Qpid Erlang模块

Question

我是erlang的新手，但我成功地让ActiveMQ使用qpid叉子c库与我的erlang对话，这个库运行良好，我从erlang上的队列本身获得消息，反之亦然。

qpidpn:subscribe("amqp://localhost/topic://xxx").
qpidpn:publish(#{address => "amqp://127.0.0.1/topic://xxx", body => "hello"}).

现在，我希望使用.erl文件实现上述代码，每次在队列上有新消息时都会调用一些函数，并且我可以采取进一步的行动将其返回原点。

Answer 1

您可以实现gen_server，因为消息似乎来自某些MQ。因此，您可以在handle_info中获取消息。一旦到了那里，你可以做任何你想对他们做的事。

Answer 2

那么，这完全取决于您的订阅服务器是如何实现的(是否是另一个进程，TCP侦听器，您是否使用gen_event行为，它是否为您解码任何数据.)。

由于您正在使用AMQP协议进行通信，所以可以使用RabbitMQ作为客户端。您将得到整个AMQP实现(包括对代理的所有响应)，以及一些用于获取消息或订阅通道的模型。代码库是成熟的，整个项目是稳定的，并且大部分逻辑都是为您编写的，所以我强烈建议使用这种方法。

“每次在队列上有新消息时调用的”在下潜到que部分中都有一定的解释。