14.4. 启用消息重新发布

流程

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

2. 在 & lt;cluster-connection& gt; 元素中，验证 <message-load-balancing > 是否已设置为 ON_DEMAND。

   <configuration>
       <core>
           ...
           <cluster-connections>
               <cluster-connection name="my-cluster">
                   ...
                   <message-load-balancing>ON_DEMAND</message-load-balancing>
                   ...
               </cluster-connection>
           </cluster-connections>
       </core>
   </configuration>

3. 在 &lt ;address-settings > 元素中，为队列或一组队列设置重新分配延迟。

   在本例中，负载均衡到 my.queue 的消息会在最后一个消费者关闭后重新分发 5000 毫秒。

   <configuration>
       <core>
           ...
           <address-settings>
               <address-setting match="my.queue">
                   <redistribution-delay>5000</redistribution-delay>
               </address-setting>
           </address-settings>
           ...
       </core>
   </configuration>

   address-setting

   将 match 属性设置为您希望重新分发消息的队列的名称。您可以使用代理通配符语法来指定队列范围。更多信息请参阅 第 4.2 节 “将地址设置应用到一组地址”。

   redistribution-delay

   代理在此队列的最终消费者关闭后应等待的时间（以毫秒为单位），然后再将消息重新分发到集群中的其他代理。如果将其设置为 0， 则信息将立即重新分发。但是，您应该在重新分发前设置延迟 - 消费者通常会关闭，但在同一个队列中快速创建另一个延迟。

4. 对集群中的每个额外代理重复此步骤。