RabbitMQ和pika：同一通道上不同队列的不同回调？

Question

我很难理解RabbitMQ的基本概念。我发现在线文档并不十分清楚。

到目前为止，我理解了什么是通道、队列、绑定等。

但如何实现以下用例：

用例：发件人以不同的主题发布到一个交易所。在接收者方面，根据主题，应该通知不同的接收者。

因此，通过主题交换，以下内容应该是可行的：

• 创建频道

我的困难在于回调与通道相关，而与队列或队列绑定无关。我不能百分之百确定我是否在这里。

这就是我的问题：为了有多个回调，IOW：不同的消息处理程序，取决于订阅的主题-您是否必须创建多个通道，每个“不同的消息处理”一个？所有这些通道都应该获取相同的交换并为该特定主题定义自己的队列队列绑定？

请确认这是否正确，或者我是否偏离了AMPQ的规范路径。。。“queue”听起来很轻，所以我直觉地认为队列或队列绑定是连接消费事件处理程序的正确点，但似乎channel是我在这方面的朋友。正当

我问题的另一个方面：

如果我真的必须为此使用多个渠道，我是否必须为每个渠道声明相同的交换（交换名称和交换类型的“主题”）？我希望有这样的东西：

• 使用此名称和“主题”类型定义一次交换
• 对于每个通道，“抓取”此预定义的exchange，并通过向此exchange添加队列和队列绑定来使用它

Answer 1

我发现单独考虑代理（RabbitMQ）和客户机（您的应用程序）的角色很有帮助。

代理RabbitMQ将从您的发布者接收消息，将它们路由到队列，并最终将它们发送给消费者。消息路由可以简单也可以复杂。在您的情况下，路由是基于主题的，有几个不同的队列。

您没有过多谈论发布者，可能是因为他们的工作很简单。他们将带有路由密钥的消息发送到RabbitMQ。

消费者方面是事情变得有趣的地方。在最简单的级别上，使用者订阅队列，从RabbitMQ接收消息，并对其进行处理。使用者打开到RabbitMQ的连接，并将通道用于特定用途（例如，订阅队列）。消息代理的威力在于，如果需要，它们允许设计者将流程分解为单独的应用程序。

除了显示不同的消息主题外，您对应用程序没有太多的了解。一个重要的设计选择是如何定义应用程序。不同的主题是否适用于不同的应用程序，或者单个应用程序是否可以处理所有类型的消息。

对于前一种情况，每个队列将有一个应用程序。订阅队列的单个通道可能是最明智的决定，除非您的应用程序需要线程化。对于线程化应用程序，每个线程都有自己的通道，所有线程都可以订阅到同一队列。每个应用程序都有自己的回调函数来处理该类型的消息。

对于后一种情况（具有多个队列的单个应用程序），最好的方法是每个队列至少有一个通道。听起来每个队列都需要自己的回调函数，您可以根据其订阅将函数分配给通道。如果应用程序可以同时处理（每个主题的）多条消息，则每个队列可能有多个通道。

关于您关于声明交换、队列和绑定的问题，这些项目只需要创建一次。但是让您的客户端在连接时声明它们是合理的做法。声明它们的好处是，如果它们被删除，它们将被再次创建，并且您的声明与代理上的内容之间的任何差异都将触发错误。