4.19. 配置环队列

流程

1. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

2. 要在不匹配地址上为没有设置显式环大小的所有队列定义默认环大小，请在 address-setting 元素中为 default-ring-size 指定一个值。例如：

   <address-settings>
      <address-setting match="ring.#">
         <default-ring-size>3</default-ring-size>
      </address-setting>
   </address-settings>

   Copy to Clipboard Toggle word wrap

   default-ring-size 参数对于定义自动创建队列的默认大小特别有用。default-ring-size 的默认值为 -1 ( 即没有大小限制)。

3. 要在特定队列中定义环大小，请将 ring-size 键添加到 queue 元素。指定一个值。例如：

   <addresses>
      <address name="myRing">
         <anycast>
            <queue name="myRing" ring-size="5" />
         </anycast>
      </address>
   </addresses>

   Copy to Clipboard Toggle word wrap

1. 生产者将三个消息发送到配置了 ring-size="3" 的环队列。

2. 所有消息都会立即分配给消费者。

   此时，messageCount= 3 和 deliver Count= 3。

3. 生产者向队列发送另一条消息。然后，将消息分配给消费者。

   现在，messageCount = 4 和 deliverCount = 4。消息计数为 4 大于配置的环大小 3。但是，代理会义务来允许这种情况，因为它无法从队列中删除发送的消息。

4. 现在，假设消费者在不确认任何消息的情况下关闭。

   在这种情况下，四个在发送中，未确认的消息将被取消回代理，并按它们所消耗的相反顺序添加到队列头。此操作会使队列超出其配置的环大小。由于环队列更喜欢队列尾部的消息，该队列会丢弃生成者发送的第一个消息，因为这是最后一个消息添加到队列的头。事务或核心会话回滚以同样的方式处理。

1. 在 12:00，生成者将消息 A 发送到配置了 ring-size="3" 的环队列。该消息被调度为 12:05。

   此时，messageCount= 1 和 scheduledCount= 1。

2. 在 12:01，生成者将消息 B 发送到同一环队列。

   now, messageCount= 2 和 scheduledCount= 1。

3. 在 12:02 时，生成者将消息 C 发送到同一环队列。

   现在，messageCount= 3 和 scheduledCount= 1。

4. at 12:03, producer 将消息 D 发送到同一环队列。

   现在，messageCount= 4 和 scheduledCount= 1。

   队列的消息计数现在为 4，一个大于 配置的环大小 3。但是，计划的消息还没有在技术上在队列中（即，它位于代理中并计划放置到队列中）。在预定的 12:05 时，代理会将消息放在队列的头部。但是，由于环队列已达到其配置大小，因此调度的消息 A 会立即被删除。