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>
         ...

   Copy to Clipboard Toggle word wrap

   根据前面的配置，代理每 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 ...>

   Copy to Clipboard Toggle word wrap

   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 ...>

   Copy to Clipboard Toggle word wrap

   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>

   Copy to Clipboard Toggle word wrap

   前面的示例配置将到期队列 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 ...>

   Copy to Clipboard Toggle word wrap

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 ...>

   Copy to Clipboard Toggle word wrap

   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

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