1. 代理目前不支持虚拟主机，这意味着忽略 CONNECT 帧中的主机标头。
2. 消息确认不是事务性的。ACK 帧不能是一个事务的一部分，如果设置了其 事务 标头，它将被忽略。

步骤

1. 打开配置文件 BROKER_INSTANCE_DIR/etc/broker.xml
2. 为 STOMP 连接将 stompEnableMessageId 参数设置为 true，如下例所示：

步骤

1. 打开配置文件 BROKER_INSTANCE_DIR/etc/broker.xml
2. 将 connectionTTL 参数添加到用于 STOMP 连接的接收器的 URI，如下例所示：

步骤

1. 打开配置文件 BROKER_INSTANCE_DIR/etc/broker.xml
2. 添加 connection-ttl-override 属性，为新默认值提供值（以毫秒为单位）。它属于 <core> 小节，如下所示。

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 在配置中添加 <wildcard-addresses> 部分，如下例所示。

   <configuration>
     <core>
       ...
       <wildcard-addresses> //
         <enabled>true</enabled> //
         <delimiter>,</delimiter> //
         <any-words>@</any-words> //
         <single-word>$</single-word>
       </wildcard-addresses>
       ...
     </core>
   </configuration>

   enabled

   当设置为 true 时，指示代理使用自定义设置。

   分隔符

   提供自定义字符，以将 用作 分隔符 而不是默认值，即 。

   any-words

   提供的字符作为 任意 单词的值用于表示"匹配零个或多个单词"序列，并将替换默认的 #。在表达式末尾使用此字符。

   单词

   提供的字符用作 单 单词的值表示"匹配单个单词"，并将替换掉默认的 *。在您的表达式的任意位置使用此字符。

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 在 地址 的所选 队列 元素中嵌套任何广播配置元素。确保 地址 和队列 元素的 name 属性的值相同。例如：

   <configuration ...>
     <core ...>
       ...
       <address name="my.anycast.destination">
         <anycast>
           <queue name="my.anycast.destination"/>
         </anycast>
       </address>
     </core>
   </configuration>

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 围绕 address 元素中 的队列 元素嵌套任何广播配置元素。例如：

   <configuration ...>
     <core ...>
       ...
       <address name="my.anycast.destination">
         <anycast>
           <queue name="q1"/>
           <queue name="q2"/>
         </anycast>
       </address>
     </core>
   </configuration>

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 将 持久配置 元素添加到所选队列。设置值 true。

   <configuration ...>
     <core ...>
       ...
       <address name="my.durable.address">
         <multicast>
           <queue name="q1">
             <durable>true</durable>
           </queue>
         </multicast>
       </address>
     </core>
   </configuration>

   注意

   因为队列默认是持久的，包括 durable 元素，并将值设为 true 绝对不需要创建持久队列。但是，明确包含 元素可让您以后将队列的行为改为不可中断。

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 将 持久配置 元素添加到每个所选队列。设置值 true。

   <configuration ...>
     <core ...>
       ...
       <address name="my.non.shared.durable.address">
         <multicast>
           <queue name="orders1">
             <durable>true</durable>
           </queue>
           <queue name="orders2">
             <durable>true</durable>
           </queue>
         </multicast>
       </address>
     </core>
   </configuration>

   注意

   因为队列默认是持久的，包括 durable 元素，并将值设为 true 绝对不需要创建持久队列。但是，明确包含 元素可让您以后将队列的行为改为不可中断。

3. 将 max-consumers 属性添加到每个所选队列。设置值 1。

   <configuration ...>
     <core ...>
       ...
       <address name="my.non.shared.durable.address">
         <multicast>
           <queue name="orders1" max-consumers="1">
             <durable>true</durable>
           </queue>
           <queue name="orders2" max-consumers="1">
             <durable>true</durable>
           </queue>
         </multicast>
       </address>
     </core>
   </configuration>

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 将 purge-on-no-consumers 属性添加到每个选定的队列。设置值 true。

   <configuration ...>
     <core ...>
       ...
       <address name="my.non.durable.address">
           <multicast>
               <queue name="orders1" purge-on-no-consumers="true"/>
           </multicast>
       </address>
     </core>
   </configuration>

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 配置 address-setting，以自动创建和删除。以下示例使用了上表中提到的所有配置元素。

   <configuration ...>
    <core ...>
     ...
     <address-settings>
       <address-setting match="activemq.#">
         <auto-create-addresses>true</auto-create-addresses>
         <auto-delete-addresses>true</auto-delete-addresses>
         <auto-create-queues>true</auto-create-queues>
         <auto-delete-queues>true</auto-delete-queues>
         <default-address-routing-type>ANYCAST</default-address-routing-type>
       </address-setting>
     </address-settings>
     ...
    </core>
   </configuration>

   address-setting

   address-setting 元素的配置应用到与通配符地址 activemq.# 匹配的任何地址或队列。#。

   auto-create-addresses

   当客户端请求连接到尚不存在的地址时，代理会创建地址。

   auto-delete-addresses

   当地址不再关联任何队列时，会删除它自动创建的地址。

   auto-create-queues

   当客户端请求连接到尚不存在的队列时，代理会创建队列。

   auto-delete-queues

   当一个自动创建的队列不再包含任何消费者或消息时，会删除它。

   default-address-routing-type

   如果客户端在连接时没有指定路由类型，代理会在向地址发送消息时使用 ANYCAST。默认值为 MULTICAST。

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 对于给定队列，添加 last-value-key 键并指定自定义值。例如：

   <address name="my.address">
       <multicast>
           <queue name="prices1" last-value-key="stock_ticker"/>
       </multicast>
   </address>

3. 另外，您可以配置最后一个值队列，它使用默认值 _AMQ_LVQ_NAME。为此，请将 last-value 键添加到给定的队列中。将值设为 true。例如：

   <address name="my.address">
       <multicast>
           <queue name="prices1" last-value="true"/>
       </multicast>
   </address>

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 在 address-setting 元素中，对于匹配的地址，添加 default-last-value-key。指定一个自定义值。例如：

   <address-setting match="lastValue">
      <default-last-value-key>stock_ticker</default-last-value-key>
   </address-setting>

   根据前面的配置，与 lastValue 地址关联的所有队列均使用 stock_ticker 的最后一个值键。默认情况下，未设置 default-last-value-key 的值。

3. 要为 一组 地址配置最后的值队列，您可以指定地址通配符。例如：

   <address-setting match="lastValue.*">
      <default-last-value-key>stock_ticker</default-last-value-key>
   </address-setting>

4. 另外，您可以配置与地址 或一组 地址关联的所有队列，以使用 _AMQ_LVQ_NAME 的默认值键名称。为此，请添加 default-last-value-queue 而不是 default-last-value-key。将值设为 true。例如：

   <address-setting match="lastValue">
      <default-last-value-queue>true</default-last-value-queue>
   </address-setting>

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 如果您之前将队列配置为最后值队列，请添加 非破坏性 密钥。将值设为 true。例如：

   <address name="my.address">
      <multicast>
         <queue name="orders1" last-value-key="stock_ticker" non-destructive="true" />
      </multicast>
   </address>

3. 如果您之前为最后一个值队列配置了地址 或一组 地址，请添加 默认的非破坏性 键。将值设为 true。例如：

   <address-setting match="lastValue">
      <default-last-value-key>stock_ticker </default-last-value-key>
      <default-non-destructive>true</default-non-destructive>
   </address-setting>

   注意

   默认情况下，默认值非破坏性 的值是 false。

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 在 core 元素中，设置 message-expiry-scan-period 以指定代理扫描过期消息的频率。

   <configuration ...>
      <core ...>
         ...
         <message-expiry-scan-period>1000</message-expiry-scan-period>
         ...

   根据前面的配置，代理扫描队列每 1000 毫秒的过期消息。

3. 在匹配地址 或一组 地址的 address-setting 元素中，指定一个到期地址。另外，设置消息到期时间。例如：

   <configuration ...>
      <core ...>
         ...
         <address-settings>
            ...
            <address-setting match="stocks">
               ...
               <expiry-address>ExpiryAddress</expiry-address>
               <expiry-delay>10</expiry-delay>
               ...
            </address-setting>
            ...
         <address-settings>
   <configuration ...>

   expiry-address

   匹配地址或地址的到期地址。在前面的示例中，代理会将 库存地址的过期信息发送到名为 ExpiryAddress 的到期地址。

   expiry-delay

   代理应用于 使用默认 过期时间的消息的过期时间（以毫秒为单位）。默认情况下，消息的过期时间为 0， 表示它们不会过期。对于超过默认值的过期时间的信息，expiry-delay 无效。

   例如，假设您将地址上的 expiry-delay 设置为 10，如上例中所示。如果默认过期时间为 0 的消息在此地址到达队列，则代理会将消息的过期时间从 0 改为 10。但是，如果另一个正在使用到期时间 20 次的消息，则其过期时间保持不变。如果将 expiry-delay 设置为 -1，则禁用此功能。默认情况下，expiry-delay 设置为 -1。

