所以我开始使用 RabbitMQ 并在网站https://www.rabbitmq.com/tutorials/tutorial-one-javascript.html上做教程,但我没有 100% 理解如何设置确认功能以便删除队列在发送消息后立即发送消息,无论消息是否被消费都无关紧要。我正在尝试创建一个队列,该队列将在发送后立即删除所有消息
我尝试了教程中的示例,例如 hello world 示例显示 noAck 属性设置为 true,这意味着我们没有确认消息,因此队列实际上应该在发送这些消息后删除这些消息,但事实并非如此,因为当我运行 send.js 3 次然后运行 receive.js 然后我会收到 3 次 hello world 消息,这不是我想要的
// this is send.js
var amqp = require('amqplib/callback_api');
amqp.connect('amqp://localhost', function(error0, connection) {
if (error0) {
throw error0;
}
connection.createChannel(function(error1, channel) {
if (error1) {
throw error1;
}
var queue = 'hello';
var msg = 'Hello World!';
channel.assertQueue(queue, {
durable: false
});
channel.sendToQueue(queue, Buffer.from(msg));
console.log(" [x] Sent %s", msg);
});
setTimeout(function() {
connection.close();
process.exit(0);
}, 500);
});
// this is receive .js
var amqp = require('amqplib/callback_api');
amqp.connect('amqp://localhost', function(error0, connection) {
if (error0) {
throw error0;
}
connection.createChannel(function(error1, channel) {
if (error1) {
throw error1;
}
var queue = 'hello';
channel.assertQueue(queue, {
durable: false
});
console.log(" [*] Waiting for messages in %s. To exit press CTRL+C",
queue);
channel.consume(queue, function(msg) {
console.log(" [x] Received %s", msg.content.toString());
}, {
noAck: true
});
});
});
例如,如果我运行 3 次 send.js,则可能会发生 2 种情况。情况 1 是消息将从接收方消费并完成。case2 是它不会从接收器中消耗,在这种情况下,我希望将其删除,如果我在 send.js 一个月后运行 receive.js,我不希望消息被消耗,但我也希望我的队列耐用而不是排他性。当我继续调用 send.js 并且消息将一直推送到该队列中时,这也是一个问题,然后如果我运行 receive.js,我将同时收到 1000 条消息,所以我的目标是避免这种情况。我很感激任何帮助