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

Question

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

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

但是如何实现以下用例：

用例：将帖子发送到不同主题的交易所。在接收方方面，根据主题，应通知不同的接收方。

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

• 创建一个频道
• 在这个频道中，创建一个主题交流
• 为每个要订阅的主题，创建一个队列和一个队列绑定，并以此主题为属性

我的困难在于 callback 将与 channel 相关，而不是与 queue 或 queue 绑定时间>。我不是 100% 确定我是否就在这里。

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

请确认这是否正确，或者我是否偏离了 AMPQ 的规范路径......“队列”听起来很轻，所以我直观地认为队列或队列绑定是附加一个正确的点消费事件处理程序，但似乎频道是我的朋友。对吧？

我问题的另一方面：

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

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

Answer 1

我发现分别考虑代理 (RabbitMQ) 和客户端（您的应用程序）的角色很有帮助。

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

您对出版商的评价并不多，可能是因为他们的工作很简单。他们将带有路由键的消息发送到 RabbitMQ。

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

除了存在不同的消息主题外，您不会对您的应用程序提供太多洞察力。您需要做出的一个重要设计选择是如何定义应用程序。不同的主题是否适合单独的应用程序，或者单个应用程序是否可以处理所有类型的消息。

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

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

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