PROSAGA码农传奇-rabbitmq-RabbitMQ和通道与连接之间的关系

0# 荀彧. | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”>
  
    对于AMQP协议在“引擎盖下”做什么的一个很好的概念性理解在这里是有用的。我建议AMQP 0.9.1选择部署的文档和API使这一点特别混乱，因此问题本身就是许多人不得不努力解决的问题。
  
  
    的
      TL; DR
    </强>
  
  
    一个
    
      连接
    
     是与AMQP服务器的物理协商TCP套接字。正确实现的客户端将具有每个应用程序中的一个，线程安全，可在线程之间共享。
  
  
    一个
    
      渠道
    
     是连接上的单个应用程序会话。线程将具有一个或多个这些会话。 AMQP体系结构0.9.1是这些不在线程之间共享，并且应该在创建它的线程完成时关闭/销毁它们。当发生各种协议违规时，服务器也会关闭它们。
  
  
    一个
    
      消费者
    
     是一个虚拟结构，表示特定通道上存在“邮箱”。使用者告诉代理将消息从特定队列推送到该通道端点。
  
  
    的
      连接事实
    </强>
  
  
    首先，正如其他人正确指出的那样，
    的
      连接
    </强>
     是表示与服务器的实际TCP连接的对象。连接在AMQP中的协议级别指定，并且与代理的所有通信都通过一个或多个连接进行。
  
  <UL>
    <LI>
      由于它是一个实际的TCP连接，它有一个IP地址和端口＃。
    </LI>
    <LI>
      协议参数是基于每个客户端协商的，作为建立连接的一部分（一个称为
      
        握手
      
      。
    </LI>
    <LI>
      它被设计成
      
        长寿命
      
      ;连接闭包是协议设计的一部分的情况很少。
    </LI>
    <LI>
      从OSI的角度来看，它可能存在于某处
      <a href="https://en.wikipedia.org/wiki/OSI_model" rel="noreferrer">
        第6层
      </A>
    </LI>
    <LI>
      可以设置心跳来监视连接状态，因为TCP本身不包含任何内容来执行此操作。
    </LI>
    <LI>
      最好有一个专用线程管理对底层TCP套接字的读写操作。大多数（如果不是全部）RabbitMQ客户端都这样做。在这方面，它们通常是线程安全的。
    </LI>
    <LI>
      相对来说，连接“创建起来很昂贵”（由于握手），但实际上，这并不重要。大多数进程实际上只需要一个连接对象。但是，如果您发现需要比单个线程/套接字所能提供的更多吞吐量（不太可能使用当前的计算技术），则可以在池中维护连接。
    </LI>
  </UL>
  
    的
      渠道事实
    </强>
  
  
    一个
    的
      渠道
    </强>
     是为应用程序的每个部分打开的应用程序会话，以便与RabbitMQ代理进行通信。它运作一个单一的
    
      连接
    
    ，并代表一个
    
      会议
    
     与经纪人。
  
  <UL>
    <LI>
      由于它代表了应用程序逻辑的逻辑部分，因此每个通道通常都存在于自己的线程中。
    </LI>
    <LI>
      通常，您的应用程序打开的所有频道都将共享一个连接（它们是在连接之上运行的轻量级会话）。连接是线程安全的，所以这没关系。
    </LI>
    <LI>
      大多数AMQP操作都是通过渠道进行的。
    </LI>
    <LI>
      从OSI Layer的角度来看，渠道可能就在附近
      <a href="https://en.wikipedia.org/wiki/OSI_model" rel="noreferrer">
        第7层
      </A>
      。
    </LI>
    <LI>
      的
        通道设计为瞬态的
      </强>
      ; AMQP设计的一部分是通道通常响应于错误而关闭（例如，在删除现有队列之前重新声明具有不同参数的队列）。
    </LI>
    <LI>
      由于它们是短暂的，因此您的应用不应将频道合并。
    </LI>
    <LI>
      服务器使用整数来标识通道。当管理连接的线程接收到特定信道的分组时，它使用该号码告诉代理该分组属于哪个信道/会话。
    </LI>
    <LI>
      通道通常不是线程安全的，因为在它们之间共享它们是没有意义的线程。
      的
        如果您有另一个需要使用代理的线程，则需要新的通道。
      </强>
    </LI>
  </UL>
  
    的
      消费者事实
    </强>
  
  
    使用者是由AMQP协议定义的对象。它既不是通道也不是连接，而是您的特定应用程序用作丢弃消息的“邮箱”的东西。
  
  <UL>
    <LI>
      “创建消费者”意味着您告诉经纪人（使用
      
        渠道
      
       通过一个
      
        连接
      
      ）您希望通过该频道向您推送消息。作为回应，经纪人将注册您拥有
      
        消费者
      
       在频道上，开始向你发送消息。
    </LI>
    <LI>
      通过连接推送的每条消息都将引用a
      
        频道号码
      
       和a
      
        消费者数量
      
      。通过这种方式，连接管理线程（在这种情况下，在Java API中）知道如何处理消息;然后，通道处理线程也知道如何处理该消息。
    </LI>
    <LI>
      消费者实施具有最广泛的变化，因为它实际上是应用程序特定的。在我的实现中，我选择在每次通过消费者到达消息时分离任务;因此，我有一个管理连接的线程，一个管理通道（和扩展，消费者）的线程，以及通过消费者传递的每个消息的一个或多个任务线程。
    </LI>
    <LI>
      关闭一个
      
        连接
      
       关闭连接上的所有通道。关闭一个
      
        渠道
      
       关闭频道上的所有消费者。它也有可能
      
        取消
      
       消费者（不关闭渠道）。在做这三件事中的任何一件都有意义的情况下有各种各样的情况。
    </LI>
    <LI>
      通常，AMQP客户端中的消费者的实现将向消费者分配一个专用信道，以避免与其他线程或代码（包括发布）的活动冲突。
    </LI>
  </UL>
  
    就消费者线程池的含义而言，我怀疑Java客户端正在做类似于我编写客户端的事情（我的基于.Net客户端，但经过大量修改）。
  
