PROSAGA码农传奇-rabbitmq-RabbitMQ：为多个消费者发送来自Queue的固定消息

<div class =“post-text”itemprop =“text”>
  
    我认为你已经完成了问题定义。你真正需要的是微不足道的，所以让我们稍微分解一下。
  
  
    鉴于两个队列，
     <code>
 Q1
 </code>
     和
     <code>
 Q2
 </code>
  
  <UL>
    <LI>
      10个消费者
    </LI>
    <LI>
      每个消费者都可以处理来自Q1和Q2的消息。
    </LI>
    <LI>
      在任何给定时间，只有2个消费者应该处理来自Q2的消息。
    </LI>
    <LI>
      所有10个消费者都可以同时处理来自Q1的消息。
    </LI>
  </UL>
  
    的
      对问题陈述的评论
    </强>
  
  
    首先，假设队列是独立的。一个独立的过程
     <code>
 P
 </code>
     会有队列
     <code>
 Q
 </code>
    因此
     <code>
 Q1
 </code>
     服务过程
     <code>
 P1
 </code>
    。这是一个严格的数学要求 - 您无法为单个进程定义两个队列
     <code>
 P
 </code>
    。
  
  
    因此，第二个约束在数学上是不正确的，原因与您无法编写接受类型参数的有效函数相同
     <code>
 string
 </code>
     和
     <code>
 bool
 </code>
     互换。它必须接受一个或另一个，因为它们不是兼容类型，或者它必须接受类型的单个共同祖先而不考虑子类型。这是一个变种
    <a href="https://www.tomdalling.com/blog/software-design/solid-class-design-the-liskov-substitution-principle/" rel="nofollow noreferrer">
      利斯科夫替代原则
    </A>
    。
  
  
    的
      重新定义问题
    </强>
  
  
    系统中共有12个消费者：
  
  <UL>
    <LI>
       <code>
 Q1
 </code>
       有10个消费者
    </LI>
    <LI>
       <code>
 Q2
 </code>
       有2个消费者
    </LI>
    <LI>
      [重要]队列之间不共享消费者
    </LI>
  </UL>
  <BLOCKQUOTE>
    
      我们可以指定RabbitMQ中的任何配置，以便RabbitMQ仅将来自Q2的2条消息推送到任何免费的消费者，并且只有在确认后才推送下两个消息，即使其他消费者是免费的并准备好消费。
    
  </BLOCKQUOTE>
  
    根据问题的新定义，您有两种选择：
  
  <OL>
    <LI>
      用一个
      <a href="https://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.get" rel="nofollow noreferrer">
         <code>
 Basic.Get
 </code>
      </A>
        - 一旦消费者完成处理最后一条消息，就从队列中拉出下一条消息。
    </LI>
    <LI>
      使用
      <a href="https://www.rabbitmq.com/consumer-prefetch.html" rel="nofollow noreferrer">
        消费者预取
      </A>
       这将立即为每个消费者传递第一条和第二条消息，然后在确认该消费者的下一条消息时一次发送一条消息。这有点复杂，但如果您的延迟裕度小于10毫秒，则可能有意义。
    </LI>
  </醇>
  
    的
      注意
    </强>
     通过正确定义问题空间，我们已经消除了试图弄清楚如何确保只有两个消费者正在处理的基本问题
     <code>
 Q2
 </code>
     消息随时。
  
</DIV>