14.5. 配置集群消息分组

流程

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

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

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

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

   将本地处理程序配置复制到从代理可防止本地处理程序出现单点故障。

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

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

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