207

RabbitMQ Java 客户端有以下概念：

  • Connection- 与 RabbitMQ 服务器实例的连接
  • Channel- ？？？
  • 消费者线程池 - 从 RabbitMQ 服务器队列中消费消息的线程池
  • 队列 - 一种以 FIFO 顺序保存消息的结构

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

  1. 我仍然不太确定 aChannel是什么，除了这是您发布和使用的结构，并且它是从开放连接创建的。如果有人可以向我解释“频道”代表什么，它可能有助于澄清一些事情。
  2. Channel和Queue是什么关系？可以使用同一个 Channel 与多个 Queue 进行通信，还是必须是 1:1？
  3. Queue和Consumer Pool是什么关系？多个消费者可以订阅同一个队列吗？同一个Consumer可以消费多个Queue吗？还是1:1的关系？
4

4 回答 4

228

  1. AConnection表示到消息代理的真实 TCP 连接，而 aChannel是其中的虚拟连接（AMQP 连接）。这样，您可以在应用程序中使用任意数量的（虚拟）连接，而不会因 TCP 连接而使代理过载。

  2. 你可以用一个Channel来做任何事情。但是，如果您有多个线程，建议Channel为每个线程使用不同的线程。

    Java 客户端 API 指南中的通道线程安全：

    通道实例可以安全地被多个线程使用。对 Channel 的请求是序列化的，一次只有一个线程能够在 Channel 上运行命令。即便如此，应用程序应该更喜欢每个线程使用一个 Channel，而不是在多个线程之间共享同一个 Channel。

    Channel和之间没有直接关系Queue。AChannel用于向代理发送 AMQP 命令。这可以是队列或类似的创建，但这些概念并没有联系在一起。

  3. 每个都Consumer在从消费者线程池分配的自己的线程中运行。如果多个 Consumer 订阅了同一个 Queue，则 broker 使用循环方式在它们之间平均分配消息。请参阅教程二：“工作队列”。

    也可以将其附加Consumer到多个队列。您可以将消费者理解为回调。每次消息到达消费者绑定的队列时都会调用这些。对于 Java Client 来说，每个 Consumer 都有一个 method handleDelivery(...)，代表回调方法。您通常做的是子类化DefaultConsumer和覆盖handleDelivery(...)。注意：如果将同一个 Consumer 实例附加到多个队列中，该方法将被不同的线程调用。因此，如有必要，请注意同步。

于 2013-08-24T14:07:04.430 回答
67

对 AMQP 协议“在幕后”所做的事情有一个很好的概念性理解在这里很有用。我会提供 AMQP 0.9.1 选择部署的文档和 API 使这特别令人困惑，所以这个问题本身就是许多人必须努力解决的问题。

TL;博士

连接是与AMQP 服务器协商的物理 TCP 套接字。正确实现的客户端将在每个应用程序中拥有其中一个，线程安全的，可在线程之间共享。

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

消费者是一个虚拟构造，表示特定频道上存在“邮箱”。消费者的使用告诉代理将消息从特定队列推送到该通道端点。

连接事实

首先，正如其他人正确指出的那样，连接是代表与服务器的实际 TCP 连接的对象。连接是在 AMQP 的协议级别指定的，与代理的所有通信都通过一个或多个连接进行。

  • 因为它是一个实际的 TCP 连接，所以它有一个 IP 地址和端口号。
  • 协议参数是在每个客户端的基础上协商的，作为建立连接的一部分（一个称为握手的过程。
  • 它被设计为长寿命；连接关闭是协议设计的一部分的情况很少。
  • 从 OSI 的角度来看，它可能位于第 6 层附近
  • 可以设置心跳来监视连接状态，因为 TCP 本身不包含任何内容来执行此操作。
  • 最好有一个专用线程管理对底层 TCP 套接字的读取和写入。大多数（如果不是全部）RabbitMQ 客户端都会这样做。在这方面，它们通常是线程安全的。
  • 相对而言，创建连接是“昂贵的”（由于握手），但实际上，这并不重要。大多数进程实际上只需要一个连接对象。但是，如果您发现需要比单个线程/套接字提供的吞吐量更高的吞吐量（在当前的计算技术下不太可能），您可以在池中维护连接。

