rabbitmq - Pika RabbitMQ 客户端服务可以消费和发布消息吗？

Question

有 Pika 经验的人能否就以下功能是否可行，或者我的想法是否表明对 Pika 缺乏概念性理解，快速回答是/否。

我想要的功能:

Python 服务(单线程脚本)使用 SelectConnection 适配器连接到我的 RabbitMQ 代理。

该连接有两个 channel 。

服务使用一个 channel A 声明一个队列并绑定(bind)到某个交换器 E1。另一个 channel B 用于声明其他一些交换 E2。

服务通过 A 从队列中消费消息。它对这些消息进行一些小处理，[可能通过其与 MongoDB 实例的连接执行 CRUD 操作]，然后发布消息以通过 B 交换 E2。

我已经通读了 Pika 文档，但没有找到足够的信息来了解这是否可行。

简单地说 - 一个 python 脚本可以通过一个 selectconnection 适配器连接同时发布和使用吗？

Answer 1

当然可以。您可以通过多种方式实现这一点(通过相同的连接、不同的连接、相同的 channel 、不同的 channel 等)

我过去实现此功能时所做的是，我创建我的连接，获取 channel 并使用它的委托(delegate)(函数)设置我的消费者。当我的消费消息函数被调用时，我得到了它附带的 channel 参数，我随后使用它来将下一条消息发布到不同的队列。如果您不想使用相同的 channel ，那么您可以简单地设置另一个 channel 。