RabbitMQ和Sails.js

要回答原始问题,如果由于某种原因想要使用Rabbit MQ而不是Sails的内置资源丰富的pubsub,最好的方法是使用rabbit.js.

首先,npm install rabbit.js.

然后,在你的Sails项目的config/sockets.js中(从rabbit.js socket.io示例中大量借用):

var context = require('rabbit.js').createContext();
module.exports = {

     onConnect: function(session, socket) {
        var pub = context.socket('PUB');
        var sub = context.socket('SUB');

        socket.on('disconnect', function() {
          pub.close();
          sub.close();
        });

        // NB we have to adapt between the APIs
        sub.setEncoding('utf8');
        socket.on('message', function(msg) {
          pub.write(msg, 'utf8');
        });
        sub.on('data', function(msg) {
          socket.send(msg);
        });
        sub.connect('chat');
        pub.connect('chat');

    }

}