14.7. クライアント接続のパーティション設定

手順

1. 最初のブローカーの <broker_instance_dir>/etc/broker.xml 設定ファイルを開きます。

2. connection-routers 要素を作成し、一貫したハッシュアルゴリズムを使用してクライアント ID をフィルタリングする connection-route を作成します。以下に例を示します。

   <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 name には、この接続ルーティング設定を識別する文字列を指定します。この名前は、一貫したハッシュフィルターを適用したい各ブローカーアクセプターに追加する必要があります。

   鍵 (key)

   フィルターを適用するキーの種類。クライアント ID をフィルタリングする場合は、key フィールドに CLIENT_ID を指定します。

   local-target-filter

   ブローカーが modulo 操作で返された整数値と比較して、一致するかどうか、ブローカーが接続を受け入れることができるかどうかを決定する値。この例の NULL|0 の値は、クライアント ID (NULL) を持たない接続と、モジュロ演算によって返される数が 0 である接続に一致します。

   policy

   modulo プロパティーキーを受け入れます。これは、ハッシュ化されたクライアント ID に対してモジュロ演算を実行して、ターゲットブローカーを識別します。modulo プロパティーキーの値は、クラスター内のブローカー数と同じでなければなりません。

   重要

   policy name は CONSISTENT_HASH_MODULO である必要があります。

3. 2 番目のブローカーの <broker_instance_dir>/etc/broker.xml 設定ファイルを開きます。

4. connection-routers 要素を作成し、一貫したハッシュアルゴリズムを使用してクライアント ID をフィルタリングするための connection route を作成します。

   次の例では、local-target-filter の値 NULL|1 により、クライアント ID を持たない (NULL) 接続と、モジュロ演算によって返される値が 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 name には、このルーティング設定の識別する文字列を指定します。この名前は、正規表現フィルターを適用したい各ブローカーアクセプターに追加する必要があります。

   鍵 (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 に CL1 の 3 文字の接頭辞がある接続に一致します。

3. 2 番目のブローカーの <broker_instance_dir>/etc/broker.xml 設定ファイルを開きます。

4. connection-routers 要素を作成し、クライアント ID の一部に基づいて接続をフィルタリングするための connection route を作成します。

   次のフィルターの例では、ブローカーは正規表現を使用して、クライアント 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. この手順を繰り返し、クラスターの追加ブローカーごとに適切な接続ルーティングフィルターを作成します。