14.5. 配置集群消息分组

流程

1. 在集群中的一个代理上配置本地处理程序。

   如果您使用高可用性，这应该是 master 代理。

   1. 打开代理的 < broker_instance_dir> /etc/broker.xml 配置文件。

   2. 在 &lt ;core&gt; 元素中，添加一个本地处理程序：

      本地处理程序充当远程处理程序的仲裁程序。它存储路由信息并将其通信到其他代理。

      <configuration>
          <core>
              ...
              <grouping-handler name="my-grouping-handler">
                  <type>LOCAL</type>
                  <timeout>10000</timeout>
              </grouping-handler>
              ...
          </core>
      </configuration>

      grouping-handler

      使用 name 属性为分组处理器指定唯一名称。

      type

      把它设置为 LOCAL。

      timeout

      等待（以毫秒为单位）决定路由消息的决定的时间。默认值为 5000 毫秒。如果在做出路由决策前达到超时，则会抛出异常，这样可确保严格的消息排序。

      当代理收到一个带有组 ID 的消息时，它会将路由传播到消费者要附加到的队列。如果集群中其他代理上的分组处理程序接受路由，则会建立路由：集群中的所有代理都将使用此组 ID 转发到该队列。如果代理的路由提议被拒绝，它会拒绝一个备用路由，重复该过程，直到路由被接受为止。

2. 如果您使用高可用性，请将本地处理程序配置复制到主代理的从代理中。

   将本地处理器配置复制到从代理可防止本地处理器的单一故障点。

3. 在集群的每个其余代理中，配置远程处理器。

   1. 打开代理的 < broker_instance_dir> /etc/broker.xml 配置文件。

   2. 在 &lt ;core&gt; 元素中，添加一个远程处理程序：

      <configuration>
          <core>
              ...
              <grouping-handler name="my-grouping-handler">
                  <type>REMOTE</type>
                  <timeout>5000</timeout>
              </grouping-handler>
              ...
          </core>
      </configuration>

      grouping-handler

      使用 name 属性为分组处理器指定唯一名称。

      type

      把它设置为 REMOTE。

      timeout

      等待（以毫秒为单位）决定路由消息的决定的时间。默认值为 5000 毫秒。将此值设置为本地处理程序值的一半。