14.5. 配置集群消息分组

流程

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

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

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

   2. 在 & lt;core > 元素中添加本地处理器：

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

      <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 > 元素中添加远程处理器：

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