在 ActiveMQ Artemis 中为每个消费者创建 DLQ

Question

我正在使用 JMS 消费来自 ActiveMQ Artemis 主题的消息。我的消费者直接连接到其消费者队列的 FQQN。像这样：

jmsTemplate.setDefaultDestinationName("Transactions.Client1::ConsumerA");

而 broker.xml 中的配置是：

<address-setting match="Transactions.*">
    <auto-create-dead-letter-resources>true</auto-create-dead-letter-resources>
    <dead-letter-address>Transactions.Retry</dead-letter-address>
</address-setting>

但是，DLQ 的名称将是 DLQ.Transactions.Client1，没有消费者名称。

我需要的是每个消费者都有自己的DLQ。类似DLQ.Transactions.Client1.ConsumerA。这可能吗？

编辑：

当我说“消费者”时，它可能（实际上）更像是“消费者群体”。例如，ConsumerA 和 ConsumerB 是两个完全不同的应用程序，（可能）具有多个运行实例并由自己的团队管理。这就是为什么我想要为每个人设置不同的 DLQ。

Answer 1

无法将代理配置为自动创建名称包含最初发送消息的队列名称的死信队列。如中所述文档中，死信队列根据最初发送消息的地址以及任何配置的前缀和/或后缀来命名。

但是，消息本身将有一个名为 _AMQ_ORIG_QUEUE 的属性，其中包含消息最初路由的队列的名称。这意味着您可以将消费者与消息选择器一起使用（例如_AMQ_ORIG_QUEUE = 'ConsumerA'），以便消费者将仅接收最初路由到特定队列的消息。这在功能上等同于每个队列都有一个死信队列。

无论如何，您所说的“消费者名称”根本不是消费者的名称，至少从经纪人的角度来看不是。这只是队列的名称。

最终，不可能为每个队列配置一个死信队列。只能为每个地址配置一个死信队列。无论资源是手动创建（例如通过broker.xml）还是自动创建，都是如此。

Answer 2

贾斯汀·伯特伦的回答可能是大多数人应该做的。如果不是每个消费者应用程序具有不同的死信地址和到期地址的要求，我就会这么做。

就我而言，我使用 Diverts 解决了这个问题。

首先，制片人没有改变。它不断向主题 Transactions.Client1 发帖。

然后，我在 broker.xml 文件中配置了一个转移：

<divert name="Transactions.Divert">
    <address>Transactions.Client1</address>
    <forwarding-address>Transactions.Client1.ConsumerA</forwarding-address>
    <exclusive>false</exclusive>
</divert>

重要：
缺点是它无法扩展。如果我有 N 个客户和 M 个消费者，我将有 N×M 个转移。

然后，地址设置更改为（注意 match 属性中的两个星号）：

<address-setting match="Transactions.*.*">
    <auto-create-dead-letter-resources>true</auto-create-dead-letter-resources>
    <dead-letter-address>Transactions.Retry</dead-letter-address>
</address-setting>

因此，当消息处理失败时，将在地址 Transactions.Retry 处创建一个名为 <代码>DLQ.Transactions.Client1.ConsumerA。

每个人都很高兴，除了运维人员，他必须在生产中配置一百多个转移。我希望他的 vim-fu 没事。

PS：提示：始终转移到具有相同前缀的地址（在示例中为“交易”）。当您必须在生产中配置集群时，这将使您的生活变得更加轻松。