4. 另外，您可以指定最小和最大到期延迟值，而不是为 expiry-delay 指定值。例如：

   <configuration ...>
      <core ...>
         ...
         <address-settings>
            ...
            <address-setting match="stocks">
               ...
               <expiry-address>ExpiryAddress</expiry-address>
               <min-expiry-delay>10</min-expiry-delay>
               <max-expiry-delay>100</max-expiry-delay>
               ...
            </address-setting>
            ...
         <address-settings>
   <configuration ...>

   min-expiry-delay

   代理应用于消息的最小过期时间（以毫秒为单位）。

   max-expiry-delay

   代理应用到消息的最大到期时间（以毫秒为单位）。

   代理应用 min-expiry-delay 和 max-expiry-delay 的值，如下所示：

   • 对于默认过期时间的消息为 0， 代理会将过期时间设置为指定的值 max-expiry-delay。如果您还没有为 max-expiry-delay 指定值，则代理会将过期时间设置为 min-expiry-delay 的指定的值。如果您还没有为 min-expiry-delay 指定值，则代理不会更改消息的过期时间。
   • 对于 max-expiry-delay 值超过 expiration 时间的消息，代理会将过期时间设置为 max-expiry-delay 的指定的值。
   • 对于在 min-expiry-delay 值低于 expiration 时间的消息，代理会将过期时间设置为 min-expiry-delay 的指定的值。
   • 对于在 min-expiry-delay 和 max-expiry-delay 之间过期的消息，代理不会更改消息的过期时间。
   • 如果您为 expiry-delay （即默认值 -1）指定了一个值，这将覆盖您为 min-expiry-delay 和 max-expiry-delay 指定的任何值。
   • min-expiry-delay 和 max-expiry-delay 的默认值为 -1（即 disabled）。

5. 在配置文件的 addresses 元素中，配置之前为 到期 地址指定的地址。在此地址上定义一个队列。例如：

   <addresses>
       ...
       <address name="ExpiryAddress">
           <anycast>
               <queue name="ExpiryQueue"/>
           </anycast>
       </address>
       ...
   </addresses>

   前面的示例配置将到期队列 ExpiryQueue 与到期地址 ExpiryAddress 关联。

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 找到您之前添加到配置文件的 <address-setting> 元素，为匹配的地址 或一组 地址定义到期地址。例如：

   <configuration ...>
   
      <core ...>
         ...
         <address-settings>
            ...
            <address-setting match="stocks">
               ...
               <expiry-address>ExpiryAddress</expiry-address>
               ...
            </address-setting>
            ...
         <address-settings>
   <configuration ...>

3. 在 <address-setting> 元素中，添加指示代理自动创建到期资源（即地址和队列）的配置项以及如何命名这些资源。例如：

   <configuration ...>
      <core ...>
         ...
         <address-settings>
            ...
            <address-setting match="stocks">
               ...
               <expiry-address>ExpiryAddress</expiry-address>
               <auto-create-expiry-resources>true</auto-create-expiry-resources>
               <expiry-queue-prefix>EXP.</expiry-queue-prefix>
               <expiry-queue-suffix></expiry-queue-suffix>
               ...
            </address-setting>
            ...
         <address-settings>
   <configuration ...>

   auto-create-expiry-resources

   指定代理是否自动创建到期地址和队列来接收过期的信息。默认值为：false。

   如果参数值设置为 true，代理会自动创建一个 <address> 元素来定义到期地址和关联的到期队列。自动创建的 <address> 元素的 name 值与为 <expiry-address> 指定的值匹配。

   自动创建的到期队列具有 多播路由 类型。默认情况下，代理将到期队列名称与最初发送消息的过期消息的地址匹配，例如 库存。

   代理还为使用 _AMQ_ORIG_ADDRESS 属性的到期队列定义过滤器。此过滤器确保到期队列仅接收发送到对应原始地址的消息。

   expiry-queue-prefix

   代理应用到自动创建的到期队列的名称的前缀。默认值为 EXP。

   当您定义前缀值或保留默认值时，到期队列的名称是前缀和原始地址的串联，如 EXP.stocks。

   expiry-queue-suffix

   代理应用到自动创建的到期队列名称的后缀。未定义默认值（即代理不应用后缀）。

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 在与队列名称匹配的 <address-setting> 元素中，为死信地址名称和传输尝试的最大数量设置值。例如：

   <configuration ...>
      <core ...>
         ...
         <address-settings>
            ...
            <address-setting match="exampleQueue">
               <dead-letter-address>DLA</dead-letter-address>
               <max-delivery-attempts>3</max-delivery-attempts>
            </address-setting>
         ...
         <address-settings>
   <configuration ...>

   匹配

   代理在此 address-setting 部分中应用配置的地址。您可以为 <address-setting> 元素的 match 属性指定一个通配符表达式。如果您想将 <address-setting> 元素中配置的死信设置与一组匹配的地址 集合 相关联，则使用通配符表达式。

   dead-letter-address

   死信地址的名称。在本例中，代理将未发送的消息从队列 示例Queue 移到 dead letter address DLA。

   max-delivery-attempts

   代理发出的最大发送尝试次数，然后向配置的死信地址移动未发送的消息。在这个示例中，代理会在三出失败传送尝试后将未发送的消息移到死信地址。默认值为 10。如果您希望代理进行无限重新发送尝试，请指定 -1 值。

3. 在 address 部分中，为死信 地址 DLA 添加一个地址元素。要将死信队列与死信队列关联，请为 队列 指定一个 name 值。例如：

   <configuration ...>
      <core ...>
         ...
         <addresses>
            <address name="DLA">
               <anycast>
                  <queue name="DLQ" />
               </anycast>
            </address>
         ...
         </addresses>
      </core>
   </configuration>

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 找到之前添加的 <address-setting> 元素，以定义匹配队列或一组队列的死信地址。例如：

   <configuration ...>
      <core ...>
         ...
         <address-settings>
            ...
            <address-setting match="exampleQueue">
               <dead-letter-address>DLA</dead-letter-address>
               <max-delivery-attempts>3</max-delivery-attempts>
            </address-setting>
         ...
         <address-settings>
   <configuration ...>

3. 在 <address-setting> 元素中，添加指示代理自动创建死信资源（即地址和队列）的配置项以及如何命名这些资源。例如：

   <configuration ...>
      <core ...>
         ...
         <address-settings>
            ...
            <address-setting match="exampleQueue">
               <dead-letter-address>DLA</dead-letter-address>
               <max-delivery-attempts>3</max-delivery-attempts>
               <auto-create-dead-letter-resources>true</auto-create-dead-letter-resources>
               <dead-letter-queue-prefix>DLQ.</dead-letter-queue-prefix>
               <dead-letter-queue-suffix></dead-letter-queue-suffix>
            </address-setting>
         ...
         <address-settings>
   <configuration ...>

   auto-create-dead-letter-resources

   指定代理是否自动创建死信地址和队列来接收未发送的消息。默认值为：false。

   如果将 auto-create-dead-letter-resources 设置为 true，则代理会自动创建一个 <address> 元素来定义死信地址和关联的死信队列。自动创建的 <address> 元素的名称与您为 <dead-letter-address> 指定的 name 值匹配。

   代理在自动创建的 <address> 元素中定义的死信队列具有 多播路由 类型。默认情况下，代理命名死信队列，以匹配未发送的消息的原始地址，如 库存。

   代理还为死信队列定义过滤器，它使用 _AMQ_ORIG_ADDRESS 属性。此过滤器确保死信队列仅接收发送到对应原始地址的消息。

   dead-letter-queue-prefix

   代理应用到自动创建的死信队列的名称的前缀。默认值为 DLQ。

   当您定义前缀值或保留默认值时，死信队列的名称是前缀和原始地址（如 DLQ.stocks ）的串联。

   dead-letter-queue-suffix

   代理应用到自动创建的死信队列的后缀。未定义默认值（即代理不应用后缀）。

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 对于给定的队列，添加 独占 密钥。将值设为 true。

   <configuration ...>
     <core ...>
       ...
       <address name="my.address">
         <multicast>
           <queue name="orders1" exclusive="true"/>
         </multicast>
       </address>
     </core>
   </configuration>

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 在 address-setting 元素中，对于匹配的地址，添加 default-exclusive-queue 键。将值设为 true。

   <address-setting match="myAddress">
       <default-exclusive-queue>true</default-exclusive-queue>
   </address-setting>

   根据前面的配置，与 myAddress 地址关联的所有队列都是独占的。默认情况下，default-exclusive-queue 的值为 false。

