4.11. 配置最后的值队列
最后的值 queue 是队列类型,当将具有相同最后一个值键值的更新消息放在队列中时,丢弃队列中的消息。通过此行为,最后一个值队列只保留同一键消息的最后一个值。
最后的值队列的一个简单用例是监控库存价格,其中只有特定库存的最新值是值得关注的。
如果消息没有配置的最后一个值键发送到最后一个值队列,代理会将这个消息作为 "normal" 消息处理。当带有配置的最后值键的新消息到达时,此类消息不会从队列清除。
您可以单独配置最后的值队列,或针对与一组地址关联的所有队列。
以下流程演示了如何以这些方式配置最后一个值队列。
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
地址关联的所有队列都使用 final_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>
前面的配置会创建一个名为 prices1
的队列,其最后一个值为 leader _ticker
。
现在,假设客户端发送两个消息。每个信息对于属性 stock_ticker
有相同的 ATN
值。每个消息都有一个不同的属性,名为 roll _price
。每个消息都发送到同一队列 prices1
。
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
)具有相同值的信息到达 prices1 queue
时,最有最后的信息会保留在队列中,第一个信息会被删除。在命令行中,您可以输入以下行来验证此行为:
TextMessage messageReceived = (TextMessage)messageConsumer.receive(5000); System.out.format("Received message: %s\n", messageReceived.getText());
在本例中,您看到的输出是第二个消息,因为两个消息都对最后一个值键和第二条消息都使用相同的值,第二个消息在队列中收到。
4.11.4. 为最后一个值队列强制使用非破坏性消耗
当消费者连接到队列时,通常的行为是发送到该消费者的消息仅由消费者获取。当消费者确认收到消息时,代理会从队列中删除消息。
作为正常消耗的替代选择,您可以将队列配置为强制实施 非破坏性 消耗。在这种情况下,当队列向消费者发送消息时,其他消费者仍然可以接收消息。此外,即使消费者使用了它,该消息仍然保留在队列中。当您强制实施这种非破坏性消耗行为时,消费者称为队列 浏览器。
强制非破坏性消耗是最后一个值队列的有用配置,因为它确保队列始终包含特定最后一个值键的最新值。
以下流程演示了如何为最后一个值队列强制使用非破坏性。
先决条件
您已单独配置了最后值队列,或针对与地址 或一组 地址关联的所有队列。如需更多信息,请参阅:
流程
-
打开 &
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-destructive
的值为false
。