作者热门文章
- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我使用以下代码示例创建了一个发布者。
var amqp = require('amqplib/callback_api');
amqp.connect('amqp://localhost', function(err, conn) {
conn.createChannel(function(err, ch) {
var args = process.argv.slice(2);
var routingkey = (args.length > 0) ? args[0] : 'anonymous.info';
var keys = routingkey.split(".")
var exchange = keys[0];
queueName = keys[1];
var msg = args.slice(1).join(' ') || 'Hello World!';
console.log("Exchange---------------------" , exchange);
console.log("routingkey-------------------", routingkey);
console.log("queueName-------------------" , queueName);
queueName = exchange;
ch.assertExchange(exchange, 'topic', {durable: false});
ch.assertQueue(queueName, {exclusive: false, durable: false}, false);
ch.bindQueue(queueName, exchange, routingkey);
ch.publish(exchange, routingkey, new Buffer(msg));
console.log(" [x] Sent %s: '%s'", routingkey, msg);
});
setTimeout(function() { conn.close(); process.exit(0) }, 500);
});
基于上述发布者:
交换:通知:::
队列名称:通知:::
路由键:['notification.addworker','notification.getworker',.....]
因此,我能够使用与多个路由键的绑定(bind)将消息发布到唯一的队列名称。
这是我的问题,我无法根据路由键使用消息,因为消息在发布时绑定(bind)到队列。
建议我上面的代码是否做错了。
消费者代码:
var args = process.argv.slice(2);
amqp.connect('amqp://localhost', function(err, conn) {
conn.createChannel(function(err, ch) {
var ex = 'notification';
var args = process.argv.slice(2);
var routingkey = (args.length > 0) ? args[0] : 'anonymous.info';
var keys = routingkey.split(".")
var exchange = keys[0];
var queueName = exchange;
ch.assertExchange(exchange, 'direct', {durable: false});
ch.assertQueue(exchange, {exclusive: false, durable:false}, function(err, q) {
console.log(' [*] Waiting for logs. To exit press CTRL+C');
ch.bindQueue(queueName, ex, routingkey);
console.log("Exchange---------------------" , exchange);
console.log("routingkey-------------------", routingkey);
console.log("queueName-------------------" , queueName);
ch.consume(queueName, function(msg) {
console.log(" [x] %s:'%s'", msg.fields.routingKey, msg.content.toString());
}, {noAck: true});
});
});
});
消费者无法根据路由键过滤消息。
寻找我做错的地方的建议。我坚持使用主题。
感谢您的耐心等待。
最佳答案
我知道这是一篇旧帖子,但如果您对我的 2 美分感兴趣...我所做的是在发布命令中添加一些回复信息:
ch.publish(exchange, send_key, new Buffer(message), { correlationId: corrId, replyTo: q.queue });
其中q.queue来自assetQueue回调,可以指定回复队列。
然后可以食用...
ch.consume(q.queue, function(msg) {...}
不确定这是否准确回答了您的问题,我还没有设法消除队列名称,我自己还是初学者。
关于javascript - RabbitMQ 消费者应该通过路由键而不是 QueueName 进行监听,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47650071/
我使用以下代码示例创建了一个发布者。 var amqp = require('amqplib/callback_api'); amqp.connect('amqp://localhost', func
我有一个 ServiceBusTrigger 公共(public)异步任务运行( [ServiceBusTrigger("%QueueName%", Connection = "ServiceBus"
我是一名优秀的程序员,十分优秀!