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. 所有消息都会立即分配给消费者。

   At this point, messageCount= 3 and deliveringCount= 3.

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

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

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

   在这种情况下，四个 in-delivery，未确认的消息将取消回代理，并根据它们使用的相反顺序添加到队列的标头中。此操作会使队列置于其配置的环大小上。由于环队列首选通过头的消息在队列的尾部消息，因此队列丢弃生成者发送的第一个消息，因为这是最后一个消息，将添加回队列头。事务或核心会话回滚的方式相同。

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

   此时，messageCount= 1 和 scheduledCount= 1。

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

   现在，messageCount= 2 和 scheduledCount= 1。

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

   现在，messageCount= 3 和 scheduledCount= 1。

4. 在 12:03 时，生成者将消息 D 发送到同一环队列。

   现在，messageCount= 4 和 scheduledCount= 1。

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