问题

TheRabbitMQ Java client具有以下概念：

  • 连接 - 与RabbitMQ服务器实例的连接
  • 频道 - ???
  • 消费者线程池 - 消耗RabbitMQ服务器队列消息的线程池
  • 队列 - 以FIFO顺序保存消息的结构

我试图理解这种关系，，更重要的是，它们之间的关联。

  • 我还不太确定Channel是什么，除了这是你发布和使用的结构，以及它是从一个开放的连接创建的。如果有人能向我解释"频道"代表什么，那么可能有助于澄清一些事情。
  • 频道和队列之间有什么关系？可以使用相同的通道与多个队列进行通信，还是必须为1：1？
  • Queue和Consumer Pool之间的关系是什么？多个消费者可以订阅同一个队列吗？同一个消费者可以使用多个队列吗？或者是1：1的关系？

在此先感谢你的帮助！

#1 热门回答(137 赞)

  • Connection表示与消息代理的真实TCP连接，而Channel是其中的虚拟连接(AMPQ连接)。这样，你可以在应用程序中使用任意数量的(虚拟)连接，而无需使用TCP连接重载代理。
  • 你可以使用一个频道的一切。但是，如果你有多个线程，建议为每个线程使用不同的Channel。 Java客户端API指南中的通道线程安全性：多个线程可以安全地使用通道实例。对通道的请求被序列化，只有一个线程能够一次在通道上运行命令。即便如此，应用程序应该更喜欢每个线程使用一个Channel，而不是跨多个线程共享相同的Channel。频道和队列之间没有直接关系。 Channel用于向代理发送AMQP命令。这可以是队列或类似的创建，但这些概念并没有捆绑在一起。
  • 每个Consumer在其自己的线程中运行，该线程从使用者线程池分配。如果多个使用者订阅了同一个队列，则代理使用循环法在它们之间平均分配消息。请参阅教程二："工作队列"。也可以将同一个Consumer连接到多个队列。你可以将消费者理解为回调。每当消息到达Consumer绑定的Queue时，就会调用它们。对于Java客户端的情况，每个消费者都有一个方法handleDelivery(...)，它表示回调方法。你通常做的是，继承DefaultConsumer并覆盖handleDelivery(...)。注意：如果将同一个Consumer实例附加到多个队列，则此方法将由不同的线程调用。因此，如有必要，请注意同步。

#2 热门回答(18 赞)

我发现这篇文章解释了AMQP模型的所有方面，其中，渠道就是其中之一。我发现这对我的理解很有帮助
https://www.rabbitmq.com/tutorials/amqp-concepts.html>某些应用程序需要与AMQP代理程序建立多个连接。但是，不希望同时打开许多TCP连接，因为这样做会消耗系统资源并使配置防火墙变得更加困难。 AMQP 0-9-1连接与可被视为"共享单个TCP连接的轻量级连接"的通道复用。对于使用多个线程/进程进行处理的应用程序，每个线程/进程打开一个新通道并且不在它们之间共享通道是很常见的。特定通道上的通信与另一个通道上的通信完全分开，因此每个AMQP方法还带有一个通道号，客户端使用该通道号来确定该方法所针对的通道(例如，需要调用哪个事件处理程序) 。

#3 热门回答(15 赞)

对AMQP协议在"引擎盖下"做什么的一个很好的概念性理解在这里是有用的。我建议AMQP 0.9.1选择部署的文档和API使这一点特别令人困惑，因此问题本身就是许多人不得不努力解决的问题。
TL; DR
Aconnection是物理协商的TCP套接字与AMQP服务器。正确实现的客户端将具有每个应用程序中的一个，线程安全，可在线程之间共享。

Achannelis是连接上的单个应用程序会话。线程将具有一个或多个这些会话。 AMQP体系结构0.9.1是这些不在线程之间共享，并且应该在创建它的线程完成时关闭/销毁它们。当发生各种协议违规时，服务器也会关闭它们。

Aconsumer是一个虚拟结构，表示特定通道上存在"邮箱"。使用者告诉代理将消息从特定队列推送到该通道端点。
连接事实
首先，正如其他人正确指出的那样，a连接是表示与服务器的实际TCP连接的对象。连接在AMQP中的协议级别指定，并且与代理的所有通信都通过一个或多个连接进行。

  • 由于它是一个实际的TCP连接，它有一个IP地址和端口#。
  • 协议参数在每个客户端的基础上协商，作为建立连接的一部分(称为握手的过程)。
  • 它的设计是长寿的;连接闭包是协议设计的一部分的情况很少。
  • 从OSI的角度来看，它可能位于第6层的某个地方
  • 可以设置心跳来监视连接状态，因为TCP本身不包含任何内容来执行此操作。
  • 最好有一个专用线程管理对底层TCP套接字的读写。大多数(如果不是全部)RabbitMQ客户端都这样做。在这方面，它们通常是线程安全的。
  • 相对而言，连接创建"昂贵"(由于握手)，但实际上，这并不重要。大多数进程实际上只需要一个连接对象。但是，如果你发现需要比单个线程/套接字所能提供的吞吐量更多(不太可能使用当前的计算技术)，则可以在池中维护连接。
    频道事实
    A频道是为应用程序的每个部分打开的应用程序会话，以便与RabbitMQ代理进行通信。它通过单一连接进行操作，并代表经纪人。
  • 由于它代表了应用程序逻辑的逻辑部分，因此每个通道通常都存在于自己的线程中。
  • 通常，你的应用程序打开的所有频道将共享一个连接(它们是在连接之上运行的轻量级会话)。连接是线程安全的，所以这没关系。
  • 大多数AMQP操作都是通过渠道进行的。
  • 从OSI Layer的角度来看，频道可能在第7层。
  • 通道设计为瞬态; AMQP的部分设计是通常响应于错误而关闭信道(例如，在删除现有队列之前重新声明具有不同参数的队列)。
  • 由于它们是短暂的，因此你的应用不应将频道合并。
  • 服务器使用整数来标识通道。当管理连接的线程接收到特定信道的分组时，它使用该号码告诉代理该分组属于哪个信道/会话。
  • 通道通常不是线程安全的，因为在线程之间共享它们是没有意义的。如果你有另一个需要使用代理的线程，则需要新的通道。
    消费者事实
    使用者是由AMQP协议定义的对象。它既不是通道也不是连接，而是你的特定应用程序用作丢弃消息的"邮箱"的东西。
  • "创建消费者"意味着你告诉代理(通过连接使用频道)你希望通过该频道向你推送消息。作为回应，经纪人将注册你在频道上有消费者并开始向你推送消息。
  • 通过连接推送的每条消息都将引用频道号和消费者号码。通过这种方式，连接管理线程(在这种情况下，在Java API中)知道如何处理消息;然后，通道处理线程也知道如何处理该消息。
  • 消费者实施具有最广泛的变化，因为它实际上是应用程序特定的。在我的实现中，每次消息通过消费者到达时，我选择分离任务;因此，我有一个管理连接的线程，一个管理通道(和扩展，消费者)的线程，以及通过消费者传递的每个消息的一个或多个任务线程。
  • 关闭连接将关闭所有通道连接。关闭频道会关闭频道上的所有消费者。也可以取消消费者(不关闭频道)。在做这三件事中的任何一件事时，有各种各样的情况。
  • 通常，AMQP客户端中的消费者的实现将为消费者分配一个专用信道，以避免与其他线程或代码(包括发布)的活动冲突。

就消费者线程池的含义而言，我怀疑Java客户端正在做类似我编写客户端的事情(我的客户端基于.Net客户端，但经过大量修改)。

原文链接