我正在尝试设置第一个RabbitMQ死信交换机，以下是我通过Web管理界面使用的步骤：
我期望这些步骤应该通过“dead.letter.test”交换机将记录放入“dead.letter.queue”中。但实际上没有发生这种情况。
我可以手动将消息放入“dead.letter.test”交换机，并且它会显示在“dead.letter.queue”中，因此我知道这一点没问题。
当我查看管理UI时，它显示DLX参数已在队列“test1”上设置。
我做错了什么？
Gentilissimo Signore很好心地在Twitter上回答了我的问题。问题在于，如果您的死信交换设置为DIRECT，则必须指定死信路由键。如果您只是想让所有NACK的消息进入一个死信桶以供以后调查（就像我一样），则应将死信交换设置为FANOUT。
这里是更新后的可行步骤：
最后我们将进行检查。首先在'test_exchange'上发布一条带有'expiration'参数设置为10000的消息。当在'test_exchange'上发布消息时，该消息将进入'test_queue'，而当一个消息过期后，队列将搜索DLX参数（Dead Letter Exchange name），如果找到名称为'dead_exchange'的消息，则将该消息传递给'dead_exchange'并将其发送到'dead_queue'中.. 如果您仍有任何关于此的问题，请写下您的问题，我一定会查看它。谢谢。
注意：必须在'test_exchange'上发布消息，因为'test_queue'和'test_exchange'的绑定没有指定路由键，并且这将正常工作。但是，如果您在'default exchange'和'routing key'上发布消息，则该消息将不会到达目标队列，并且在消息过期后，队列会尝试使用默认的路由键将该死信消息传递到'dead_exchange'，但消息将无法到达该队列。
sahil.gulati1991@outlook.com。 - Sahil Gulatix-dead-letter-routing-key（在你的情况下是test1），否则将使用默认路由键。在你的情况下，RabbitMQ代理检测到循环并简单地丢弃被拒绝的消息。test1队列上设置x-dead-letter-exchange=dead.letter.test和x-dead-letter-routing-key=dead.letter.queue参数。如果不是必须的话，就不需要创建FANOUT交换机。
您可以使用与其他交换机已经使用的相同路由键创建DIRECT交换机。而且不需要为新交换机创建新队列。您可以使用现有队列来处理新交换机。您只需要将新交换机与队列绑定即可。
这是我的receive.js文件：
var amqp = require("amqplib/callback_api");
var crontab = require('node-crontab');
amqp.connect("amqp://localhost", function (err, conn) {
conn.createChannel(function (err, ch) {
var ex = 'direct_logs';
var ex2 = 'dead-letter-test';
var severity = 'enterprise-1-key';
//assert "direct" exchange
ch.assertExchange(ex, 'direct', { durable: true });
//assert "dead-letter-test" exchange
ch.assertExchange(ex2, 'direct', { durable: true });
//if acknowledgement is nack() then message will be stored in second exchange i.e. ex2="dead-letter-test"
ch.assertQueue('enterprise-11', { exclusive: false, deadLetterExchange: ex2 }, function (err, q) {
var n = 0;
console.log(' [*] Waiting for logs. To exit press CTRL+C');
console.log(q);
//Binding queue with "direct_logs" exchange
ch.bindQueue(q.queue, ex, severity);
//Binding the same queue with "dead-letter-test"
ch.bindQueue(q.queue, ex2, severity);
ch.consume(q.queue, function (msg) {
// consume messages via "dead-letter-exchange" exchange at every second.
if (msg.fields.exchange === ex2) {
crontab.scheduleJob("* * * * * *", function () {
console.log("Received by latest exchange %s", msg.fields.routingKey, msg.content.toString());
});
} else {
console.log("Received %s", msg.fields.routingKey, msg.content.toString());
}
if (n < 1) {
// this will executes first time only. Here I'm sending nack() so message will be stored in "deadLetterExchange"
ch.nack(msg, false, false);
n += 1;
} else {
ch.ack(msg)
n = 0
}
}, { noAck: false });
});
});
});
如果您希望所有队列都有相同的死信交换机，那么设置一个通用策略会更加容易：
sudo rabbitmqctl -p /my/vhost/path set_policy DLX ".*" '{"dead-letter-exchange":"MyExchange.DEAD"}' --apply-to queues
创建名为“dead.letter.test”的DIRECT交换机
正确
创建名为“dead.letter.queue”的队列
正确
将“dead.letter.queue”绑定到“dead.letter.test”上
正确
创建带有死信交换机设置为“dead.letter.test”的新队列“test1”
我假设您正在创建test1队列并将其绑定到dead.letter.test交换机上
向“test1”发送一条消息
如果您想要您的消息被dead.letter.queue接收，则在发送消息时必须提供路由键，并且使用dead.letter.queue的客户端也应该使用相同的路由键进行消费
如果您发布消息而未指定路由键，则只有订阅test1的客户端将接收到该消息。
如果您将消息发布到direct.letter.test交换机，则所有队列都将接收到该消息。它将像一个fanout交换机一样工作
因此，如果您想让dead.letter.queue接收消息，则必须将消息发布到该队列或在发布和订阅时使用相同的路由键并将消息发布到交换机
针对使用Spring-AMQP的用户
在我的情况下，问题是不同的。我想要一个死信交换机是直接类型的。我为队列设置了x-dead-letter-exchange和x-dead-letter-routing-key。此外，在application.properties中我设置了spring.rabbitmq.listener.simple.default-requeue-rejected=false。
看起来一切都很好，但是在调试时我注意到我的SimpleRabbitListenerContainerFactory的defaultRequeueRejected为null。原因是当您在@Configuration中声明SimpleRabbitListenerContainerFactory时，您创建了一个新的“非默认”bean。默认的bean会在幕后根据您的属性自动创建。但是您在@Config中的SimpleRabbitListenerContainerFactory不会读取这些属性，您必须自己读取并在Java代码中设置。
这种情况曾经发生在我身上，因为当我想要配置并发性时，我只是从Spring-AMQP文档中复制粘贴了配置。但你应该在一个地方完成所有操作，比如在属性中，像这样：
spring.rabbitmq.listener.simple.default-requeue-rejected=false
spring.rabbitmq.listener.simple.concurrency=5
spring.rabbitmq.listener.simple.max-concurrency=10
或者完全使用Java，例如
@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
factory.setConnectionFactory(connectionFactory);
factory.setConcurrentConsumers(5);
factory.setMaxConcurrentConsumers(10);
factory.setDefaultRequeueRejected(false);
return factory;
}
这两个是相同的。
我期望当我使用第二个选项（Java）时，它仍然可以从application.properties中获取属性，然后我可以在Java中进行自定义，但实际上并不是这样的。 是的，“复制粘贴”是邪恶的 :)
ackMode="MANUAL"
但是我从未设置它（因为运行时异常），使用默认ACK代替。