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

流程

1. 打开 <broker_instance_dir>/etc/broker.xml 配置文件。
2. 将用于 STOMP 连接的接收器的 stomp EnableMessageId 参数设置为 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 时，指示代理使用您的自定义设置。

   delimiter

   提供要用作 分隔符 的自定义字符，而非默认的 字符，即：

   any-words

   作为 any-words 的值提供的字符表示 'match of zero or more word'，并将替换默认值 #。在表达式末尾使用此字符。

   single-word

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

流程

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

2. 将 anycast 配置元素包装在所选的 队列 元素周围 。确保 地址 和 队列 元素的 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. 将 anycast 配置元素周围的 address 元素包装到 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>

   注意

   由于队列默认为持久，因此在创建 持久 队列时，包括持久元素并将值设置为 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>

   注意

   由于队列默认为持久，因此在创建 持久 队列时，包括持久元素并将值设置为 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。为此，请将 最后值键 添加到给定队列中。将值设为 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>

   注意

   默认情况下，default -non-destructive 的值为 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，即它们不会过期。对于过期时间大于默认的消息，expiration -delay 无效。

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

4. 另外，您可以指定最小和最大 到期延迟值，而不是为 expiration-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 的消息，代理会将过期时间设置为 max-expiry-delay 的指定值。
   • 对于过期时间低于 min-expiry-delay 的消息，代理会将过期时间设置为 min-expiry-delay 的指定值。
   • 对于在 min-expiry-delay 和 max-expiry-delay 之间带有 expiration 的消息， 代理不会更改消息的过期时间。
   • 如果您为 expiry-delay 指定一个值（即默认值 -1以外的值），这将覆盖您为 min-expiry-delay 和 max-expir y-delay 指定的任何值。
   • min-expiry-delay 和 max- expiry-delay 的默认值都是 -1 （即禁用）。

5. 在 配置文件的 address 元素中，配置之前为 expiration -address 指定 的地址。在此地址上定义队列.例如：

   <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> 元素来定义到期地址和关联的到期队列。auto-created <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

   死信地址的名称。在本例中，代理将未传送的消息从队列 exampleQueue 移动到死信地址 DLA。

   max-delivery-attempts

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

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

   <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> 指定的名称值匹配。

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

   代理还为使用 _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 键添加到 队列 元素中。指定一个值。例如：

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

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

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

   此时，Message Count= 3 和 delivery Count= 3。

3. 制作者向队列发送另一条消息。该消息随后被分配给消费者。

   现在，MessageCount = 4 和 deliveryCount = 4。消息数 4 大于配置的环大小 3。但是，代理会坚持允许这种情况，因为它无法从队列中删除传输中消息。

4. 现在，假设消费者未拒绝任何消息即可关闭。

   在这种情况下，四个未确认的消息将被取消到代理，并按使用它们的相反顺序添加到队列头。此操作在其配置的环大小上放置队列。由于环队列将队列末尾的消息优先于头条消息，因此队列会丢弃制作者发送的第一条消息，因为这是最近一次添加回队列头的消息。事务或核心会话回滚的方式相同。

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

   此时，Message Count= 1 和 schedule Count= 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 可根据需求侦听此绑定。如果存在带有与地址策略所包含地址匹配的地址转换的绑定，则任何与转义地址的转发地址匹配的队列绑定都将产生需求。默认值为 false。

   max-hops

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

   transformer-ref

   转换器配置的名称。如果要在联合消息传输过程中转换消息，您可以添加转换器配置。此流程稍后将介绍转换器配置。

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

   <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 属性的值指定要包含在 address 策略中的地址。您可以指定一个精确的地址，如 queue. bbc.new 或 queue.usatoday。或者，您可以使用通配符表达式来指定匹配的地址 集合。在前面的示例中，地址策略还包含以字符串 queue.news 开头的 所有 地址名称。

   exclude

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