3. 要为 一组 地址配置专用队列，您可以指定地址通配符。例如：

   <address-setting match="myAddress.*">
       <default-exclusive-queue>true</default-exclusive-queue>
   </address-setting>

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 要在不设置显式环大小匹配的地址上为所有队列定义默认环大小，请在 address-setting 元素中指定 default-ring-size 的值。例如：

   <address-settings>
      <address-setting match="ring.#">
         <default-ring-size>3</default-ring-size>
      </address-setting>
   </address-settings>

   default-ring-size 参数对于定义自动创建队列的默认大小特别有用。default-ring-size 的默认值为 -1（即没有大小限制）。

3. 要在特定队列上定义环大小，请将 ring-size 键添加到 queue 元素中。指定一个值。例如：

   <addresses>
      <address name="myRing">
         <anycast>
            <queue name="myRing" ring-size="5" />
         </anycast>
      </address>
   </addresses>

1. 制作者将三个消息发送到配置了 ring-size="3" 的环队列。

2. 所有消息都会立即分配给消费者。

   此时，messageCount= 3 和 deliver Count= 3。

3. 制作者将另一条消息发送到队列。然后，消息被分配到消费者。

   现在，MessageCount = 4 和 deliverCount = 4。4 的消息计数大于配置的环形大小为 3。但是，代理会被视为允许这种情况，因为它无法从队列中删除发送的消息。

4. 现在，假设使用者已关闭，且未被确认任何消息。

   在这种情况下，四个正在发送中，未确认的消息将被取消回代理，并按照它们使用的相反顺序添加到队列的头位。此操作会使队列超过配置的环形大小。由于环队列优先选择队列用于通过头上消息的尾部消息，因此队列会丢弃制作者发送的第一个消息，因为这是最后一个消息已重新添加到队列的头条。事务或核心会话回滚会采用同样的方式处理。

1. 在 12:00 时，制作者将消息 A 发送到配置了 ring-size ="3 的环队列。该消息被调度为 12:05。

   此时，Message Count= 1 和 scheduledCount= 1。

2. 在 12:01 上，生产者将消息 B 发送到同一个环队列。

   现在，MessageCount= 2 和 scheduledCount= 1。

3. 在 12:02，生产者将消息 C 发送到同一个环队列。

   现在，MessageCount= 3 和 scheduledCount= 1。

4. 在 12:03，生产者将消息 D 发送到同一个环队列。

   现在，MessageCount= 4 和 scheduledCount= 1。

   队列的消息计数现在为 4，它 大于 配置的环形大小为 3。但是，尚未在队列（即，它位于代理中并计划放置在队列中）上的消息。在预定的 12:05 交付时间，代理会将消息放在队列的头部。但是，由于环队列已达到其配置的大小，调度的消息 A 会立即被删除。

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

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

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

   name

   联合配置的名称。在本例中，名称对应于本地代理的名称。

   user

   与上游代理连接的共享用户名。

   password

   与上游代理连接的共享密码。

   注意

   如果远程代理的用户和密码凭证不同，您可以在添加到配置中时为这些代理单独指定凭证。此流程稍后会加以描述。

3. 在 federation 元素中，添加 <address-policy> 元素。例如：

   <federations>
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <address-policy name="news-address-federation" auto-delete="true" auto-delete-delay="300000" auto-delete-message-count="-1" enable-divert-bindings="false" max-hops="1" transformer-ref="news-transformer">
           </address-policy>
   
       </federation>
   </federations>

   name

   地址策略的名称。代理上配置的所有地址策略都必须具有唯一的名称。

   auto-delete

   在地址联合期间，本地代理会在远程地址动态创建持久队列。auto-delete 属性的值指定本地代理断开连接后远程队列是否应删除，以及 auto-delete-delay 和 auto-delete-message-count 属性的值也已达到。如果要自动清理动态创建队列，这是有用的选项。如果本地代理在较长时间断开连接，则还想防止在远程代理上构建信息，它也很有用的选项。但是，如果您希望在本地代理中始终为本地代理保持排队信息，则可能会将这个选项设置为 false，从而避免在本地代理上丢失信息。

   auto-delete-delay

   本地代理断开连接后，此属性的值会指定动态创建的远程队列有资格自动删除前的时间（以毫秒为单位）。

   auto-delete-message-count

   在本地代理断开连接后，此属性的值指定仍可在队列有资格自动删除前在动态创建的远程队列中的最大消息数。

   enable-divert-bindings

   将此属性设置为 true 可按需侦听绑定。如果一个与地址策略包含的地址匹配的地址有 movert 绑定，则与 movert 转发地址匹配的任何队列绑定都将创建需要。默认值为：false。

   max-hops

   联合期间可以发出消息的最大跃点数。特定拓扑需要此属性的特定值。要了解更多有关这些要求的信息，请参阅 第 4.21.2 节 “用于地址联合的常见拓扑”。

   transformer-ref

   转换器配置的名称。如果要在联合消息传输过程中转换信息，可以添加转换器配置。此流程稍后会描述转换器配置。

4. 在 <address-policy> 元素中，添加地址匹配模式来包含地址策略并排除地址。例如：

   <federations>
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <address-policy name="news-address-federation" auto-delete="true" auto-delete-delay="300000" auto-delete-message-count="-1" enable-divert-bindings="false" max-hops="1" transformer-ref="news-transformer">
   
               <include address-match="queue.bbc.new" />
               <include address-match="queue.usatoday" />
               <include address-match="queue.news.#" />
   
               <exclude address-match="queue.news.sport.#" />
           </address-policy>
   
       </federation>
   </federations>

   Include

   此元素的 address-match 属性值指定要包含在地址策略中的地址。您可以指定准确的地址，例如 queue.bbc.new 或 queue.usatoday。或者，您可以使用通配符表达式来指定 一组 匹配的地址。在前面的示例中，地址策略还包括以字符串 queue.news 开头的所有地址名称。

   exclude

   此元素的 address-match 属性值指定要从地址策略中排除的地址。您可以指定准确的地址名，或使用通配符表达式来指定匹配的地址 集合。在前面的示例中，地址策略会排除以字符串 queue.news.sport 开头的所有地址名称。

5. （可选）使用 federation 元素，添加 transformer 元素来引用自定义转换器实施。例如：

   <federations>
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <address-policy name="news-address-federation" auto-delete="true" auto-delete-delay="300000" auto-delete-message-count="-1" enable-divert-bindings="false" max-hops="1" transformer-ref="news-transformer">
   
               <include address-match="queue.bbc.new" />
               <include address-match="queue.usatoday" />
               <include address-match="queue.news.#" />
   
               <exclude address-match="queue.news.sport.#" />
           </address-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>

   name

   转换器配置的名称。这个名称在本地代理上必须是唯一的。这是您指定为地址策略的 transformer-ref 属性的值。

   class-name

   实施 org.apache.activemq.core.server.transformer.Transformer 接口的用户定义的类的名称。

   转换器的 transform（） 方法会在消息被传输之前通过消息调用。这可让您在联合邮件标头或正文前转换该邮件标头或正文。

   属性

   用于存放特定转换器配置的键值对。

