4.12. 将过期的消息移到过期地址

流程

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 （即 disabled）。

5. 在配置文件的 addresses 元素中，配置之前为 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 路由类型。默认情况下，代理将到期队列命名为 expiry 队列，以匹配最初发送过期消息的地址，如 库存。

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

   expiry-queue-prefix

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

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

   expiry-queue-suffix

   代理应用到自动创建的过期队列的后缀。默认值没有被定义（即，代理不会应用后缀）。