gpt4 book ai didi

node.js - 使用 AMQP.Node 的 RabbitMQ 和 Node 中未使用死信消息

转载 作者:搜寻专家 更新时间:2023-11-01 00:33:25 25 4
gpt4 key购买 nike

我想在我的一名工作人员经过一定时间后收到一条消息。在发现所谓的死信交换后,我决定使用 Node 和 RabbitMQ。

消息似乎已发送到 DeadExchange 中的队列,但在 WorkExchange 中的 WorkQueue 中经过一段时间后,消费者再也没有收到消息。是 bindQueue 关闭了,还是死信不起作用?

我现在已经尝试了很多不同的值。有人可以指出我所缺少的吗?

var amqp = require('amqplib');
var url = 'amqp://dev.rabbitmq.com';

amqp.connect(url).then(function(conn) {
//Subscribe to the WorkQueue in WorkExchange to which the "delayed" messages get dead-letter'ed (is that a verb?) to.
return conn.createChannel().then(function(ch) {
return ch.assertExchange('WorkExchange', 'direct').then(function() {
return ch.assertQueue('WorkQueue', {
autoDelete: false,
durable: true
})
}).then(function() {
return ch.bindQueue('WorkQueue', 'WorkExchange', '');
}).then(function() {
console.log('Waiting for consume.');

return ch.consume('WorkQueue', function(msg) {
console.log('Received message.');
console.log(msg.content.toString());
ch.ack(msg);
});
});
})
}).then(function() {
//Now send a test message to DeadExchange to a random (unique) queue.
return amqp.connect(url).then(function(conn) {
return conn.createChannel();
}).then(function(ch) {
return ch.assertExchange('DeadExchange', 'direct').then(function() {
return ch.assertQueue('', {
arguments: {
'x-dead-letter-exchange': 'WorkExchange',
'x-message-ttl': 2000,
'x-expires': 10000
}
})
}).then(function(ok) {
console.log('Sending delayed message');

return ch.sendToQueue(ok.queue, new Buffer(':)'));
});
})
}).then(null, function(error) {
console.log('error\'ed')
console.log(error);
console.log(error.stack);
});

我正在使用 amqp.node ( https://github.com/squaremo/amqp.node ),它是 npm 中的 amqplib。尽管 node-amqp ( https://github.com/postwait/node-amqp ) 似乎更受欢迎,但它并没有实现完整的协议(protocol),并且在重新连接方面存在很多突出的问题。

dev.rabbitmq.com 正在运行 RabbitMQ 3.1.3。

最佳答案

这是一个工作代码。当消息在 DeadExchange 中花费的时间超过 ttl 时,它将被推送到 WorkExchange。成功的关键是定义正确的路由键。您希望向其发送 post ttl 的交换队列应与路由键绑定(bind)(注意:不是默认值),并且“x-dead-letter-routing-key”属性值应与该路由键匹配。

var amqp = require('amqplib');
var url = 'amqp://localhost';

amqp.connect(url).then(function(conn) {
//Subscribe to the WorkQueue in WorkExchange to which the "delayed" messages get dead-letter'ed (is that a verb?) to.
return conn.createChannel().then(function(ch) {
return ch.assertExchange('WorkExchange', 'direct').then(function() {
return ch.assertQueue('WorkQueue', {
autoDelete: false,
durable: true
})
}).then(function() {
return ch.bindQueue('WorkQueue', 'WorkExchange', 'rk1');
}).then(function() {
console.log('Waiting for consume.');

return ch.consume('WorkQueue', function(msg) {
console.log('Received message.');
console.log(msg.content.toString());
ch.ack(msg);
});
});
})
}).then(function() {
//Now send a test message to DeadExchange to DEQ queue.
return amqp.connect(url).then(function(conn) {
return conn.createChannel();
}).then(function(ch) {
return ch.assertExchange('DeadExchange', 'direct').then(function() {
return ch.assertQueue('DEQ', {
arguments: {
'x-dead-letter-exchange': 'WorkExchange',
'x-dead-letter-routing-key': 'rk1',
'x-message-ttl': 15000,
'x-expires': 100000
}
})
}).then(function() {
return ch.bindQueue('DEQ', 'DeadExchange', '');
}).then(function() {
console.log('Sending delayed message');

return ch.publish('DeadExchange', '', new Buffer("Over the Hills and Far Away!"));
});
})
}).then(null, function(error) {
console.log('error\'ed')
console.log(error);
console.log(error.stack);
});

关于node.js - 使用 AMQP.Node 的 RabbitMQ 和 Node 中未使用死信消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17969152/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com