4.12. 将过期的消息移到到期地址
对于最后一个值队列以外的队列,如果您只有一个非破坏性消费者,则代理永远不会从队列中删除消息,从而导致队列大小增加时间。要防止这种不约束的队列大小增长,您可以配置当消息过期时,并指定代理到达过期消息的地址。
4.12.1. 配置消息到期
以下流程演示了如何配置消息到期。
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 在
core
元素中,设置message-expiry-scan-period
以指定代理扫描过期信息的频率。<configuration ...> <core ...> ... <message-expiry-scan-period>1000</message-expiry-scan-period> ...
根据上述配置,代理每 1000 毫秒扫描过期的消息的队列。
在匹配地址 或一组 地址的
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
。
另外,您还可以为
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(
禁用)。
-
对于默认到期时间
在
配置文件的
address 元素中,配置之前为expiry-address
指定的地址。在此地址定义队列。例如:<addresses> ... <address name="ExpiryAddress"> <anycast> <queue name="ExpiryQueue"/> </anycast> </address> ... </addresses>
前面的示例配置将到期队列
ExpiryQueue
与到期地址ExpiryAddress
关联。
4.12.2. 自动创建到期资源
常见的用例是根据原始地址隔离过期的消息。例如,您可以选择将过期的消息从名为来自名为 stocks
的地址路由到一个名为 EXP.stocks
的过期队列。同样,您可以将过期的消息从名为 order
的地址路由到名为 EXP.orders
的过期队列。
这种路由模式有助于轻松跟踪、检查和管理过期的消息。但是,很难在主要使用自动创建的地址和队列的环境中实现这种模式。在这种环境中,管理员不希望额外的工作手动创建地址和队列来容纳过期的消息。
作为解决方案,您可以将代理配置为自动创建资源(即地址和队列)以处理给定地址 或一组 地址的过期消息。以下流程演示了示例。
先决条件
- 您已为给定地址 或一组 地址配置了到期地址。更多信息请参阅 第 4.12.1 节 “配置消息到期”。
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 找到您之前添加到配置文件的
<address-setting
> 元素,以定义匹配地址 或一组 地址的到期地址。例如:<configuration ...> <core ...> ... <address-settings> ... <address-setting match="stocks"> ... <expiry-address>ExpiryAddress</expiry-address> ... </address-setting> ... <address-settings> <configuration ...>
在
<address-setting
> 元素中,添加配置项来指示代理自动创建到期资源(即地址和队列),以及如何命名这些资源。例如:<configuration ...> <core ...> ... <address-settings> ... <address-setting match="stocks"> ... <expiry-address>ExpiryAddress</expiry-address> <auto-create-expiry-resources>true</auto-create-expiry-resources> <expiry-queue-prefix>EXP.</expiry-queue-prefix> <expiry-queue-suffix></expiry-queue-suffix> ... </address-setting> ... <address-settings> <configuration ...>
auto-create-expiry-resources
指定代理是否自动创建到期地址和队列来接收过期的消息。默认值为
false
。如果参数值设为
true
,代理会自动创建一个 <address>
; 元素来定义到期地址和关联的到期队列。自动创建的 <address>
元素的名称值与 指定的值<expiry-address>
匹配。自动创建的过期队列有
multicast
路由类型。默认情况下,代理为到期队列命名,以匹配最初发送过期消息的地址,如stocks
。代理还会为使用
_AMQ_ORIG_ADDRESS
属性的到期队列定义过滤器。此过滤器确保到期队列只接收发送到对应原始地址的消息。expiry-queue-prefix
代理应用到自动创建到期队列的名称前缀。默认值为
EXP。
当您定义前缀值或保留默认值时,到期队列的名称是前缀和原始地址的串联,如
EXP.stocks
。expiry-queue-suffix
- 代理应用于自动创建到期队列名称的后缀。默认值没有被定义(即代理不会应用后缀)。
您可以使用本身(例如,使用 AMQ Broker Core Protocol JMS 客户端)或使用完全限定的队列名称(例如,使用其他 JMS 客户端时)直接访问到期队列。
由于到期地址和队列是自动创建的,因此与删除自动创建的地址和队列相关的任何地址设置也适用于这些到期资源。
其他资源
- 有关配置自动删除自动创建的地址和队列的地址设置的更多信息,请参阅 第 4.8.2 节 “配置自动创建和删除地址和队列”。