配置 AMQ Broker

流程

1. 打开 & lt;broker_instance_dir>/etc/artemis.profile 文件。

2. 将新参数 -Dartemis.disableXxe 添加至 Java 系统参数的 JAVA_ARGS 列表中。

   -Dartemis.disableXxe=true

3. 保存 artemis.profile 文件。

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

流程

1. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。
2. 对于用于 STOMP 连接的 acceptor，将 stompEnableMessageId 参数设置为 true，如下例所示：

流程

1. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。
2. 将 connectionTTL 参数添加到用于 STOMP 连接的 acceptor 的 URI 中，如下例所示：

流程

1. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。
2. 添加 connection-ttl-override 属性，并为新的默认值提供一个毫秒的值。它属于 < core&gt; 小节，如下所示。

流程

1. 打开 & lt;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 的值提供的字符代表“匹配 0 个或更多个序列”，并将替换默认的 #。在您的表达式末尾使用此字符。

   single-word

   作为 single-word 的值提供的字符代表“匹配一个词”，并将替换默认的 *。在您的表达式中的任何位置使用此字符。

流程

1. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

2. 使用一个 address 所选的 queue 项环绕一个 anycast 配置项。确保 address 和 queue 元素的 name 属性的值相同。例如：

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

流程

1. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

2. 使用在 address 项中的 queue 项环绕一个 anycast 配置项。例如：

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

流程

1. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

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

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

   注意

   由于队列默认为 durable，因此包括 durable 元素并将值设为 true 并不是创建持久队列的严格要求。但是，显式包含元素可让您稍后将队列的行为改为不可写入的（如果需要）。

流程

1. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

2. 将 durable 配置元素添加到每个所选队列。设置 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，因此包括 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. 打开 & lt;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. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

2. 配置用于 自动创建和删除的地址设置。以下示例使用上表中提到的所有配置元素。

   <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. rhcs 匹配的任何地址或队列。

   auto-create-addresses

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

   auto-delete-addresses

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

   auto-create-queues

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

   auto-delete-queues

   当不再有任何消费者或消息时，自动创建的队列会被删除。

   default-address-routing-type

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

1. 打开 & lt;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. 打开 & lt;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 地址关联的所有队列都使用 final _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. 打开 & lt;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. 如果您之前为最后一个值队列配置了地址 或一组 地址，请添加 default-non-destructive 键。将值设为 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. 打开 & lt;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 值的消息，代理会将过期时间设置为 max-expiry-delay 的指定的值。
   • 对于在 min-expiry-delay 值低于过期时间的消息，代理会将过期时间设置为 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 （即禁用）。

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

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

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

流程

1. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

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

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

3. 在 & lt;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 &gt; 元素来定义到期地址和关联的过期队列。自动创建的 <address& gt; 元素的 name 值与为 <expiry-address> 指定的值匹配。

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

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

   expiry-queue-prefix

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

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

   expiry-queue-suffix

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

流程

1. 打开 & lt;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 ...>

   match

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

   dead-letter-address

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

   max-delivery-attempts

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

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

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

流程

1. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

2. 找到您之前添加的 &lt ;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，则代理会自动创建一个 & lt;address > 元素来定义死信地址和一个关联的死信队列。自动创建的 <address& gt; 元素的名称与您为 < dead-letter-address> 指定的值 匹配。

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

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

   dead-letter-queue-prefix

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

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

   dead-letter-queue-suffix

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

流程

1. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

2. 对于给定队列，添加 exclusive 键。将值设为 true。

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

1. 打开 & lt;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. 打开 & lt;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. 所有消息都会立即分配给消费者。

   At this point, messageCount= 3 and deliveringCount= 3.

3. 生产者向队列发送另一个消息。然后，消息会被分配给消费者。

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

