14.7. 分区客户端连接

流程

1. 为第一个代理打开 < broker_instance_dir> /etc/broker.xml 配置文件。

2. 创建 connection-routers 元素，并使用一致的哈希算法创建连接 路由 以过滤客户端 ID。例如：

   <configuration>
      <core>
         ...
         <connection-routers>
            <connection-route name=”consistent-hash-routing”>
               <key>CLIENT_ID</target-key>
               <local-target-filter>NULL|0</local-target-filter>
               <policy name="CONSISTENT_HASH_MODULO">
                  <property key="modulo" value="<number_of_brokers_in_cluster>">
                  </property>
               </policy>
            </connection-route>
         </connection-routers>
         ...
      </core>
   </configuration>

   connection-route

   对于 connection-route 名称，请为这个连接路由配置指定标识字符串。您必须将此名称添加到每个代理接受器中，您要将一致的散列过滤器应用到其中。

   key

   要将过滤器应用到的键类型。要过滤客户端 ID，在 key 字段中指定 CLIENT_ID。

   local-target-filter

   代理与 modulo 操作返回的整数值进行比较的值，以确定是否有匹配项并且代理可以接受连接。示例中的 NULL|0 值为没有客户端 ID(NULL)的连接提供了匹配的连接，其中 modulo 操作返回的数量为 0。

   policy

   接受 modulo 属性键，它在散列客户端 ID 上执行 modulo 操作来识别目标代理。modulo 属性键的值必须等于集群中的代理数量。

   重要

   策略名称 必须是 CONSISTENT_HASH_MODULO。

3. 为第二个代理打开 < broker_instance_dir> /etc/broker.xml 配置文件。

4. 创建 connection-routers 元素，并使用一致的哈希算法创建用于过滤客户端 ID 的连接路由。

   在以下示例中，local-target-filter 的 NULL|1 为没有客户端 ID(NULL)的连接提供了匹配的连接，其中 modulo 操作返回的值为 1。

   <configuration>
      <core>
         ...
         <connection-routers>
            <connection-route name=”consistent-hash-routing”>
               <key>CLIENT_ID</target-key>
               <local-target-filter>NULL|1</local-target-filter>
               <policy name="CONSISTENT_HASH_MODULO">
                  <property key="modulo" value="<number_of_brokers_in_cluster>">
                  </property>
               </policy>
            </connection-route>
         </connection-routers>
         ...
      </core>
   </configuration>

5. 重复此流程，为集群中的每个额外代理创建一致的哈希过滤器。

流程

1. 为第一个代理打开 < broker_instance_dir> /etc/broker.xml 配置文件。

2. 创建 connection-routers 元素并创建一个 connection-route 来过滤客户端 ID 的一部分。例如：

   <configuration>
       <core>
           ...
           <connection-routers>
               <connection-route name=”regex-routing”>
                   <key>CLIENT_ID</target-key>
                   <key-filter>^.{3}</key-filter>
                   <local-target-filter>NULL|FOO</local-target-filter>
               </connection-route>
       </connection-routers>
           ...
       </core>
   </configuration>

   connection-route

   对于 connection-route 名称，请为此路由配置指定标识字符串。您必须将此名称添加到要应用正则表达式过滤器的每个代理接受器中。

   key

   要将过滤器应用到的键。要过滤客户端 ID，在 key 字段中指定 CLIENT_ID。

   key-filter

   将正则表达式应用到的客户端 ID 字符串中用于提取键值。在上面的第一个代理示例中，代理提取一个键值，它是客户端 ID 的前 3 个字符。例如，如果客户端 ID 字符串是 FOO100.consumer，则代理提取一个键值 FOO。代理提取键值后，它会将其与 local-target-filter 的值进行比较。

   如果传入的连接没有客户端 ID，或者代理无法使用为 key-filter 指定的正则表达式提取键值，则键值设置为 NULL。

   local-target-filter

   代理与键值比较的值，以确定是否有匹配项并且代理可以接受连接。上面的第一个代理示例所示的 NULL|FOO 值匹配，与没有客户端 ID(NULL)或在客户端 ID 中具有 3 个字符前缀 FOO 的连接匹配。

3. 为第二个代理打开 < broker_instance_dir> /etc/broker.xml 配置文件。

4. 创建 connection-routers 元素，并创建 连接路由，以根据客户端 ID 的一部分过滤连接。

   在以下过滤器示例中，代理使用正则表达式提取一个键值，它是客户端 ID 的前 3 个字符。代理将 NULL 和 BAR 的值与键值进行比较，以确定是否有匹配项和代理可以接受连接。

   <configuration>
       <core>
           ...
           <connection-routers>
               <connection-route name=”regex-routing”>
                   <key>CLIENT_ID</target-key>
                   <key-filter>^.{3}</key-filter>
                   <local-target-filter>NULL|BAR</local-target-filter>
               </connection-route>
           </connection-routers>
           ...
       </core>
   </configuration>

5. 重复此步骤，并为集群中的每个附加代理创建适当的连接路由过滤器。