使用AMQP和RabbitMQ的Spring,使用可选的x-dead-letter-exchange排队

Question

我在RabbitMQ中创建了一个现有队列.它可以使用或不使用x-dead-letter-exchange参数创建.我正在使用RabbitTemplate在Spring中创建此队列的使用者.当我声明队列时,我不想指定x-dead-letter-exchange参数.我希望模板以某种方式表现出来或不关心.我AmqpRejectAndDontRequeueException从我的消费者那里抛出来指示不良消息,但是我希望队列的创建者负责决定是否为被拒绝的消息创建交换和队列.

这是我在bean中声明队列的bean:

@Bean
Queue queue() {
    Map<String, Object> args = new HashMap<>();
    // set the queue with a dead letter feature
    args.put("x-dead-letter-exchange", REJECTED_EXCHANGE);
    args.put("x-dead-letter-routing-key", REJECTED_ROUTING_KEY);
    Queue queue = new Queue(Constants.QUEUE_NAME, false, false, false, args);
    return queue;
}

这工作正常,但当队列的创建者决定不使用死信功能时,我看到以下错误:

Channel shutdown: channel error; protocol method: #method<channel.close>
(reply-code=406, reply-text=PRECONDITION_FAILED - 
inequivalent arg 'x-dead-letter-exchange' for queue 'queueName'

消息有点长,它继续告诉我哪一方有哪些x-dead-letter-exchange(没有或交换的名称).我尝试了不同的组合(例如,创建具有交换的队列,而不是在Spring中指定它,或者在没有交换的情况下创建队列并在Spring中指定它),只是为了看到此消息的不同变体.

如何声明队列以便它只接受队列中已设置的任何参数？

Answer 1

是的，可能的原因是 - 如果您手动声明一些队列，然后您的程序（代码中的客户端）尝试创建一个（基于您在代码中的设置），那么您会收到此错误。其背后的原因是当您的代码（客户端应用程序）尝试访问一个队列时。它从服务器获得一个信号，表明该连接不可用。

为了解决这个问题

• 删除您手动创建的所有队列，并让客户端程序自行创建它们。
• 如果你在删除队列时遇到问题，因为里面有一些数据，或者出于某种原因，你想维护它，手动创建一个队列，并通过“移动”选项卡将所有要删除的队列数据移动到其中队列的。

Answer 2

正如您在spring 文档: 中看到的那样The RabbitMQ broker will not allow declaration of a queue with mismatched arguments.，所以您不能这样做。
在 RabbitMQ Java API 中，有一种方法可以检查队列是否已经存在：queueDeclarePassive.

如果 Spring AMQP API 提供了类似的功能，您可以在尝试声明队列之前使用它。