6. 在 federation 元素中，添加一个或多个 上游 元素。每个 上游 元素都定义了与远程代理的连接以及应用到该连接的策略。例如：

   <federations>
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <upstream name="eu-east-1">
               <static-connectors>
                   <connector-ref>eu-east-connector1</connector-ref>
               </static-connectors>
               <policy ref="news-address-federation"/>
           </upstream>
   
           <upstream name="eu-west-1" >
               <static-connectors>
                   <connector-ref>eu-west-connector1</connector-ref>
               </static-connectors>
               <policy ref="news-address-federation"/>
           </upstream>
   
           <address-policy name="news-address-federation" auto-delete="true" auto-delete-delay="300000" auto-delete-message-count="-1" enable-divert-bindings="false" max-hops="1" transformer-ref="news-transformer">
   
               <include address-match="queue.bbc.new" />
               <include address-match="queue.usatoday" />
               <include address-match="queue.news.#" />
   
               <exclude address-match="queue.news.sport.#" />
           </address-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>

   static-connectors

   包含连接器( connector-ref )元素列表，它引用本地代理的 broker.xml 配置文件中定义的 连接器 元素。连接器定义要用于传出连接的传输（TCP、SSL、HTTP 等）和服务器连接参数（主机、端口等）。此步骤的下一步演示了如何添加在 static-connectors 元素中引用的连接器。

   policy-ref

   在应用于上游代理的下游代理上配置的地址策略的名称。

   您可以针对 上游 元素指定的附加选项如下所述：

   name

   上游代理配置的名称。在本例中，名称对应于名为 eu-east-1 和 eu-west-1 的上游代理。

   user

   创建到上游代理的连接时使用的用户名。如果没有指定，则使用 federation 元素配置中指定的共享用户名。

   password

   创建到上游代理的连接时使用的密码。如果未指定，则使用 federation 元素配置中指定的共享密码。

   call-failover-timeout

   与 call-timeout 类似，但在进行故障转移尝试时使用了调用。默认值为 -1，这表示超时被禁用。

   call-timeout

   时间，以毫秒为单位，在传输一个阻塞调用的数据包时，联合连接会等待来自远程代理的回复。如果此时间过长，连接会引发异常。默认值为 30000。

   check-period

   周期，以毫秒为单位，本地代理发送到远程代理的连续"维持性"消息用于检查联合连接的健康状况。如果连接是健康的，远程代理会响应每个 keep-alive 信息。如果连接不健康，则当下游代理无法从上游代理接收响应时，则会使用一个称为 断路器 机制来阻止联合消费者。如需更多信息，请参阅 circuit-breaker-timeout 参数的描述。check-period 参数的默认值为 30000。

   circuit-breaker-timeout

   下游和上游代理之间的单一连接可能由多个联合队列和地址消费者共享。如果代理之间的连接丢失，每个联合消费者可能会尝试同时重新连接。为避免这种情况，称为 断路器的机制会 拦截使用者。当指定的超时值 elapses 时，断路器重新尝试连接。如果成功，用户就不会被阻塞。否则，会再次应用断路器。

   connection-ttl

   如果连接停止从远程代理接收信息，则持续时间（以毫秒为单位）。默认值为 60000。

   discovery-group-ref

   作为定义与上游代理连接的静态连接器的替代方法，可以使用这个元素来指定在 broker.xml 配置文件中已在其他位置配置的发现组。特别是，您可以将现有发现组指定为此元素的 discovery-group-name 属性的值。有关发现组的详情请参考 第 16.1.5 节 “代理发现方法”。

   ha

   指定是否为与上游代理的连接启用高可用性。如果此参数的值被设置为 true，本地代理可以连接到上游集群中任何可用的代理，并在实时上游代理关闭时自动切换到备份代理。默认值为：false。

   initial-connect-attempts

   下游代理要连接到上游代理的初始尝试数。如果在不建立连接的情况下达到这个值，则上游代理会被永久地离线。downstream 代理不再将消息路由到上游代理。默认值为 -1，这表示没有限制。

   max-retry-interval

   在连接到远程代理时，后续重新连接尝试间最大时间（以毫秒为单位）。默认值为 2000。

   reconnect-attempts

   如果连接失败，下游代理会尝试重新连接到上游代理的次数。如果在不重新建立连接的情况下达到这个值，则上游代理会被永久离线。downstream 代理不再将消息路由到上游代理。默认值为 -1，这表示没有限制。

   retry-interval

   如果连接到远程代理失败，则后续重新连接尝试之间的周期（以毫秒为单位）。默认值为 500。

   retry-interval-multiplier

   应用到 retry-interval 参数的值的因素。默认值为：1。

   share-connection

   如果为同一代理配置了下游和上游连接，则共享同一连接，只要下游和上游配置都设为 true。默认值为：false。

7. 在本地代理中，将连接器添加到远程代理中。这些是您联合地址配置 的静态 连接器元素中引用的连接器。例如：

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

步骤

1. 在本地代理上，打开 <broker-instance-dir>/etc/broker.xml 配置文件。

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

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

3. 添加地址策略配置。例如：

   <federations>
       ...
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <address-policy name="news-address-federation" max-hops="1" auto-delete="true" auto-delete-delay="300000" auto-delete-message-count="-1" transformer-ref="news-transformer">
   
               <include address-match="queue.bbc.new" />
               <include address-match="queue.usatoday" />
               <include address-match="queue.news.#" />
   
               <exclude address-match="queue.news.sport.#" />
           </address-policy>
   
       </federation>
     ...
   </federations>

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

   <federations>
       ...
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <address-policy name="news-address-federation" max-hops="1" auto-delete="true" auto-delete-delay="300000" auto-delete-message-count="-1" transformer-ref="news-transformer">
   
               <include address-match="queue.bbc.new" />
               <include address-match="queue.usatoday" />
               <include address-match="queue.news.#" />
   
               <exclude address-match="queue.news.sport.#" />
           </address-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>

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>
   
           <address-policy name="news-address-federation" max-hops="1" auto-delete="true" auto-delete-delay="300000" auto-delete-message-count="-1" transformer-ref="news-transformer">
               <include address-match="queue.bbc.new" />
               <include address-match="queue.usatoday" />
               <include address-match="queue.news.#" />
   
               <exclude address-match="queue.news.sport.#" />
           </address-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>

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

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>

   connector name="netty-connector"

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

   连接器名称="eu-west-1-connector", connector name="eu-east-1-connector"

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

   acceptor name="netty-acceptor"

   接受与远程代理用来连接到本地代理的连接器相对应的本地代理。

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 在新的 <federations> 元素中，添加 <federation> 元素。例如：

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

   name

   联合配置的名称。在本例中，名称对应于下游代理的名称。

   user

   与上游代理连接的共享用户名。

   password

   与上游代理连接的共享密码。

   注意

   • 如果上游代理的用户和密码凭证不同，您可以在将它们添加到配置中时为这些代理单独指定凭证。此流程稍后会加以描述。

3. 在 federation 元素中，添加 <queue-policy> 元素。指定 <queue-policy> 元素的属性值。例如：

   <federations>
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <queue-policy name="news-queue-federation" include-federated="true" priority-adjustment="-5" transformer-ref="news-transformer">
           </queue-policy>
   
       </federation>
   </federations>

   name

   队列策略的名称。代理上配置的所有队列策略都必须具有唯一的名称。

   include-federated

   当此属性的值设置为 false 时，配置不会重新影响已经受到影响的消费者（即联合队列上的使用者）。这可避免发生在对称或闭环拓扑中的情形，没有非破坏消费者，并在系统中最终出现消息流。

   如果您没有 闭环拓扑，您可以将此属性的值设置为 true。例如，假设您有三个代理（ BrokerA、BrokerB、BrokerB 和 BrokerC ）的链，在 BrokerA 和消费者在 BrokerC 上有一个消费者。在这种情况下，您希望 BrokerB 重新将消费者重新变为 BrokerA。

   Priority-adjustment

   当消费者连接到队列时，在创建上游（ 联合）消费者时使用其优先级。federated consumer 的优先级根据 priority-adjustment 属性的值调整。这个属性的默认值为 -1，这样可确保本地使用者在负载均衡期间优先于联合消费者。但是，您可以根据需要更改优先级调整的值。

   transformer-ref

   转换器配置的名称。如果要在联合消息传输过程中转换信息，可以添加转换器配置。此流程稍后会描述转换器配置。