4. 现在，假设消费者在不确认任何消息的情况下关闭。

   在这种情况下，四个 in-delivery，未确认的消息将取消回代理，并根据它们使用的相反顺序添加到队列的标头中。此操作会使队列置于其配置的环大小上。由于环队列首选通过头的消息在队列的尾部消息，因此队列丢弃生成者发送的第一个消息，因为这是最后一个消息，将添加回队列头。事务或核心会话回滚的方式相同。

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

   此时，messageCount= 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. 打开 & lt;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 元素中，添加一个 < 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 可让 disrt 绑定根据需要侦听。如果存在与地址策略包含的地址匹配的地址绑定，则任何与 divert 转发地址匹配的队列绑定都会满足需求。默认值为 false。

   max-hops

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

   transformer-ref

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

4. 在 &lt ;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 属性的值指定要包含在地址策略中的地址。您可以指定一个准确的地址，例如 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.myorg.NewsTransformer</class-name>
               <property key="key1" value="value1"/>
               <property key="key2" value="value2"/>
           </transformer>
   
       </federation>
   </federations>

   name

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

   class-name

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

   转换程序的 convert （） 方法在传输消息之前通过消息调用。这可让您在联邦前转换消息标头或正文。

   属性

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

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

   <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.myorg.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"消息之间，以毫秒为单位，以检查联邦连接的健康状态。如果联邦连接健康，远程代理会响应每个 keep-alive 信息。如果连接不健康，当下游代理无法从上游代理接收响应时，会使用一个名为 断路器 的机制阻止联邦用户。如需更多信息，请参阅 breaker-breaker-timeout 参数的描述。check-period 参数的默认值为 30000。

   circuit-breaker-timeout

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

   connection-ttl

   如果联邦连接停止从远程代理接收消息，则联邦连接会保持活动状态。默认值为 60000。

   discovery-group-ref

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

   ha

   指定是否为到上游代理的连接启用高可用性。如果此参数的值设为 true，则本地代理可以连接到上游集群中的任何可用代理，并在 live 上游代理关闭时自动切换到备份代理。默认值为 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. 在本地代理中，将连接器添加到远程代理中。这些是联邦地址配置的 static-connectors 元素中引用的连接器。例如：

   <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.myorg.NewsTransformer</class-name>
               <property key="key1" value="value1"/>
               <property key="key2" value="value2"/>
           </transformer>
   
       </federation>
     ...
   </federations>

5. 为每个远程代理添加 downstream 项。例如：

   <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>
                   <upstream-connector-ref>netty-connector</upstream-connector-ref>
                   <policy ref="news-address-federation"/>
           </downstream>
   
           <downstream name="eu-west-1" >
                   <static-connectors>
                       <connector-ref>eu-west-connector1</connector-ref>
                   </static-connectors>
                   <upstream-connector-ref>netty-connector</upstream-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.myorg.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"

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

流程

1. 打开 & lt;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& gt; 元素的属性指定值。例如：

   <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 和 BrokerC 的链，以及 BrokerA 的生成者以及 BrokerC 的消费者。在这种情况下，您将希望 BrokerB 重新联邦消费者到 BrokerA。

   priority-adjustment

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

流程

1. 打开 & lt;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.myorg.NewsTransformer</class-name>
               <property key="key1" value="value1"/>
               <property key="key2" value="value2"/>
           </transformer>
   
       </federation>
     ...
   </federations>

5. 为每个远程代理添加 downstream 项。例如：

   <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>
               <upstream-connector-ref>netty-connector</upstream-connector-ref>
               <policy ref="news-address-federation"/>
           </downstream>
   
           <downstream name="eu-west-1" >
               <static-connectors>
                   <connector-ref>eu-west-connector1</connector-ref>
               </static-connectors>
               <upstream-connector-ref>netty-connector</upstream-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.myorg.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"

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

1. 打开 & lt;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. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

