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. 制作者将三个消息发送到配置了 ring-size="3" 的环队列。

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

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

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

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

4. 现在，假设消费者已关闭，而不会确认任何消息。

   在这种情况下，四个 in-delivery，未确认的消息会取消到代理，并以相反的顺序添加到队列的头。此操作将队列置于其配置的环大小上。由于环队列更喜欢在头上队列尾部的消息，因此队列丢弃了生产者发送的第一个消息，因为这是最后一个消息添加到队列的头头。事务或核心会话回滚的方式相同。

1. 在 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 会立即被删除。