渠道事实

Channel是为应用程序的每个部分打开的应用程序会话，用于与 RabbitMQ 代理进行通信。它通过单个连接运行，并代表与代理的会话。

  • 由于它代表应用程序逻辑的逻辑部分，因此每个通道通常存在于自己的线程上。
  • 通常，您的应用打开的所有通道都将共享一个连接（它们是在连接之上运行的轻量级会话）。连接是线程安全的，所以没关系。
  • 大多数 AMQP 操作都是通过通道进行的。
  • 从 OSI 层的角度来看，通道可能在第 7 层左右。
  • 通道被设计为瞬态的；AMQP 设计的一部分是通道通常会关闭以响应错误（例如，在删除现有队列之前重新声明具有不同参数的队列）。
  • 由于它们是瞬态的，因此您的应用程序不应汇集通道。
  • 服务器使用整数来标识通道。当管理连接的线程接收到特定通道的数据包时，它使用此编号告诉代理该数据包属于哪个通道/会话。
  • 通道通常不是线程安全的，因为在线程之间共享它们是没有意义的。如果您有另一个线程需要使用代理，则需要一个新通道。

消费者事实

消费者是 AMQP 协议定义的对象。它既不是通道也不是连接，而是您的特定应用程序用作某种“邮箱”来丢弃消息的东西。

  • “创建消费者”意味着您告诉代理（通过连接使用通道）您希望通过该通道将消息推送给您。作为响应，代理将注册您在通道上有消费者并开始向您推送消息。
  • 通过连接推送的每条消息都将引用一个通道号和一个消费者号。这样，连接管理线程（在这种情况下，在 Java API 中）知道如何处理消息；然后，通道处理线程也知道如何处理该消息。
  • 消费者实现具有最广泛的变化，因为它实际上是特定于应用程序的。在我的实现中，我选择在每次消息通过消费者到达时分拆一个任务；因此，我有一个管理连接的线程，一个管理通道的线程（以及扩展的消费者），以及通过消费者传递的每条消息的一个或多个任务线程。
  • 关闭连接会关闭连接上的所有通道。关闭通道会关闭通道上的所有消费者。也可以取消消费者（不关闭通道）。在各种情况下，做这三件事中的任何一件都是有意义的。
  • 通常，AMQP 客户端中消费者的实现会为消费者分配一个专用通道，以避免与其他线程或代码（包括发布）的活动发生冲突。

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

于 2018-02-13T15:21:47.283 回答
24

我发现这篇文章解释了 AMQP 模型的所有方面，其中通道就是其中之一。我发现它对完善我的理解很有帮助

https://www.rabbitmq.com/tutorials/amqp-concepts.html

一些应用程序需要多个连接到 AMQP 代理。然而，同时打开许多 TCP 连接是不可取的，因为这样做会消耗系统资源并使配置防火墙更加困难。AMQP 0-9-1 连接与通道复用，可以被认为是“共享单个 TCP 连接的轻量级连接”。

对于使用多个线程/进程进行处理的应用程序，很常见的是为每个线程/进程打开一个新的通道，并且它们之间不共享通道。

特定通道上的通信与另一个通道上的通信完全分开，因此每个 AMQP 方法还带有一个通道号，客户端使用该通道号来确定该方法用于哪个通道（因此，例如，需要调用哪个事件处理程序） .

于 2015-03-13T09:52:19.783 回答
10

就像一个 TCP 连接可以有多个 Channels之间存在关系。

Channel：它是连接内的虚拟连接。当从队列发布或使用消息时 - 这一切都通过一个通道完成而Connection：它是您的应用程序和 RabbitMQ 代理之间的 TCP 连接。

在多线程架构中，您可能需要每个线程单独的连接。这可能会导致 TCP 连接的未充分利用，还会增加操作系统在网络高峰期建立所需数量的 TCP 连接的开销。系统的性能可能会大大降低。这是通道派上用场的地方，它在 TCP 连接中创建虚拟连接。它直接减少了操作系统的开销，还允许我们以更快、更可靠和同时的方式执行异步操作。 在此处输入图像描述

于 2020-01-06T13:15:07.437 回答