4.11. 配置最后的值队列


最后的值 queue 是队列类型,当将具有相同最后一个值键值的更新消息放在队列中时,丢弃队列中的消息。通过此行为,最后一个值队列只保留同一键消息的最后一个值。

最后的值队列的一个简单用例是监控库存价格,其中只有特定库存的最新值是值得关注的。

注意

如果消息没有配置的最后一个值键发送到最后一个值队列,代理会将这个消息作为 "normal" 消息处理。当带有配置的最后值键的新消息到达时,此类消息不会从队列清除。

您可以单独配置最后的值队列,或针对与一组地址关联的所有队列。

以下流程演示了如何以这些方式配置最后一个值队列。

4.11.1. 单独配置最后的值队列

以下流程显示单独配置最后一个值队列。

  1. 打开 & lt;broker_instance_dir> /etc/broker.xml 配置文件。
  2. 对于给定队列,添加 last-value-key 键并指定自定义值。例如:

    <address name="my.address">
        <multicast>
            <queue name="prices1" last-value-key="stock_ticker"/>
        </multicast>
    </address>
  3. 或者,您可以配置使用默认值最后一个值键键 _AMQ_LVQ_NAME 的最后值队列。为此,请将 last-value 键添加到给定队列中。将值设为 true。例如:

    <address name="my.address">
        <multicast>
            <queue name="prices1" last-value="true"/>
        </multicast>
    </address>

4.11.2. 为地址配置最后的值队列

以下流程演示了如何为地址 或一组 地址配置最后一个值队列。

  1. 打开 & lt;broker_instance_dir&gt; /etc/broker.xml 配置文件。
  2. 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 的值。

  3. 要为 一组 地址配置最后的值队列,您可以指定一个地址通配符。例如:

    <address-setting match="lastValue.*">
       <default-last-value-key>stock_ticker</default-last-value-key>
    </address-setting>
  4. 或者,您可以配置与一个地址 或一组 地址关联的所有队列,以使用默认的最后一个值键名称 _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.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. 为最后一个值队列强制使用非破坏性消耗

当消费者连接到队列时,通常的行为是发送到该消费者的消息仅由消费者获取。当消费者确认收到消息时,代理会从队列中删除消息。

作为正常消耗的替代选择,您可以将队列配置为强制实施 非破坏性 消耗。在这种情况下,当队列向消费者发送消息时,其他消费者仍然可以接收消息。此外,即使消费者使用了它,该消息仍然保留在队列中。当您强制实施这种非破坏性消耗行为时,消费者称为队列 浏览器

强制非破坏性消耗是最后一个值队列的有用配置,因为它确保队列始终包含特定最后一个值键的最新值。

以下流程演示了如何为最后一个值队列强制使用非破坏性。

先决条件

流程

  1. 打开 & lt;broker_instance_dir&gt; /etc/broker.xml 配置文件。
  2. 如果您之前单独将队列配置为最后一个值队列,请添加 非破坏性 键。将值设为 true。例如:

    <address name="my.address">
       <multicast>
          <queue name="orders1" last-value-key="stock_ticker" non-destructive="true" />
       </multicast>
    </address>
  3. 如果您之前为最后一个值队列配置了地址 或一组 地址,请添加 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

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.