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. 如果您使用高可用性，请将本地处理器配置复制到主代理的 slave 代理。

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

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 毫秒。将此值设置为本地处理程序的至少一半。