4. 在 <queue-policy> 元素中，添加地址匹配模式以包括队列策略中的地址和排除地址。例如：

   <federations>
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <queue-policy name="news-queue-federation" include-federated="true" priority-adjustment="-5" 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>
   
       </federation>
   </federations>

   Include

   此元素的 address-match 属性值指定要包含在队列策略中的地址。您可以指定准确的地址，例如 queue.bbc.new 或 queue.usatoday。或者，您可以使用通配符表达式来指定 一组 匹配的地址。在前面的示例中，队列策略还包含以字符串 queue.news 开头的所有地址名。

   与 address-match 属性相结合，您可以使用 queue-match 属性将特定的队列包含到队列策略中的这些地址上。与 address-match 属性类似，您可以指定准确的队列名称，也可以使用通配符表达式来指定 一组 队列。在前面的示例中，数字符号(#)通配符字符表示，每个地址或地址集 的所有 队列都包含在队列策略中。

   exclude

   此元素的 address-match 属性值指定要从队列策略中排除的地址。您可以指定准确的地址，或使用通配符表达式来指定匹配的地址 集合。在前面的示例中，数字符号(#)通配符表示 所有 地址中与 queue-match 属性匹配的任何 队列。在这种情况下，所有以字符串 .local 结尾的队列都将被排除。这表明某些队列保留为本地队列，而不是联合。

5. 在 federation 元素中，添加 transformer 元素来引用自定义转换器实施。例如：

   <federations>
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <queue-policy name="news-queue-federation" include-federated="true" priority-adjustment="-5" 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>

   name

   转换器配置的名称。这个名称在代理上必须是唯一的。您可以将这个名称指定为 address 策略的 transformer-ref 属性的值。

   class-name

   实施 org.apache.activemq.core.server.transformer.Transformer 接口的用户定义的类的名称。

   转换器的 transform（） 方法会在消息被传输之前通过消息调用。这可让您在联合邮件标头或正文前转换该邮件标头或正文。

   属性

   用于存放特定转换器配置的键值对。

6. 在 federation 元素中，添加一个或多个 上游 元素。每个 上游 元素都定义了一个上游代理连接，以及应用到该连接的策略。例如：

   <federations>
       <federation name="eu-north-1" user="federation_username" password="32a10275cf4ab4e9">
   
           <upstream name="eu-east-1">
               <static-connectors>
                   <connector-ref>eu-east-connector1</connector-ref>
               </static-connectors>
               <policy ref="news-queue-federation"/>
           </upstream>
   
           <upstream name="eu-west-1" >
               <static-connectors>
                   <connector-ref>eu-west-connector1</connector-ref>
               </static-connectors>
               <policy ref="news-queue-federation"/>
           </upstream>
   
           <queue-policy name="news-queue-federation" include-federated="true" priority-adjustment="-5" 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>

   static-connectors

   包含连接器( connector-ref )元素列表，它引用本地代理的 broker.xml 配置文件中定义的 连接器 元素。连接器定义要用于传出连接的传输（TCP、SSL、HTTP 等）和服务器连接参数（主机、端口等）。此步骤的以下步骤演示了如何添加联合队列配置 的静态 连接器元素所引用的连接器。

   policy-ref

   在应用到上游代理的下游代理上配置的队列策略的名称。

   您可以针对 上游 元素指定的附加选项如下所述：

   name

   上游代理配置的名称。在本例中，名称对应于名为 eu-east-1 和 eu-west-1 的上游代理。

   user

   创建到上游代理的连接时使用的用户名。如果没有指定，则使用 federation 元素配置中指定的共享用户名。

   password

   创建到上游代理的连接时使用的密码。如果未指定，则使用 federation 元素配置中指定的共享密码。

   call-failover-timeout

   与 call-timeout 类似，但在进行故障转移尝试时使用了调用。默认值为 -1，这表示超时被禁用。

   call-timeout

   时间，以毫秒为单位，在传输一个阻塞调用的数据包时，联合连接会等待来自远程代理的回复。如果此时间过长，连接会引发异常。默认值为 30000。

   check-period

   周期，以毫秒为单位，本地代理发送到远程代理的连续"维持性"消息用于检查联合连接的健康状况。如果连接是健康的，远程代理会响应每个 keep-alive 信息。如果连接不健康，则当下游代理无法从上游代理接收响应时，则会使用一个称为 断路器 机制来阻止联合消费者。如需更多信息，请参阅 circuit-breaker-timeout 参数的描述。check-period 参数的默认值为 30000。

   circuit-breaker-timeout

   下游和上游代理之间的单一连接可能由多个联合队列和地址消费者共享。如果代理之间的连接丢失，每个联合消费者可能会尝试同时重新连接。为避免这种情况，称为 断路器的机制会 拦截使用者。当指定的超时值 elapses 时，断路器重新尝试连接。如果成功，用户就不会被阻塞。否则，会再次应用断路器。

   connection-ttl

   如果连接停止从远程代理接收信息，则持续时间（以毫秒为单位）。默认值为 60000。

   discovery-group-ref

   作为定义与上游代理连接的静态连接器的替代方法，可以使用这个元素来指定在 broker.xml 配置文件中已在其他位置配置的发现组。特别是，您可以将现有发现组指定为此元素的 discovery-group-name 属性的值。有关发现组的详情请参考 第 16.1.5 节 “代理发现方法”。

   ha

   指定是否为与上游代理的连接启用高可用性。如果此参数的值被设置为 true，本地代理可以连接到上游集群中任何可用的代理，并在实时上游代理关闭时自动切换到备份代理。默认值为：false。

   initial-connect-attempts

   下游代理要连接到上游代理的初始尝试数。如果在不建立连接的情况下达到这个值，则上游代理会被永久地离线。downstream 代理不再将消息路由到上游代理。默认值为 -1，这表示没有限制。

   max-retry-interval

   在连接到远程代理时，后续重新连接尝试间最大时间（以毫秒为单位）。默认值为 2000。

   reconnect-attempts

   如果连接失败，下游代理会尝试重新连接到上游代理的次数。如果在不重新建立连接的情况下达到这个值，则上游代理会被永久离线。downstream 代理不再将消息路由到上游代理。默认值为 -1，这表示没有限制。

   retry-interval

   如果连接到远程代理失败，则后续重新连接尝试之间的周期（以毫秒为单位）。默认值为 500。

   retry-interval-multiplier

   应用到 retry-interval 参数的值的因素。默认值为：1。

   share-connection

   如果为同一代理配置了下游和上游连接，则共享同一连接，只要下游和上游配置都设为 true。默认值为：false。

7. 在本地代理中，将连接器添加到远程代理中。这些是您联合地址配置 的静态 连接器元素中引用的连接器。例如：

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

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

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

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

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>

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>

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>

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

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>

   connector name="netty-connector"

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

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

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

   acceptor name="netty-acceptor"

   接受与远程代理用来连接到本地代理的连接器相对应的本地代理。

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 对于给定的接受者，请添加 sslEnabled 密钥，并将值设置为 true。另外，添加 keyStorePath 和 keyStorePassword 键。设置与代理密钥存储对应的值。例如：

   <acceptor name="artemis">tcp://0.0.0.0:61616?sslEnabled=true;keyStorePath=../etc/broker.keystore;keyStorePassword=1234!</acceptor>

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 对于您之前为单向 TLS 配置的接受者，请添加 needClientAuth 密钥。将值设为 true。例如：

   <acceptor name="artemis">tcp://0.0.0.0:61616?sslEnabled=true;keyStorePath=../etc/broker.keystore;keyStorePassword=1234!;needClientAuth=true</acceptor>

3. 上一步骤中的配置假定客户端证书由受信任的提供程序签名。如果客户端的证书 没有 由受信任的提供程序签名（例如，它是自签名的，例如，代理需要将客户端证书导入到信任存储中。在这种情况下，添加 trustStorePath 和 trustStorePassword 密钥。设置与代理信任存储对应的值。例如：

   <acceptor name="artemis">tcp://0.0.0.0:61616?sslEnabled=true;keyStorePath=../etc/broker.keystore;keyStorePassword=1234!;needClientAuth=true;trustStorePath=../etc/client.truststore;trustStorePassword=5678!</acceptor>

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 在 security-settings 元素内，添加一个 security-setting 元素来配置权限。例如：

   <security-settings>
       <security-setting match="#">
           <permission type="createDurableQueue" roles="user"/>
           <permission type="deleteDurableQueue" roles="user"/>
           <permission type="createNonDurableQueue" roles="user"/>
           <permission type="deleteNonDurableQueue" roles="user"/>
           <permission type="send" roles="user"/>
           <permission type="consume" roles="user"/>
       </security-setting>
   </security-settings>

   上述配置为 所有 队列分配特定权限 到用户 角色的成员。

3. 打开 <broker-instance-dir>/etc/login.config 文件。

4. 根据您要使用的目录服务，配置 LDAP 登录模块。

   1. 如果您使用 Microsoft Active Directory 目录服务，请添加类似以下示例的配置：

      activemq {
        org.apache.activemq.artemis.spi.core.security.jaas.LDAPLoginModule required
           debug=true
           initialContextFactory=com.sun.jndi.ldap.LdapCtxFactory
           connectionURL="LDAP://localhost:389"
           connectionUsername="CN=Administrator,CN=Users,OU=System,DC=example,DC=com"
           connectionPassword=redhat.123
           connectionProtocol=s
           connectionTimeout=5000
           authentication=simple
           userBase="dc=example,dc=com"
           userSearchMatching="(CN={0})"
           userSearchSubtree=true
           readTimeout=5000
           roleBase="dc=example,dc=com"
           roleName=cn
           roleSearchMatching="(member={0})"
           roleSearchSubtree=true
           ;
      };

      注意

      如果使用 Microsoft Active Directory，并且需要为 connectionUsername 属性指定一个空格（例如 OU=System Accounts）的值，您必须将该值包括在双引号("")中，并使用反斜杠(\)转义对对中的每个双引号("")。例如，connectionUsername="CN=Administrator,CN=Users,OU=\"System Accounts\",DC=example,DC=com"。

   2. 如果您使用 ApacheDS 目录服务，请添加类似以下示例的配置：

      activemq {
        org.apache.activemq.artemis.spi.core.security.jaas.LDAPLoginModule required
           debug=true
           initialContextFactory=com.sun.jndi.ldap.LdapCtxFactory
           connectionURL="ldap://localhost:10389"
           connectionUsername="uid=admin,ou=system"
           connectionPassword=secret
           connectionProtocol=s
           connectionTimeout=5000
           authentication=simple
           userBase="dc=example,dc=com"
           userSearchMatching="(uid={0})"
           userSearchSubtree=true
           userRoleName=
           readTimeout=5000
           roleBase="dc=example,dc=com"
           roleName=cn
           roleSearchMatching="(member={0})"
           roleSearchSubtree=true
           ;
      };

      debug

      打开(true)或关闭(false)。默认值为：false。

      initialContextFactory

      必须始终设置为 com.sun.jndi.ldap.LdapCtxFactory

      connectionURL

      使用 LDAP URL __<ldap://Host:Port> 的目录服务器位置。一个（可选）可以通过添加正斜杠 / （后跟目录树中特定节点的 DN）来证明这个 URL。Apache DS 的默认端口为 10389，而对于 Microsoft AD 的默认值是 389。

      connectionUsername

      打开与目录服务器的连接的用户的可区分名称(DN)。例如： uid=admin,ou=system。目录服务器通常需要客户端显示用户名/密码凭据，以便能打开连接。

      connectionPassword

      与来自 connectionUsername 的 DN 匹配的密码。在目录服务器中，在 Directory Information Tree (DIT)中，密码通常作为 userPassword 属性存储在相应的目录条目中。

      connectionProtocol

      支持所有值，但实际上没有被使用。必须明确设置这个选项，因为它没有默认值。

      connectionTimeout

      指定代理可以连接到目录服务器的最长时间，以毫秒为单位。如果代理无法在此时间内连接到目录 s，它将会中止连接尝试。如果您为此属性指定零或小于值，则使用底层 TCP 协议的超时值。如果没有指定值，代理会无限期等待建立连接，或者底层网络超时。

      当为连接池请求了连接池时，此属性指定代理在达到最大池大小且池中所有连接都处于连接的最长时间。如果您指定了零或更少值，则代理会无限期等待连接可用。否则，代理会在达到最长等待时间时中止连接尝试。

      身份验证

      指定绑定到 LDAP 服务器时使用的身份验证方法。这个参数可以设置为 简单 （需要用户名和密码）或 none （允许匿名访问）。

      userBase

      选择 DIT 的特定子树来搜索用户条目。子树通过 DN 指定，用于指定子树的基本节点。例如，将此选项设置为 ou=User,ou=ActiveMQ,ou=system,ou=system，搜索用户条目仅限于 ou=User,ou=ActiveMQ,ou=system 节点下的子树。

      userSearchMatching

      指定一个 LDAP 搜索过滤器，它应用到 userBase 选择的子树。详情请查看下面的 第 5.4.1.1 节 “搜索匹配参数” 部分。

      userSearchSubtree

      相对于由 userBase 指定的节点，指定用户条目的搜索深度。此选项是一个布尔值。指定一个 false 值表示搜索尝试匹配 用户Base 节点的其中一个子条目（映射到 javax.naming.directory.SearchControls.ONELEVEL_SCOPE）。指定一个 true 值表示搜索尝试匹配 属于用户Base 节点 的子树 的任何条目（映射到 javax.naming.directory.SearchControls.SUBTREE_SCOPE）。

      userRoleName

      user 条目的属性名称，其中包含用户的角色名称列表。角色名称由代理的授权插件解析为组名称。如果省略这个选项，则不会从用户条目中提取角色名称。

      readTimeout

      指定代理可以等待从目录服务器到 LDAP 请求的响应的最长时间，以毫秒为单位。如果代理没有从目录服务器接收响应，代理会中止请求。如果您指定一个零个或更少值，或者您没有指定值，则代理会无限期等待目录服务器中的响应进入 LDAP 请求。

      roleBase

      如果角色数据直接存储在目录服务器中，则可以使用角色选项（角色Base、roleSearchMatching、roleSearchSubtree 和 roleName）的组合来指定 userRoleName 选项。这个选项选择 DIT 的特定子树来搜索 role/group 条目。子树通过 DN 指定，用于指定子树的基本节点。例如，将此选项设置为 ou=Group,ou=ActiveMQ,ou=system,ou=system ,ou=system 条目的搜索仅限于 ou=Group,ou=ActiveMQ,ou=system node 下的子树。

      roleName

      角色条目的属性类型，其中包含角色/组的名称（如 C、O、OU 等）。如果忽略了这个选项，则有效禁用角色搜索功能。

      roleSearchMatching

      指定 LDAP 搜索过滤器，它应用到 roleBase 选择的子树。详情请查看下面的 第 5.4.1.1 节 “搜索匹配参数” 部分。

      roleSearchSubtree

      根据 roleBase 指定的节点，指定角色条目的搜索深度。如果设置为 false （默认为 false），则搜索尝试匹配 角色Base 节点的其中一个子条目（映射到 javax.naming.directory.SearchControls.ONELEVEL_SCOPE）。如果为 true，它将尝试匹配属于角色Base 节点的子树的任何条目（映射到 javax.naming.directory.SearchControls.SUBTREE_SCOPE）。

      注意

      Apache DS 使用 DN 路径的 OID 部分。Microsoft Active Directory 使用 CN 部分。例如，您可以在 Apache DS 中使用 DN 路径，如 oid=testuser,dc=example,dc=com，而您可能在 Microsoft Active Directory 中使用 DN 路径，如 cn=testuser,dc=example,dc=com。

5. 启动或重启代理（服务或进程）。

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 在 security-settings 元素内，添加 security-setting-plugin 元素。例如：

   <security-settings>
       <security-setting-plugin class-name="org.apache.activemq.artemis.core.server.impl.LegacyLDAPSecuritySettingPlugin">
           <setting name="initialContextFactory" value="com.sun.jndi.ldap.LdapCtxFactory"/>
           <setting name="connectionURL" value="ldap://localhost:1024"/>`ou=destinations,o=ActiveMQ,ou=system`
           <setting name="connectionUsername" value="uid=admin,ou=system"/>
           <setting name="connectionPassword" value="secret"/>
           <setting name="connectionProtocol" value="s"/>
           <setting name="authentication" value="simple"/>
       </security-setting-plugin>
   </security-settings>

   class-name

   实施是 org.apache.activemq.artemis.core.server.impl.LegacyLDAPSecuritySettingPlugin。

   initialContextFactory

   用于连接到 LDAP 的初始上下文工厂。它必须始终设置为 com.sun.jndi.ldap.LdapCtxFactory （即默认值）。

   connectionURL

   使用 LDAP URL 指定目录服务器的位置，<ldap://Host:Port>。您可以选择通过在目录树中添加正斜杠 / 并在目录树中添加可分辨名称(DN)来证明此 URL。例如： ldap://ldapserver:10389/ou=system。默认值为 ldap://localhost:1024。

   connectionUsername

   将打开与目录服务器连接的用户的 DN。例如： uid=admin,ou=system。目录服务器通常需要客户端显示用户名/密码凭据，以便能打开连接。

   connectionPassword

   与来自 connectionUsername 的 DN 匹配的密码。在目录服务器中，在 Directory Information Tree (DIT)中，密码通常作为 userPassword 属性存储在相应的目录条目中。

   connectionProtocol

   当前未使用的.以后，此选项可能会允许您为与目录服务器的连接选择安全套接字层(SSL)。必须明确设置这个选项，因为它没有默认值。

   身份验证

   指定绑定到 LDAP 服务器时使用的身份验证方法。此参数的有效值为 simple （用户名和密码）或 none （匿名）。默认值为 simple。

   注意

   不支持 简单的身份验证和安全层(SASL)身份验证。

1. 在命令提示符中，使用 mask 工具加密密码：

   $ <broker_instance_dir>/bin/artemis mask <password>

   result: 3a34fd21b82bf2a822fa49a8d8fa115d

2. 打开 <broker_instance_dir>/etc/login.config 文件。找到 connectionPassword 参数：

   connectionPassword = <password>

3. 使用加密值替换 plain-text 密码：

   connectionPassword = 3a34fd21b82bf2a822fa49a8d8fa115d

4. 使用标识符 "ENC（）" 打包加密值：

   connectionPassword = "ENC(3a34fd21b82bf2a822fa49a8d8fa115d)"

步骤

1. 停止代理。

   1. 在 Linux 中：

      <broker_instance_dir>/bin/artemis stop

   2. 在 Windows 上：

      <broker_instance_dir>\bin\artemis-service.exe stop

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

3. 将 name-value 对 saslMechanisms=GSSAPI 添加到接收器 URL 的 查询字符串。

   <acceptor name="amqp">
     tcp://0.0.0.0:5672?protocols=AMQP;saslMechanisms=GSSAPI
   </acceptor>

   上述配置意味着接受者在验证 Kerberos 凭证时使用 GSSAPI 机制。

4. （可选）还支持 PLAIN 和 ANONYMOUS SASL 机制。要指定多个机制，请使用逗号分隔的列表。例如：

   <acceptor name="amqp">
     tcp://0.0.0.0:5672?protocols=AMQP;saslMechanisms=GSSAPI,PLAIN
   </acceptor>

   结果为使用 GSSAPI 和 PLAIN SASL 机制的接受者。

5. 启动代理。

   1. 在 Linux 中：

      <broker_instance_dir>/bin/artemis run

   2. 在 Windows 上：

      <broker_instance_dir>\bin\artemis-service.exe start

步骤

1. 停止代理。

   1. 在 Linux 中：

      <broker_instance_dir>/bin/artemis stop

   2. 在 Windows 上：

      <broker_instance_dir>\bin\artemis-service.exe stop

2. 打开 <broker_instance_dir>/etc/login.config 配置文件。

3. 添加名为 amqp-sasl-gssapi 的配置范围。以下示例显示了在 JDK 的 Oracle 和 OpenJDK 版本中找到的 Krb5LoginModule 的配置。

   amqp-sasl-gssapi {
       com.sun.security.auth.module.Krb5LoginModule required
       isInitiator=false
       storeKey=true
       useKeyTab=true
       principal="amqp/my_broker_host@example.com"
       debug=true;
   };

   amqp-sasl-gssapi

   默认情况下，代理上的 GSSAPI 机制实施使用名为 amqp-sasl-gssapi 的 JAAS 配置范围来获取其 Kerberos 接收器凭证。

   Krb5LoginModule

   此版本的 Krb5LoginModule 由 JDK 的 Oracle 和 OpenJDK 版本提供。通过引用 Java 供应商的文档，验证 Krb5LoginModule 及其可用选项的完全限定类名称。

   useKeyTab

   Krb5LoginModule 在验证主体时使用 Kerberos keytab。keytabs 使用来自 Kerberos 环境的工具生成。有关生成 Kerberos keytab 的详情，请查看您的厂商文档。

   principal

   Principal 设置为 amqp/my_broker_host@example.com。这个值必须与在 Kerberos 环境中创建的服务主体对应。有关创建服务主体的详情，请查看您的厂商文档。

4. 启动代理。

   1. 在 Linux 中：

      <broker_instance_dir>/bin/artemis run

   2. 在 Windows 上：

      <broker_instance_dir>\bin\artemis-service.exe start

步骤

1. 停止代理。

   1. 在 Linux 中：

      <broker_instance_dir>/bin/artemis stop

   2. 在 Windows 上：

      <broker_instance_dir>\bin\artemis-service.exe stop

2. 打开 <broker_instance_dir>/etc/login.config 配置文件。

3. 添加 AMQ Broker Krb5LoginModule 和 LDAPLoginModule 的配置。通过引用 LDAP 供应商的文档来验证配置选项。

   下方显示了一个示例配置：

   org.apache.activemq.artemis.spi.core.security.jaas.Krb5LoginModule required
       ;
   org.apache.activemq.artemis.spi.core.security.jaas.LDAPLoginModule optional
       initialContextFactory=com.sun.jndi.ldap.LdapCtxFactory
       connectionURL="ldap://localhost:1024"
       authentication=GSSAPI
       saslLoginConfigScope=broker-sasl-gssapi
       connectionProtocol=s
       userBase="ou=users,dc=example,dc=com"
       userSearchMatching="(krb5PrincipalName={0})"
       userSearchSubtree=true
       authenticateUser=false
       roleBase="ou=system"
       roleName=cn
       roleSearchMatching="(member={0})"
       roleSearchSubtree=false
       ;

   注意

   上例中显示的 Krb5LoginModule 版本通过 AMQ Broker 发布，并将 Kerberos 身份转换为可供其他 AMQ 模块用于角色映射的代理身份。

4. 启动代理。

   1. 在 Linux 中：

      <broker_instance_dir>/bin/artemis run

   2. 在 Windows 上：

      <broker_instance_dir>\bin\artemis-service.exe start

步骤

1. 打开 <broker-instance-dir>/etc/boostrap.xml 配置文件。

2. 在 class-name 属性的 security-manager 元素中，指定 class 是 org.apache.activemq.artemis.spi.core.security.ActiveMQSecurityManager5 接口的用户定义的实施。例如：

   <broker xmlns="http://activemq.org/schema">
      ...
      <security-manager class-name="com.foo.MySecurityManager">
         <property key="myKey1" value="myValue1"/>
         <property key="myKey2" value="myValue2"/>
      </security-manager>
      ...
   </broker>

步骤

1. 导航到 目录，前往包含自定义安全管理器示例的目录。

   $ cd <install-dir>/examples/features/standard/security-manager

2. 运行 示例。

   $ mvn verify

步骤

1. 在命令提示符中，使用 mask 工具加密密码：

   $ <broker_instance_dir>/bin/artemis mask <password>

   result: 3a34fd21b82bf2a822fa49a8d8fa115d

2. 打开 <broker_instance_dir>/etc/broker.xml 配置文件，其中包含您要屏蔽的纯文本密码：

   <cluster-password>
     <password>
   </cluster-password>

3. 使用加密值替换 plain-text 密码：

   <cluster-password>
     3a34fd21b82bf2a822fa49a8d8fa115d
   </cluster-password>

4. 使用标识符 ENC（） 结束加密的值：

   <cluster-password>
     ENC(3a34fd21b82bf2a822fa49a8d8fa115d)
   </cluster-password>

步骤

1. 作为 BROKER_INSTANCE_DIR 的所有者，停止代理。在以下示例中，用户 amq-broker 是在安装 AMQ Broker 的过程中创建的。

   su - amq-broker
   cd __BROKER_INSTANCE_DIR__/bin
   $ ./artemis stop

2. （可选）运行以下 CLI 命令，以获取数据工具的完整参数列表。请注意，工具默认使用 BROKER_INSTANCE_DIR/etc/broker.xml 中的设置。

   $ ./artemis help data compact.

3. 运行以下 CLI 命令以压缩数据。

   $ ./artemis data compact.

4. 在工具成功压缩数据后，重启代理。

   $ ./artemis run

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 在 <core> 元素中添加以下连接器：

   • 一个连接器，定义了其他代理可以如何连接到这个代理
   • 一个或多个用来定义此代理如何连接到集群中的其它代理的连接器

   <configuration>
       <core>
           ...
           <connectors>
               <connector name="netty-connector">tcp://localhost:61617</connector>  1
               <connector name="broker2">tcp://localhost:61618</connector>  2
               <connector name="broker3">tcp://localhost:61619</connector>
           </connectors>
           ...
       </core>
   </configuration>

   1

   此连接器定义其他代理可用于连接到此代理的连接信息。这些信息将在发现过程中发送到集群中的其他代理。

   2

   broker2 和 broker3 连接器定义此代理如何连接到集群中的两个其他代理，其中一个代理始终可用。如果集群中还有其他代理，则在进行初始连接时，这些连接器之一会发现它们。

   有关连接器的更多信息，请参阅 第 2.2 节 “关于连接器”。

3. 添加集群连接并把它配置为使用静态发现。

   默认情况下，集群连接将加载对称拓扑中所有地址的消息。

   <configuration>
       <core>
           ...
           <cluster-connections>
               <cluster-connection name="my-cluster">
                   <connector-ref>netty-connector</connector-ref>
                   <static-connectors>
                       <connector-ref>broker2-connector</connector-ref>
                       <connector-ref>broker3-connector</connector-ref>
                   </static-connectors>
               </cluster-connection>
           </cluster-connections>
           ...
       </core>
   </configuration>

   cluster-connection

   使用 name 属性指定集群连接的名称。

   connector-ref

   定义其他代理可以如何连接到此代理的连接器。

   static-connectors

   此代理可以使用一个或多个连接器，与集群中的其他代理进行初始连接。进行此初始连接后，代理将发现集群中的其他代理。只有当集群使用静态发现时，才需要配置此属性。

4. 配置集群连接的任何其他属性。

   这些额外的集群连接属性具有适用于大多数常见用例的默认值。因此，如果您不希望默认行为，您只需要配置这些属性。如需更多信息，请参阅 附录 C, Cluster Connection Configuration 元素。

5. 创建集群用户和密码。

   AMQ Broker 附带默认集群凭证，但您应该更改它们以防止未授权的远程客户端使用这些默认凭证来连接代理。

   重要

   集群密码必须与集群中的每个代理相同。

   <configuration>
       <core>
           ...
           <cluster-user>cluster_user</cluster-user>
           <cluster-password>cluster_user_password</cluster-password>
           ...
       </core>
   </configuration>

6. 在每个额外代理上重复此步骤。

   您可以将集群配置复制到每个额外代理中。但是，不要复制其他 AMQ Broker 数据文件（如绑定、日志和大型消息目录）。这些文件在集群中的节点之间必须是唯一的，否则集群无法正确表单。

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 在 <core> 元素中，添加连接器。

   此连接器定义其他代理可用于连接到此代理的连接信息。这些信息将在发现过程中发送到集群中的其他代理。

   <configuration>
       <core>
           ...
           <connectors>
               <connector name="netty-connector">tcp://localhost:61617</connector>
           </connectors>
           ...
       </core>
   </configuration>

3. 添加 UDP 广播组。

   广播组可让代理将其集群连接的信息推送到集群中的其他代理。这个广播组使用 UDP 广播连接设置：

   <configuration>
       <core>
           ...
           <broadcast-groups>
               <broadcast-group name="my-broadcast-group">
                   <local-bind-address>172.16.9.3</local-bind-address>
                   <local-bind-port>-1</local-bind-port>
                   <group-address>231.7.7.7</group-address>
                   <group-port>9876</group-port>
                   <broadcast-period>2000</broadcast-period>
                   <connector-ref>netty-connector</connector-ref>
               </broadcast-group>
           </broadcast-groups>
           ...
       </core>
   </configuration>

   除非另有说明，否则需要以下参数：

   broadcast-group

   使用 name 属性指定广播组的唯一名称。

   local-bind-address

   绑定 UDP 套接字的地址。如果您的代理上有多个网络接口，则需要指定您要用于广播的接口。如果没有指定此属性，则套接字将绑定到操作系统所选 IP 地址。这是特定于 UDP 的属性。

   local-bind-port

   数据报套接字绑定的端口。在大多数情况下，使用 -1 默认值，它指定了匿名端口。此参数用于与 local-bind-address 的连接。这是特定于 UDP 的属性。

   group-address

   数据要广播的多播地址。它是一类 D IP 地址，范围为 224.0.0.0 - 239.255.255.255 （含）。地址 224.0.0.0 会被保留，不可用。这是特定于 UDP 的属性。

   group-port

   用于广播的 UDP 端口号。这是特定于 UDP 的属性。

   broadcast-period （可选）

   连续广播之间的时间间隔（以毫秒为单位）。默认值为 2000 毫秒。

   connector-ref

   之前配置的群集连接器应该被广播。

4. 添加 UDP 发现组。

   发现组定义了此代理从其他代理接收连接器信息的方式。代理维护一个连接器列表（每个代理的一个条目）。当从代理接收广播时，它会更新其条目。如果没有从代理接收广播的时间长度，它会删除该条目。

   此发现组使用 UDP 发现集群中的代理：

   <configuration>
       <core>
           ...
           <discovery-groups>
               <discovery-group name="my-discovery-group">
                   <local-bind-address>172.16.9.7</local-bind-address>
                   <group-address>231.7.7.7</group-address>
                   <group-port>9876</group-port>
                   <refresh-timeout>10000</refresh-timeout>
               </discovery-group>
           <discovery-groups>
           ...
       </core>
   </configuration>

   除非另有说明，否则需要以下参数：

   discovery-group

   使用 name 属性指定发现组的唯一名称。

   local-bind-address （可选）

   如果运行代理的机器使用多个网络接口，您可以指定发现组应该侦听的网络接口。这是特定于 UDP 的属性。

   group-address

   要侦听的组的多播地址。它应当与您要侦听的广播组中的 group-address 匹配。这是特定于 UDP 的属性。

   group-port

   多播组的 UDP 端口号。它应当与您要侦听的广播组中的 group-port 匹配。这是特定于 UDP 的属性。

   refresh-timeout （可选）

   发现组在从特定代理接收最后一次广播后等待的时间（以毫秒为单位），然后再从其列表中删除代理的连接器对条目。默认值为 10000 毫秒（10 秒）。

   把它设置为比广播组的 广播期间 值高得多。否则，即使代理仍然广播（由于时间略有差异），代理可能会定期从列表中消失。

5. 创建集群连接并将其配置为使用动态发现。

   默认情况下，集群连接将加载对称拓扑中所有地址的消息。

   <configuration>
       <core>
           ...
           <cluster-connections>
               <cluster-connection name="my-cluster">
                   <connector-ref>netty-connector</connector-ref>
                   <discovery-group-ref discovery-group-name="my-discovery-group"/>
               </cluster-connection>
           </cluster-connections>
           ...
       </core>
   </configuration>

   cluster-connection

   使用 name 属性指定集群连接的名称。

   connector-ref

   定义其他代理可以如何连接到此代理的连接器。

   discovery-group-ref

   此代理用来定位集群其他成员的发现组。只有当集群使用动态发现时，才需要配置此属性。

6. 配置集群连接的任何其他属性。

   这些额外的集群连接属性具有适用于大多数常见用例的默认值。因此，如果您不希望默认行为，您只需要配置这些属性。如需更多信息，请参阅 附录 C, Cluster Connection Configuration 元素。

7. 创建集群用户和密码。

   AMQ Broker 附带默认集群凭证，但您应该更改它们以防止未授权的远程客户端使用这些默认凭证来连接代理。

   重要

   集群密码必须与集群中的每个代理相同。

   <configuration>
       <core>
           ...
           <cluster-user>cluster_user</cluster-user>
           <cluster-password>cluster_user_password</cluster-password>
           ...
       </core>
   </configuration>

8. 在每个额外代理上重复此步骤。

   您可以将集群配置复制到每个额外代理中。但是，不要复制其他 AMQ Broker 数据文件（如绑定、日志和大型消息目录）。这些文件在集群中的节点之间必须是唯一的，否则集群无法正确表单。

步骤

1. 打开 <broker-instance-dir>/etc/broker.xml 配置文件。

2. 在 <core> 元素中，添加连接器。

   此连接器定义其他代理可用于连接到此代理的连接信息。这些信息将在发现过程中发送到集群中的其他代理。

   <configuration>
       <core>
           ...
           <connectors>
               <connector name="netty-connector">tcp://localhost:61617</connector>
           </connectors>
           ...
       </core>
   </configuration>

3. 在 <core> 元素中，添加 JGroups 广播组。

   广播组可让代理将其集群连接的信息推送到集群中的其他代理。这个广播组使用 JGroups 来广播连接设置：

   <configuration>
       <core>
           ...
           <broadcast-groups>
               <broadcast-group name="my-broadcast-group">
                   <jgroups-file>test-jgroups-file_ping.xml</jgroups-file>
                   <jgroups-channel>activemq_broadcast_channel</jgroups-channel>
                   <broadcast-period>2000</broadcast-period>
                   <connector-ref>netty-connector</connector-ref>
               </broadcast-group>
           </broadcast-groups>
           ...
       </core>
   </configuration>

   除非另有说明，否则需要以下参数：

   broadcast-group

   使用 name 属性指定广播组的唯一名称。

   jgroups-file

   用于初始化 JGroups 通道的 JGroups 配置文件名称。该文件必须位于 Java 资源路径中，以便代理可以加载它。

   jgroups-channel

   要连接到以进行广播的 JGroups 通道的名称。

   broadcast-period （可选）

   连续广播之间的时间间隔，以毫秒为单位。默认值为 2000 毫秒。

   connector-ref

   之前配置的群集连接器应该被广播。

4. 添加 JGroups 发现组。

   发现组定义连接器信息的方式。代理维护一个连接器列表（每个代理的一个条目）。当从代理接收广播时，它会更新其条目。如果没有从代理接收广播的时间长度，它会删除该条目。

   此发现组使用 JGroups 来发现集群中的代理：

   <configuration>
       <core>
           ...
           <discovery-groups>
               <discovery-group name="my-discovery-group">
                   <jgroups-file>test-jgroups-file_ping.xml</jgroups-file>
                   <jgroups-channel>activemq_broadcast_channel</jgroups-channel>
                   <refresh-timeout>10000</refresh-timeout>
               </discovery-group>
           <discovery-groups>
           ...
       </core>
   </configuration>

   除非另有说明，否则需要以下参数：

   discovery-group

   使用 name 属性指定发现组的唯一名称。

   jgroups-file

   用于初始化 JGroups 通道的 JGroups 配置文件名称。该文件必须位于 Java 资源路径中，以便代理可以加载它。

   jgroups-channel

   要连接的 JGroups 通道的名称，以接收广播。

   refresh-timeout （可选）

   发现组在从特定代理接收最后一次广播后等待的时间（以毫秒为单位），然后再从其列表中删除代理的连接器对条目。默认值为 10000 毫秒（10 秒）。

   把它设置为比广播组的 广播期间 值高得多。否则，即使代理仍然广播（由于时间略有差异），代理可能会定期从列表中消失。

5. 创建集群连接并将其配置为使用动态发现。

   默认情况下，集群连接将加载对称拓扑中所有地址的消息。

   <configuration>
       <core>
           ...
           <cluster-connections>
               <cluster-connection name="my-cluster">
                   <connector-ref>netty-connector</connector-ref>
                   <discovery-group-ref discovery-group-name="my-discovery-group"/>
               </cluster-connection>
           </cluster-connections>
           ...
       </core>
   </configuration>

   cluster-connection

   使用 name 属性指定集群连接的名称。

   connector-ref

   定义其他代理可以如何连接到此代理的连接器。

   discovery-group-ref

   此代理用来定位集群其他成员的发现组。只有当集群使用动态发现时，才需要配置此属性。

6. 配置集群连接的任何其他属性。

   这些额外的集群连接属性具有适用于大多数常见用例的默认值。因此，如果您不希望默认行为，您只需要配置这些属性。如需更多信息，请参阅 附录 C, Cluster Connection Configuration 元素。

7. 创建集群用户和密码。

   AMQ Broker 附带默认集群凭证，但您应该更改它们以防止未授权的远程客户端使用这些默认凭证来连接代理。

   重要

   集群密码必须与集群中的每个代理相同。

   <configuration>
       <core>
           ...
           <cluster-user>cluster_user</cluster-user>
           <cluster-password>cluster_user_password</cluster-password>
           ...
       </core>
   </configuration>

8. 在每个额外代理上重复此步骤。

   您可以将集群配置复制到每个额外代理中。但是，不要复制其他 AMQ Broker 数据文件（如绑定、日志和大型消息目录）。这些文件在集群中的节点之间必须是唯一的，否则集群无法正确表单。