5. （可选）在联合 元素 中，添加一个转换 器 元素来引用自定义转换器实施。例如：

   <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

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

   class-name

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

   转换器的 transformation （） 方法通过消息调用，然后再传输消息。这可让您在联合之前转换邮件标题或正文。

   属性

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

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 and eu-west-1 的上游代理对应。

   user

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

   password

   创建与上游代理连接时使用的密码。如果没有指定，则使用在联合 元素 配置中指定的共享密码。

   call-failover-timeout

   与 call-timeout 类似，但在故障切换尝试期间使用调用时。默认值为 -1，这意味着禁用了超时。

   call-timeout

   当联合连接传输阻止调用的数据包时，以毫秒为单位等待来自远程代理的回复。如果这一次到期，连接会引发异常。默认值为 30000。

   check-period

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

   circuit-breaker-timeout

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

   connection-ttl

   如果联合连接停止从远程代理接收消息，则联合连接以毫秒为单位。默认值为 60000。

   discovery-group-ref

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

   ha

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

   initial-connect-attempts

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

   max-retry-interval

   当与远程代理连接失败时，后续重新连接尝试之间最长的时间（毫秒）。默认值为 2000。

   reconnect-attempts

   如果连接失败，下游代理将尝试重新连接到上游代理的次数。如果在没有重新建立连接的情况下达到这个值，上游代理会永久离线。下游代理不再将消息路由到上游代理。默认值为 -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"

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

   connector name="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、Broker B 和 BrokerC ）组成的链，位于 BrokerA 的生产者和 BrokerC。在这种情况下，您需要 BrokerB 将 消费者更新为 BrokerA。

   priority-adjustment

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

   transformer-ref

   转换器配置的名称。如果要在联合消息传输过程中转换消息，您可以添加转换器配置。此流程稍后将介绍转换器配置。

