4.10. 配置分片队列
在队列中处理消息的常见模式,其中只需要部分排序才能使用 队列分片。这意味着您定义作为单个逻辑队列的任何广播地址,但由多个底层物理队列提供支持。
步骤
-
打开
<broker-instance-dir>/etc/broker.xml
配置文件。 添加
address
元素并设置name
属性。例如:<configuration ...> <core ...> ... <addresses> <address name="my.sharded.address"></address> </addresses> </core> </configuration>
添加任何
广播
路由类型,并包含所需的分片队列数量。在以下示例中,队列q1、
和q
2q3
会被添加为任何广播目的地。<configuration ...> <core ...> ... <addresses> <address name="my.sharded.address"> <anycast> <queue name="q1" /> <queue name="q2" /> <queue name="q3" /> </anycast> </address> </addresses> </core> </configuration>
根据上述配置,发送到 my.sharded.address
的消息在 q
1、q2
和 q3
之间均匀分布。在使用完全限定域名(FQQN)并将仅发送到该特定队列的消息时,客户端可以直接连接到特定的物理队列。
要将特定消息绑定到特定队列,客户端可以为每个消息指定消息组。代理将分组消息路由到同一队列,一个消费者处理它们。
其他资源
有关以下内容的更多信息:
- 全限定队列名称,请查看 第 4.9 节 “指定完全限定的队列名称”
- 消息分组,请参阅 第 11 章 消息组