将 RabbitMQ 与 Ruby 和 Node.js 应用程序一起使用？

Question

我在 Rails 中使用 Bunny gem，在 Node.js 中使用 AMQP。 Rails 是发布者，Node.js 应用程序是订阅者。

来自 Rails 的代码：

conn = Bunny.new
conn.start

ch = conn.create_channel
x = Bunny::Exchange.new(ch, :direct, "messenger")
q1 = ch.queue("new_messages").bind(x, :routing_key => 'send')
x.publish('hi', :routing_key => 'send')

来自 Node.js 的代码：

var amqp = require('amqp');

var connection = amqp.createConnection();

connection.addListener('ready', function(){
    var exchange = connection.exchange('messenger');
    var queue = connection.queue('new_messages')

    queue.bind('messenger', 'send')

    queue.subscribe( {ack:true}, function(message){
        console.log(message.data.toString())
        queue.shift()
    });
});

从管理插件中，我可以看到 Rails 代码运行良好，但来自 Node.js 的代码没有意义。

我的错误在哪里？

Answer 1

主要问题在于您如何尝试将队列绑定到“信使”交换。您已经使用交换名称来获取对交换对象的引用。将队列绑定到交换器时，不要再次传入字符串名称，而是将 此引用 传递到 queue.bind()。只需更改第一个 queue.bind() 参数：

var exchange = connection.exchange('messenger');    
var queue = connection.queue('new_messages');

// Use the reference to the exchange object you just received;
// pass it in here instead of the exchange's name
queue.bind(exchange, 'send');

编辑

这是一个完整的工作示例；只需放入您自己的连接属性：

var amqp = require('amqp');

var connection = amqp.createConnection({
    host: 'my_host',
    login: 'my_login',
    password: 'my_password',
    authMechanism: 'AMQPLAIN',
    vhost: 'my_vhost'
});

connection.addListener('ready', function(){

    console.log('ready');

    var exchange = connection.exchange('messenger');
    var queue = connection.queue('new_messages');

    queue.bind(exchange, 'send');

    // if message successfully received, print message
    queue.subscribe( {ack:true}, function(message){

        console.log(message.data.toString());
        queue.shift();
    });

    // test by sending a message
    exchange.publish('send', 'this is a test message', {}, function() {})
});

干杯。