2. 对于您之前为单向 TLS 配置的 acceptor，请添加 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. 打开 & lt;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. 打开 & lt;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

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

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

      身份验证

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

      userBase

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

      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、roleSearchMatching、roleSearchSubtree、roleName和 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 路径，如 oid=testuser,dc=example,dc=com，而您可以在 Microsoft Active Directory 中使用 DN 路径，如 cn=testuser,dc=example,dc=com。

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

流程

1. 打开 & lt;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. 打开 & lt;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. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

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

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

   前面的配置意味着 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. 打开 & lt;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 acceptor 凭证。

   Krb5LoginModule

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

   useKeyTab

   Krb5LoginModule 配置为在验证主体时使用 Kerberos keytab。keytab 使用 Kerberos 环境中的工具生成。有关生成 Kerberos keytab 的详细信息，请参阅厂商中的文档。

   主体

   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. 打开 & lt;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. 打开 & lt;broker_instance_dir> /etc/boostrap.xml 配置文件。

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

   <broker xmlns="http://activemq.org/schema">
      ...
      <security-manager class-name="com.myclass.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. 打开 & lt;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. 使用 mask 实用程序加密配置文件中的每个密码。对于 key 参数，指定用于加密密码的字符串。使用相同的密钥字符串来加密每个密码。

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

   警告

   确保您保留在运行 mask 实用程序以加密密码时指定的密钥字符串记录。您必须在环境变量中配置相同的键值，以允许代理解密密码。

   有关在配置文件中加密密码的详情，请参考 第 5.9.2 节 “在配置文件中加密密码”。

2. 在命令提示符中，将 ARTEMIS_DEFAULT_SENSITIVE_STRING_CODEC_KEY 环境变量设置为您在加密每个密码时指定的密钥字符串。

   $ export ARTEMIS_DEFAULT_SENSITIVE_STRING_CODEC_KEY= <key>

3. 启动代理。

   $ ./artemis run

4. 取消设置 ARTEMIS_DEFAULT_SENSITIVE_STRING_CODEC_KEY 环境变量。

   $ unset ARTEMIS_DEFAULT_SENSITIVE_STRING_CODEC_KEY

   注意

   如果在启动代理后取消设置 ARTEMIS_DEFAULT_SENSITIVE_STRING_CODEC_KEY 环境变量，您必须在每次后续时间启动代理前再次将其设置为相同的密钥字符串。

1. 打开 & lt;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 的默认值是 3333333 纳秒（每秒 300 次）。AIO 的默认值为 50000 纳秒（即每秒 2000 次）。

   journal-max-io

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

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

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

流程

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

流程

1. 将适当的 JDBC 客户端库添加到代理运行时。要做到这一点，将相关的 .jar 文件添加到 < broker_instance_dir>/lib 目录中。
2. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

3. 在 core 元素中，添加一个包含 database-store 元素的 store 元素。

   <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>BIND_TABLE</bindings-table-name>
             <message-table-name>MSG_TABLE</message-table-name>
             <large-message-table-name>LGE_TABLE</large-message-table-name>
             <page-store-table-name>PAGE_TABLE</page-store-table-name>
             <node-manager-store-table-name>NODE_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>
             <jdbc-max-page-size-bytes>100K</jdbc-max-page-size-bytes>
          </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 毫秒。

   jdbc-max-page-size-bytes

   当 AMQ Broker 将消息保留到 JDBC 数据库时，每个页文件的最大大小（以字节为单位）。默认值为 102400，其值为 100KB。您指定的值也支持字节表示法，如 "K" "MB" 和 "GB"。

流程

1. 打开 & lt;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. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

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

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

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

流程

1. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

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

   <address-settings>
       <address-setting match="my.paged.address">
           ...
           <max-size-bytes>104857600</max-size-bytes>
           <max-size-messages>20000</max-size-messages>
           <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"。

   max-size-messages

   代理在为 address-full-policy 属性指定的操作前允许地址的最大消息数。默认值为 -1，这意味着没有消息限制。

   page-size-bytes

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

   address-full-policy

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

   页面

   代理将任何其他信息记录到磁盘。

   DROP

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

   FAIL

   代理丢弃任何进一步的信息，并给客户端消息制作者发出异常。

   BLOCK

   客户端消息制作者在尝试发送进一步消息时阻止。

   如果您为 max-size-bytes 和 max-size-message 属性设置了限制，代理会在达到任何一个限制时执行为 address-full-policy 属性指定的操作。在上例中，当内存中地址的总消息超过 20,000 或使用 104857600 字节时，代理会启动 my.paged.address 地址的分页消息。

   下面介绍了上例中 没有显示 的其他分页配置元素。

   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. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

3. 在 core 元素中，添加 global-max-size 元素并指定一个值。例如：

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

   global-max-size

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

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

   在前面的示例中，代理配置为在处理消息时使用最多 1GB 可用内存。

   global-max-messages

   允许所有地址的消息总数。当达到这个限制时，代理会为与每个传入消息关联的地址执行为 address-full-policy 属性指定的操作。默认值为 -1，这意味着没有消息限制。

   如果您为 global-max-size 和 global-max-messages 属性设置了限制，代理会在达到任何一个限制时执行为 address-full-policy 属性指定的操作。使用上例中的配置，代理会在内存中消息数量超过 900,000 或使用 1 GB 可用内存时启动分页消息。

   注意

   如果为单个地址设置的限制（使用 max-size-bytes 或 max-size-message 属性），则在为 global-max-size 或 global-max-messages 属性设置的限制之前，代理将执行为该地址的 address-full-policy 属性指定的操作。

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. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

3. 在 core 元素中，添加属性来根据磁盘使用情况或消息数量指定分页限制，并在达到任何限制时指定要执行的操作。例如：

   <address-settings>
      <address-setting match="match="my.paged.address"">
       ...
       <page-limit-bytes>10G</page-limit-bytes>
       <page-limit-messages>1000000</page-limit-messages>
       <page-full-policy>FAIL</page-full-policy>
       ...
      </address-setting>
   </address-settings>

   page-limit-bytes

   在代理执行 page-full-policy 属性指定的操作前，允许为地址分页传入的消息的最大大小（以字节为单位）。您指定的值支持字节表示法，如 "K"、"MB" 和 "GB"。默认值为 -1，这意味着没有限制。

   page-limit-messages

   在代理执行为 page-full-policy 属性指定的操作前，地址的最大传入消息数。默认值为 -1，这意味着没有消息限制。

   page-full-policy

   代理在 page-limit-bytes 或 page-limit-messages 属性中设置的限制为地址达到时执行的操作。有效值为：

   DROP The broker 静默丢弃任何进一步的信息。

   FAIL the broker 会丢弃任何进一步的信息并通知发送的客户端

   在上例中，代理页面会为 my.paged.address 地址分页信息，直到使用了 10 GB 的磁盘空间或直到所有 100万条消息都被被分页为止。

4. 启动代理。

   1. 对于 Linux：

      <broker_instance_dir>/bin/artemis run

   2. 对于 Windows：

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

流程

1. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。
2. 对于您为匹配地址或一组地址配置的 address-settings 元素，请指定将页消息传送到内存中的限制。例如：

流程

1. 停止代理。

   1. 对于 Linux：

      <broker_instance_dir>/bin/artemis stop

   2. 对于 Windows：

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

2. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。

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

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

   max-disk-usage

   代理可以使用的可用磁盘空间的最大百分比。当达到这个限制时，代理会阻止传入的信息。默认值为 90。

   在上例中，代理限制为使用百分之八十的可用磁盘空间。

4. 启动代理。

   1. 对于 Linux：

      <broker_instance_dir>/bin/artemis run

   2. 对于 Windows：

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

流程

1. 打开 & lt;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. 打开 & lt;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 的值。