4. 在 <queue-policy> 元素中，添加 address-matching 模式，以从队列策略中包含和排除地址。例如：

   <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 属性匹配 的任何 队列。在这种情况下，任何以 string .local 结尾的队列都将被排除。这表示特定队列保留为本地队列，而不是联合。

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

   <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 策略的 converter-ref 属性的值。

   class-name

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

   转换器的 transformation （） 方法通过消息调用，然后再传输消息。这可让您在联合之前转换邮件标题或正文。

   属性

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

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 and eu-west-1 的上游代理对应。

   user

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

   password

   创建与上游代理连接时使用的密码。如果没有指定，则使用在联合 元素 配置中指定的共享密码。

   call-failover-timeout

   与 call-timeout 类似，但在故障切换尝试期间使用调用时。默认值为 -1，这意味着禁用了超时。

   call-timeout

   当联合连接传输阻止调用的数据包时，以毫秒为单位等待来自远程代理的回复。如果这一次到期，连接会引发异常。默认值为 30000。

   check-period

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

   circuit-breaker-timeout

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

   connection-ttl

   如果联合连接停止从远程代理接收消息，则联合连接以毫秒为单位。默认值为 60000。

   discovery-group-ref

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

   ha

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

   initial-connect-attempts

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

   max-retry-interval

   当与远程代理连接失败时，后续重新连接尝试之间最长的时间（毫秒）。默认值为 2000。

   reconnect-attempts

   如果连接失败，下游代理将尝试重新连接到上游代理的次数。如果在没有重新建立连接的情况下达到这个值，上游代理会永久离线。下游代理不再将消息路由到上游代理。默认值为 -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 配置的接收器，添加 require ClientAuth 密钥。将值设为 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)或 off(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

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

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

      身份验证

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

      userBase

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

      userSearchMatching

      指定 LDAP 搜索过滤器，应用到 userBase 选择的子树。如需更多信息，请参阅以下 第 5.4.1.1 节 “搜索匹配参数” 部分。

      userSearchSubtree

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

      userRoleName

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

      readTimeout

      指定代理可以等待从目录服务器接收到 LDAP 请求的最大时间（以毫秒为单位）。如果代理没有收到来自目录服务器的响应，代理会中止请求。如果您指定的值为零或以下值，或者您没有指定值，代理会无限期地等待从目录服务器响应到 LDAP 请求。

      roleBase

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

      roleName

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

      roleSearchMatching

      指定 LDAP 搜索过滤器，应用到 roleBase 选择的子树。如需更多信息，请参阅以下 第 5.4.1.1 节 “搜索匹配参数” 部分。

      roleSearchSubtree

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

      注意

      Apache DS 使用 DN 路径的 OID 部分。Microsoft Active Directory 使用 CN 部分。例如，您可以在 Apache DS 中使用 DN 路径，如 as 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. 在命令提示符后，使用 掩码 程序加密密码：

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

   result: 3a34fd21b82bf2a822fa49a8d8fa115d

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

   connectionPassword = <password>

3. 将纯文本密码替换为加密值：

   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 由 Oracle 和 OpenJDK 版本的 JDK 提供。通过参考来自 Java 供应商的文档，验证 Krb5LoginModule 的完全限定类名称及其可用选项。

   useKeyTab

   在验证主体时，Krb5LoginModule 配置为使用 Kerberos keytab。keytab 使用来自 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. 在 security-manager 元素中，为 class-name 属性指定类，该类是用户定义的 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. 在命令提示符后，使用 掩码 程序加密密码：

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

   result: 3a34fd21b82bf2a822fa49a8d8fa115d

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

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

3. 将纯文本密码替换为加密值：

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

4. 使用标识符 ENC（） 包装加密的值：

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

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

   默认情况下，代理配置为使用基于日志的持久性，如下所示。

   <configuration>
     <core>
       ...
       <persistence-enabled>true</persistence-enabled>
       <journal-type>ASYNCIO</journal-type>
       <bindings-directory>./data/bindings</bindings-directory>
       <journal-directory>./data/journal</journal-directory>
       <journal-datasync>true</journal-datasync>
       <journal-min-files>2</journal-min-files>
       <journal-pool-files>-1</journal-pool-files>
       <journal-device-block-size>4096</journal-device-block-size>
       <journal-file-size>10M</journal-file-size>
       <journal-buffer-timeout>12000</journal-buffer-timeout>
       <journal-max-io>4096</journal-max-io>
       ...
     </core>
   </configuration>

   启用持久性

   如果此参数的值设为 true，代理将使用基于文件的日志实现消息持久性。

   journal-type

   要使用的日志类型。如果设置为 ASYNCIO，代理首先会尝试使用 AIO。如果没有找到 AIO，代理将使用 NIO。

   bindings-directory

   绑定日志的文件系统位置。默认值为相对于 <broker_instance_dir> 目录。

   journal-directory

   消息日志的文件系统位置。默认值为相对于 <broker_instance_dir> 目录。

   journal-datasync

   如果此参数的值设为 true，代理将使用 fdatasync 功能确认磁盘写入。

   journal-min-files

   在代理启动时最初创建的日志文件数。

   journal-pool-files

   回收未使用的文件后要保留的文件数.默认值 -1 表示在清理过程中不会删除任何文件。

   journal-device-block-size

   存储设备上日志所使用的数据块的最大大小，以字节为单位。默认值为 4096 字节。

   journal-file-size

   指定日志目录中各个日志文件的最大大小，以字节为单位。达到此限制时，代理会启动新文件。此参数还支持字节表示法（如 K、M、G）或二进制等效（Ki、Mi、Gi）。如果您的配置中没有明确指定此参数，则默认值为 10485760 字节(10MiB)。

   journal-buffer-timeout

   指定代理刷新日志缓冲区的频率，以纳秒为单位。AIO 通常使用高于 NIO 的清空率，因此代理为 NIO 和 AIO 维护不同的默认值。如果您的配置中没有明确指定此参数，则 NIO 的默认值为 3333 纳秒（即每秒 300 倍）。AIO 的默认值为 50000 纳秒（即，每秒为 2000 倍）。

   journal-max-io

   任意时间上 IO 队列中的最大写入请求数。如果队列已满，代理会阻止进一步写入，直到可用空间为止。

   如果您使用 NIO，这个值应该始终为 1。如果您使用的是 AIO，且此参数未在配置中明确指定，则默认值为 500。

2. 根据上述描述，根据需要调整您的存储设备的持久性配置。

流程

1. 在 Linux 上，若要管理磁盘写入缓存设置，请使用 tools hdparm （用于 IDE 磁盘）或 sdparm 或 sginfo （用于 SDSI/SATA 磁盘）。
2. 在 Windows 上，要管理磁盘写入器缓存设置，请右键单击磁盘。选择 属性.

流程

1. 将适当的 JDBC 客户端库添加到代理运行时。为此，请将相关 .jar 文件添加到 <broker_instance_dir>/lib 目录中。
2. 打开 <broker_instance_dir>/etc/broker.xml 配置文件。

3. 在 core 元素中，添加一个 包含 数据库存储元素的 storage 元素。

   <configuration>
     <core>
       <store>
          <database-store>
          </database-store>
       </store>
     </core>
   </configuration>

4. 在 database-store 元素中，添加 JDBC 持久性的配置参数并指定值。例如：

   <configuration>
     <core>
       <store>
          <database-store>
             <jdbc-connection-url>jdbc:oracle:data/oracle/database-store;create=true</jdbc-connection-url>
             <jdbc-user>ENC(5493dd76567ee5ec269d11823973462f)</jdbc-user>
             <jdbc-password>ENC(56a0db3b71043054269d11823973462f)</jdbc-password>
             <bindings-table-name>BINDINGS_TABLE</bindings-table-name>
             <message-table-name>MESSAGE_TABLE</message-table-name>
             <large-message-table-name>LARGE_MESSAGES_TABLE</large-message-table-name>
             <page-store-table-name>PAGE_STORE_TABLE</page-store-table-name>
             <node-manager-store-table-name>NODE_MANAGER_TABLE</node-manager-store-table-name>
             <jdbc-driver-class-name>oracle.jdbc.driver.OracleDriver</jdbc-driver-class-name>
             <jdbc-network-timeout>10000</jdbc-network-timeout>
             <jdbc-lock-renew-period>2000</jdbc-lock-renew-period>
             <jdbc-lock-expiration>20000</jdbc-lock-expiration>
             <jdbc-journal-sync-period>5</jdbc-journal-sync-period>
          </database-store>
       </store>
     </core>
   </configuration>

   jdbc-connection-url

   数据库服务器的完整 JDBC 连接 URL。连接 URL 应当包含所有配置参数和数据库名称。

   jdbc-user

   您的数据库服务器的加密用户名。有关加密配置文件中使用的用户名和密码的详情请参考 第 5.9 节 “加密配置文件中的密码”。

   jdbc-password

   加密您的数据库服务器密码。有关加密配置文件中使用的用户名和密码的详情请参考 第 5.9 节 “加密配置文件中的密码”。

   bindings-table-name

   存储绑定数据的表的名称。指定表名称可让您在多个服务器之间共享一个数据库，而无需干扰。

   message-table-name

   存储消息数据的表的名称。指定此表名称可让您在多个服务器之间共享一个数据库，而无需干扰。

   large-message-table-name

   保留大量消息和相关数据的表名称。此外，如果客户端以区块形式流传输大型消息，块将存储在这个表中。指定此表名称可让您在多个服务器之间共享一个数据库，而无需干扰。

   page-store-table-name

   存储目录信息的表的名称。指定此表名称可让您在多个服务器之间共享一个数据库，而无需干扰。

   node-manager-store-table-name

   用于实时和备份代理的共享存储高可用性(HA)锁定及其他 HA 相关数据的表名称。指定此表名称可让您在多个服务器之间共享一个数据库，而无需干扰。使用共享存储 HA 的每个实时备份对必须使用相同的表名称。您不能在多个（不相关的）实时备份对间共享相同的表。

   jdbc-driver-class-name

   JDBC 数据库驱动程序的完全限定类名称。有关支持的数据库的详情，请查看红帽客户门户网站 中的 Red Hat AMQ 7 支持的配置。

   jdbc-network-timeout

   JDBC 网络连接超时，以毫秒为单位.默认值为 20000 毫秒。将 JDBC 用于共享存储 HA 时，建议将超时设为小于或等于 jdbc-lock-expiration 的值。

   jdbc-lock-renew-period

   当前 JDBC 锁定的续订期的时长，以毫秒为单位。当这次调整后，代理可以续订锁定。建议设置比 jdbc-lock-expiration 值小几个倍的值。这为代理提供了足够时间来扩展租期，并给予代理时间尝试在发生连接问题时续订锁定。默认值为 2000 毫秒。

   jdbc-lock-expiration

   以毫秒为单位计算当前 JDBC 锁定的时间（即获取或续订），即使 jdbc-lock-renew-period 的值已经过期。

   代理定期尝试根据 jdbc-lock-renew-period 的值续订它拥有的锁定。如果代理 无法 续订锁定（例如，因为连接问题），代理会一直尝试续订锁定，直到自锁定上次成功获取或更新后通过 jdbc-lock-expiration 的值。

   上述续订行为的例外是，当另一个代理获取锁定时。如果数据库管理系统(DBMS)和代理之间出现时间偏差，或者垃圾回收需要长时间暂停，则可能会发生这种情况。在这种情况下，最初拥有锁定的代理会认为锁定丢失，且不会尝试更新锁定。

   在过期时间过后，如果 JDBC 锁定没有被当前拥有的代理续订，则另一个代理可以建立 JDBC 锁定。

   jdbc-lock-expiration 的默认值为 20000 毫秒。

   jdbc-journal-sync-period

   代理日志与 JDBC 同步的持续时间，以毫秒为单位。默认值为 5 毫秒。

流程

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

2. 在您之前为 JDBC 配置添加的 database-store 元素中，删除 jdbc-driver-class-name, jdbc-connection-url, jdbc-user, jdbc-password, 参数。在此过程稍后，您将用对应的 DBCP 配置参数替换它们。

   注意

   如果您没有显式删除前面的参数，则优先选择您在此流程中添加的对应的 DBCP 参数。

3. 在 database-store 元素内，添加 data-source-properties 元素。例如：

   <store>
       <database-store>
           <data-source-properties>
           </data-source-properties>
           <bindings-table-name>BINDINGS</bindings-table-name>
           <message-table-name>MESSAGES</message-table-name>
           <large-message-table-name>LARGE_MESSAGES</large-message-table-name>
           <page-store-table-name>PAGE_STORE</page-store-table-name>
           <node-manager-store-table-name>NODE_MANAGER_STORE</node-manager-store-table-name>
           <jdbc-network-timeout>10000</jdbc-network-timeout>
           <jdbc-lock-renew-period>2000</jdbc-lock-renew-period>
           <jdbc-lock-expiration>20000</jdbc-lock-expiration>
           <jdbc-journal-sync-period>5</jdbc-journal-sync-period>
       </database-store>
   </store>

4. 在新的 data-source-properties 元素内，为连接池添加 DBCP 数据源属性。指定键值对。例如：

   <store>
       <database-store>
           <data-source-properties>
               <data-source-property key="driverClassName" value="com.mysql.jdbc.Driver" />
               <data-source-property key="url" value="jdbc:mysql://localhost:3306/artemis" />
               <data-source-property key="username" value="ENC(5493dd76567ee5ec269d1182397346f)"/>
               <data-source-property key="password" value="ENC(56a0db3b71043054269d1182397346f)"/>
               <data-source-property key="poolPreparedStatements" value="true" />
               <data-source-property key="maxTotal" value="-1" />
           </data-source-properties>
           <bindings-table-name>BINDINGS</bindings-table-name>
           <message-table-name>MESSAGES</message-table-name>
           <large-message-table-name>LARGE_MESSAGES</large-message-table-name>
           <page-store-table-name>PAGE_STORE</page-store-table-name>
           <node-manager-store-table-name>NODE_MANAGER_STORE</node-manager-store-table-name>
           <jdbc-network-timeout>10000</jdbc-network-timeout>
           <jdbc-lock-renew-period>2000</jdbc-lock-renew-period>
           <jdbc-lock-expiration>20000</jdbc-lock-expiration>
           <jdbc-journal-sync-period>5</jdbc-journal-sync-period>
       </database-store>
   </store>

   driverClassName

   JDBC 数据库驱动程序的完全限定类名称。

   url

   数据库服务器的完整 JDBC 连接 URL。

   username

   您的数据库服务器的加密用户名。您还可以将此值指定为未加密的纯文本。有关加密配置文件中使用的用户名和密码的详情请参考 第 5.9 节 “加密配置文件中的密码”。

   password

   加密您的数据库服务器密码。您还可以将此值指定为未加密的纯文本。有关加密配置文件中使用的用户名和密码的详情请参考 第 5.9 节 “加密配置文件中的密码”。

   poolPreparedStatements

   当此参数的值设为 true 时，池可以具有无限数量的缓存就绪语句。这可降低初始化成本。

   maxTotal

   池中连接的最大数量。当此参数的值设为 -1 时，没有限制。

流程

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

2. 在 core 元素内，添加 分页目录 元素。指定文件系统中分页目录的位置。

   <configuration ...>
     <core ...>
       ...
       <paging-directory>/path/to/paging-directory</paging-directory>
       ...
     </core>
   </configuration>

   对于您随后为分页配置的每个地址，代理会在您指定的分页目录中添加一个专用目录。

流程

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

2. 对于您为匹配地址或地址 集 配置的 address-setting 元素，添加配置元素以指定最大内存使用量并定义分页行为。例如：

   <address-settings>
       <address-setting match="my.paged.address">
           ...
           <max-size-bytes>104857600</max-size-bytes>
           <page-size-bytes>10485760</page-size-bytes>
           <address-full-policy>PAGE</address-full-policy>
           ...
       </address-setting>
   </address-settings>

   max-size-bytes

   代理执行为 address-full-policy 指定策略之前，地址允许的最大内存大小，以字节为单位。默认值为 -1，这意味着没有限制。您指定的值还支持字节表示法，如 "K"、"MB" 和 "GB"。

   page-size-bytes

   分页系统中使用的每个页面文件的大小（以字节为单位）。默认值为 10485760 （即 10 MiB）。您指定的值还支持字节表示法，如 "K"、"MB" 和 "GB"。

   address-full-policy

   代理在达到地址最大值时执行的操作。默认值为 PAGE。有效值为：

   页面

   代理将进一步的信息传输到磁盘。

   DROP

   代理会静默丢弃任何进一步的信息。

   FAIL

   代理会向客户端消息制作者丢弃任何其他消息和问题。

   BLOCK

   当客户端消息制作者尝试发送更多消息时，它们会阻止它们。

   以上示例中 未显示 的其他分页配置元素如下所述。

   page-max-cache-size

   代理保留在内存中的页面文件数量，以便在分页导航期间优化 IO。默认值为 5。

   page-sync-timeout

   定期页面同步之间的时间（以纳秒为单位）。如果您使用异步 IO 日志（即 journal-type 在 broker.xml 配置文件中被设置为 ASYNCIO ），则默认值为 3333333。如果您使用标准 Java NIO 日志（即 journal-type 设置为 NIO），则默认值是 journal-buffer-timeout 参数的配置值。

流程

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. 在 core 元素中，添加 global-max-size 元素并指定一个值。例如：

   <configuration>
     <core>
       ...
       <global-max-size>1GB</global-max-size>
       ...
     </core>
   </configuration>

   global-max-size

   代理可用于所有地址的内存总量，以字节为单位。达到这个限制时，对于与传入消息关联的地址，代理会执行指定为 address-full-policy 值的策略。global-max-size 的默认值是托管代理的 Java 虚拟机(JVM)可用的最大内存的一半。

   global-max-size 的值以字节为单位，但也支持字节表示法（例如："K"、"Mb"、"GB"）。

   在前面的示例中，代理被配置为在处理消息时最多使用一千兆字节的可用内存。

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/broker.xml 配置文件。

3. 在 core 元素中添加 max-disk-usage 配置元素并指定一个值。例如：

   <configuration>
     <core>
       ...
       <max-disk-usage>50</max-disk-usage>
       ...
     </core>
   </configuration>

   max-disk-usage

   代理在分页消息时可使用的可用磁盘空间的最大百分比。达到这个限制时，代理会阻止传入的信息，而不是分页它们。默认值为 90。

   在前面的示例中，代理仅在分页消息时使用 50% 的磁盘空间。

4. 启动代理。

   1. 在 Linux 中：

      <broker_instance_dir>/bin/artemis run

   2. 在 Windows 中：

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

流程

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

2. 对于您已为匹配地址或地址 集 配置的 address-setting 元素，请添加配置元素来定义消息阻止行为。例如：

   <address-settings>
       <address-setting match="my.blocking.address">
           ...
           <max-size-bytes>300000</max-size-bytes>
           <address-full-policy>BLOCK</address-full-policy>
           ...
       </address-setting>
   </address-settings>

   max-size-bytes

   代理执行为 address-full-policy 指定策略之前，地址允许的最大内存大小，以字节为单位。您指定的值还支持字节表示法，如 "K"、"MB" 和 "GB"。

   注意

   如果在 address -setting 元素中指定了 max-size- bytes，则该值将应用到 每个 匹配地址。指定这个值 并不意味着 所有匹配地址 的总 大小都仅限于 max-size-bytes 的值。

   address-full-policy

   代理在达到地址最大值时执行的操作。

   在前面的示例中，当发送到地址 my.blocking.address 的消息超过 300000 字节时，代理开始阻止来自 Core 或 OpenWire 消息制作者进一步的消息。

流程

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

2. 对于您已为匹配地址或地址 集 配置的 address-setting 元素，请指定内存中所有 AMQP 消息的最大大小。例如：

   <address-settings>
       <address-setting match="my.amqp.blocking.address">
           ...
           <max-size-bytes-reject-threshold>300000</max-size-bytes-reject-threshold>
           ...
       </address-setting>
   </address-settings>

   max-size-bytes-reject-threshold

   代理在进一步阻止 AMQP 消息前，地址允许的最大内存大小，以字节为单位。您指定的值还支持字节表示法，如 "K"、"MB" 和 "GB"。默认情况下，max-size-bytes-reject-threshold 设置为 -1，这意味着没有最大大小。

   注意

   如果在 address -setting 元素中指定了 max-size-bytes-reject- threshold，则该值将应用到 每个 匹配地址。指定这个值 并不意味着 所有匹配地址 的总 大小都仅限于 max-size-bytes-reject-threshold 的值。