4.11. 配置最后的值队列
最后一个值队列 是队列类型,当将具有相同值值的新消息放入队列中时,丢弃队列中的消息。通过此行为,最后一个值队列只保留同一键的信息的最后值。
最后一个值队列的一个简单用例是监控库存费用,只有特定库存的最新价值就是值得关注。
如果没有配置的最后值键的消息发送到最后一个值队列,则代理会将此消息作为"常规"消息处理。当有配置的最后值键到达的新消息时,这些消息不会从队列清除。
您可以单独配置最后一个值队列,或者配置与一组地址关联的所有队列。
以下流程演示了如何使用以下方法配置最后一个值队列。
4.11.1. 单独配置最后一个值队列
以下流程演示了如何单独配置最后一个值队列。
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 对于给定队列,添加
last-value-key
键并指定自定义值。例如:<address name="my.address"> <multicast> <queue name="prices1" last-value-key="stock_ticker"/> </multicast> </address>
另外,您可以配置最后一个值队列,该队列使用默认值
_AMQ_LVQ_NAME
。为此,请将last-value
键添加到给定队列。将值设为true
。例如:<address name="my.address"> <multicast> <queue name="prices1" last-value="true"/> </multicast> </address>
4.11.2. 为地址配置最后一个值队列
以下流程演示了如何为地址 或一组 地址配置最后一个值队列。
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 在
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
的值。要为 一组 地址配置最后的值队列,您可以指定地址通配符。例如:
<address-setting match="lastValue.*"> <default-last-value-key>stock_ticker</default-last-value-key> </address-setting>
或者,您可以将所有与地址 或一组 地址关联的队列配置为使用默认值
_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>
其他资源
- 有关您可以在配置地址时使用的通配符语法的详情,请参考 第 4.2 节 “将地址设置应用到一组地址”。
4.11.3. 最后值队列行为示例
本例演示了最后一个值队列的行为。
在 broker.xml
配置文件中,假设您添加了以下配置:
<address name="my.address"> <multicast> <queue name="prices1" last-value-key="stock_ticker"/> </multicast> </address>
上述配置会创建一个名为 price 1
的队列,其值为 stock_ticker
的最后一个值。
现在,假设客户端会发送两条信息。每个消息在属性 stock_ticker
的 ATN
值相同。每个消息在名为 stock_price
的属性中具有不同的值。每个消息都发送到同一队列、价格1
。
TextMessage message = session.createTextMessage("First message with last value property set"); message.setStringProperty("stock_ticker", "ATN"); message.setStringProperty("stock_price", "36.83"); producer.send(message);
TextMessage message = session.createTextMessage("Second message with last value property set"); message.setStringProperty("stock_ticker", "ATN"); message.setStringProperty("stock_price", "37.02"); producer.send(message);
当 stock_ticker
最后一个值键的值相同(在此情况下为 ATN
)的两条消息到达 price1 队列时
,只有最新的消息保留在队列中,第一个被清除的消息。在命令行中输入以下行来验证此行为:
TextMessage messageReceived = (TextMessage)messageConsumer.receive(5000); System.out.format("Received message: %s\n", messageReceived.getText());
在本例中,您看到的是第二条消息,因为这两个消息对最后一个值键使用相同的值,并在第一个信息之后在队列中收到第二个消息。
4.11.4. 为最后一个值队列强制使用非破坏性
当消费者连接到队列时,通常的行为是发送到该消费者的消息仅由消费者获取。当消费者确认消息收到时,代理会从队列中删除消息。
作为正常消耗的替代选择,您可以将队列配置为强制实施 非破坏性 的消耗。在这种情况下,当队列向消费者发送消息时,其他消费者仍然可以接收该消息。此外,即使消费者使用过它,消息也会保留在队列中。当您强制实施这种非破坏性消耗行为时,消费者被称为队列 浏览器。
强制使用非破坏性是最后一个值队列的一个非常有用的配置,因为它可确保队列始终保留一个特定最后一个值值的最新值。
以下流程演示了如何为最后一个值队列强制实施非破坏性消耗。
先决条件
您已逐一配置了 last-value 队列,或者已针对与某个地址 或一组 地址关联的所有队列。如需更多信息,请参阅:
流程
-
打开 &
lt;broker_instance_dir> /etc/broker.xml
配置文件。 如果您之前将队列单独配置为最后一个值队列,请添加
非破坏性
的密钥。将值设为true
。例如:<address name="my.address"> <multicast> <queue name="orders1" last-value-key="stock_ticker" non-destructive="true" /> </multicast> </address>
如果您之前为最后一个值队列配置了地址 或一组 地址,请添加
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-structive 的值为
false
。