4.22.9. 配置下游队列联合

流程

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

2. 添加一个包含 <federation> 元素的 <federations > 元素。例如：

   <federations>
     <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
     </federation>
   </federations>

   Copy to Clipboard Toggle word wrap

3. 添加队列策略配置。例如：

   <federations>
       ...
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <queue-policy name="news-queue-federation" priority-adjustment="-5" include-federated="true" transformer-ref="new-transformer">
   
               <include queue-match="#" address-match="queue.bbc.new" />
               <include queue-match="#" address-match="queue.usatoday" />
               <include queue-match="#" address-match="queue.news.#" />
   
               <exclude queue-match="#.local" address-match="#" />
   
           </queue-policy>
   
       </federation>
     ...
   </federations>

   Copy to Clipboard Toggle word wrap

4. 如果要在传输前转换消息，请添加转换器配置。例如：

   <federations>
       ...
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <queue-policy name="news-queue-federation" priority-adjustment="-5" include-federated="true" transformer-ref="news-transformer">
   
               <include queue-match="#" address-match="queue.bbc.new" />
               <include queue-match="#" address-match="queue.usatoday" />
               <include queue-match="#" address-match="queue.news.#" />
   
               <exclude queue-match="#.local" address-match="#" />
   
           </queue-policy>
   
           <transformer name="news-transformer">
               <class-name>org.foo.NewsTransformer</class-name>
               <property key="key1" value="value1"/>
               <property key="key2" value="value2"/>
           </transformer>
   
       </federation>
     ...
   </federations>

   Copy to Clipboard Toggle word wrap

5. 为每个远程代理添加 下游 元素。例如：

   <federations>
       ...
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <downstream name="eu-east-1">
               <static-connectors>
                   <connector-ref>eu-east-connector1</connector-ref>
               </static-connectors>
               <transport-connector-ref>netty-connector</transport-connector-ref>
               <policy ref="news-address-federation"/>
           </downstream>
   
           <downstream name="eu-west-1" >
               <static-connectors>
                   <connector-ref>eu-west-connector1</connector-ref>
               </static-connectors>
               <transport-connector-ref>netty-connector</transport-connector-ref>
               <policy ref="news-address-federation"/>
           </downstream>
   
           <queue-policy name="news-queue-federation" priority-adjustment="-5" include-federated="true" transformer-ref="new-transformer">
   
               <include queue-match="#" address-match="queue.bbc.new" />
               <include queue-match="#" address-match="queue.usatoday" />
               <include queue-match="#" address-match="queue.news.#" />
   
               <exclude queue-match="#.local" address-match="#" />
   
           </queue-policy>
   
           <transformer name="news-transformer">
               <class-name>org.foo.NewsTransformer</class-name>
               <property key="key1" value="value1"/>
               <property key="key2" value="value2"/>
           </transformer>
   
       </federation>
     ...
   </federations>

   Copy to Clipboard Toggle word wrap

   如前面的配置所示，远程代理现在被视为本地代理的下游。下游代理使用配置中的连接信息来回连接到本地（即 上游）代理。

6. 在本地代理中，添加本地和远程代理使用的连接器和接收器来建立联合连接。例如：

   <connectors>
      <connector name="netty-connector">tcp://localhost:61616</connector>
      <connector name="eu-west-1-connector">tcp://localhost:61616</connector>
      <connector name="eu-east-1-connector">tcp://localhost:61617</connector>
   </connectors>
   
   <acceptors>
      <acceptor name="netty-acceptor">tcp://localhost:61616</acceptor>
   </acceptors>

   Copy to Clipboard Toggle word wrap

   connector name="netty-connector"

   本地代理发送到远程代理的连接器配置。远程代理使用此配置返回本地代理。

   connector name="eu-west-1-connector" , connector name="eu-east-1-connector"

   与远程代理的连接器.本地代理使用这些连接器连接到远程代理，并共享远程代理需要连接到本地代理的配置。

   acceptor name="netty-acceptor"

   本地代理上的接收器，对应于远程代理用来连接到本地代理的连接器。