4.11. 配置最后的值队列


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

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

注意

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

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

以下流程演示了如何使用以下方法配置最后一个值队列。

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 地址关联的所有队列都使用 stock_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>

上述配置会创建一个名为 price 1 的队列,其值为 stock_ticker 的最后一个值。

现在,假设客户端会发送两条信息。每个消息在属性 stock_tickerATN 值相同。每个消息在名为 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. 为最后一个值队列强制使用非破坏性

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

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

强制使用非破坏性是最后一个值队列的一个非常有用的配置,因为它可确保队列始终保留一个特定最后一个值值的最新值。

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

先决条件

流程

  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-structive 的值为 false

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

© 2024 Red Hat, Inc.