</DIV>

1# 诸葛神侯 | 2019-08-31 10-32

2# 土豆 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”>
  <OL>
    <LI>
      
        一个
         <code>
 Connection
 </code>
         表示与消息代理的真实TCP连接，而a
         <code>
 Channel
 </code>
         是一个虚拟连接（AMPQ连接）。这样，您可以在应用程序中使用任意数量的（虚拟）连接，而无需使用TCP连接重载代理。
      
    </LI>
    <LI>
      
        你可以用一个
         <code>
 Channel
 </code>
         为了一切。但是，如果您有多个线程，建议使用不同的线程
         <code>
 Channel
 </code>
         对于每个线程。
      
      
        <a href="http://www.rabbitmq.com/api-guide.html#channel-threads" rel="noreferrer">
          Java客户端API指南中的通道线程安全性
        </A>
        ：
      
      <BLOCKQUOTE>
        
          通道实例可安全地供多个线程使用。请求进入
  频道被序列化，只有一个线程能够运行a
  一次命令在频道上。即便如此，应用程序应该更喜欢
  每个线程使用一个Channel而不是共享同一个Channel
  多线程。
        
      </BLOCKQUOTE>
      
        之间没有直接关系
         <code>
 Channel
 </code>
         和
         <code>
 Queue
 </code>
        。一个
         <code>
 Channel
 </code>
         用于将AMQP命令发送到代理。这可以是队列或类似的创建，但这些概念并没有捆绑在一起。
      
    </LI>
    <LI>
      
        每
         <code>
 Consumer
 </code>
         在从消费者线程池分配的自己的线程中运行。如果多个使用者订阅了同一个队列，则代理使用循环法在它们之间平均分配消息。看到
        <a href="http://www.rabbitmq.com/tutorials/tutorial-two-java.html" rel="noreferrer">
          教程二：“工作队列”
        </A>
        。
      
      
        也可以连接它
         <code>
 Consumer
 </code>
         到多个队列。
您可以将消费者理解为回调。每当消息到达Consumer绑定的Queue时，就会调用它们。对于Java客户端的情况，每个消费者都有一个方法
         <code>
 handleDelivery(...)
 </code>
        ，表示回调方法。你通常做的是，子类
         <code>
 DefaultConsumer
 </code>
         和覆盖
         <code>
 handleDelivery(...)
 </code>
        。注意：如果将同一个Consumer实例附加到多个队列，则此方法将由不同的线程调用。因此，如有必要，请注意同步。
      
    </LI>
  </醇>
</DIV>