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>

   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>

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

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

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

3. producer 将另一条消息发送到队列。然后，消息被分配到消费者。

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

4. 现在，假设使用者已经关闭，而不会导致任何消息。

   在这种情况下，发送四个未确认的消息会取消相关的消息，并以相反的顺序重新添加到队列的头端。此操作将队列置于其配置的环大小。由于环队列优先于队列尾部的消息，因此队列丢弃由制作者发送的第一个消息，因为这是向队列头添加的最后一个消息。事务或者核心会话回滚的方式相同。

1. at 12:00，制作者将消息 A 发送到配置了 ring-size="3" 的环队列。该消息计划为 12:05。

   此时，messageCount= 1 和 scheduledCount= 1.

2. at 12:01，制作者将消息 B 发送到同一环队列。

   现在，messageCount= 2 和 scheduledCount= 1。

3. at 12:02，制作者将消息 C 发送到同一环队列。

   现在，messageCount= 3 和 scheduledCount= 1。

4. at 12:03，制作者将消息 D 发送到同一环队列。

   现在，messageCount= 4 和 scheduledCount= 1。

   队列的消息计数现在是 4，一个大于 配置的环大小 3。但是，已调度的消息尚不在队列上讲而在队列中（即，它属于代理，并计划在队列中放置）。在为期 12:05 的交付时间，代理将消息放在队列的头部。但是，由于环队列已达到其配置大小，因此计划的消息 A 会立即被删除。