14.7. 对客户端连接进行分区

流程

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

2. 创建 connection-routers 元素，创建一个 connection-route 来使用一致的哈希算法过滤客户端 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。

   在以下示例中，NULL|1 的 local-target-filter 值为没有客户端 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|CL1</local-target-filter>
               </connection-route>
       </connection-routers>
           ...
       </core>
   </configuration>

   connection-route

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

   key

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

   key-filter

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

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

   local-target-filter

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

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

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

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

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

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