如何为浏览器客户端设置RabbitMQ绑定

Question

我正在使用socket.io将数据消息从RabbitMQ流式传输到浏览器，但到目前为止，我只知道如何对服务器进行硬编码，以订阅单个（预先指定的）路由密钥（在下面的代码中，它是message.1）。我想做的是创建一个api，这样每个客户端（浏览器会话）都可以订阅他们想要的任何路由密钥，并让socket.io只将订阅的消息流式传输到这些客户端。这是我已经拥有的代码：

//app.js    
var express = require('express'),
        routes = require('./routes'),
        api = require('./routes/api'),
        http = require('http'),
        path = require('path');

var amqp = require('amqp'),
    rabbitMq = amqp.createConnection({ url: "amqp://guest:guest@localhost" },
        {defaultExchangeName: "amq.topic"});
var app = module.exports = express(),
    server = http.createServer(app),
    io = require('socket.io').listen(server);

/**
 * Configuration
 */
// all environments
app.set('port', process.env.PORT || 3000);
app.set('views', __dirname + '/views');
app.set('view engine', 'jade');
app.use(express.logger('dev'));
app.use(express.bodyParser());
app.use(express.methodOverride());
app.use(express.static(path.join(__dirname, 'public')));
app.use(app.router);
// development only
if (app.get('env') === 'development') {
  app.use(express.errorHandler());
}
// production only
if (app.get('env') === 'production') {
  // TODO
};

/**
 * Routes
 */
// serve index and view partials
app.get('/', routes.index);
app.get('/partials/:name', routes.partials);
// JSON API
app.get('/api/name', api.name);
// redirect all others to the index (HTML5 history)
app.get('*', routes.index);

rabbitMq.on('ready', function () {
    io.sockets.on('connection', function (socket) {
        var exchange = rabbitMq.exchange('my-exchange',{durable:true});
        var queue = rabbitMq.queue('my-queue',{durable: true});
        queue.bind(exchange,'message.1'); // all messages
        queue.subscribe(function (message) {
            socket.broadcast.emit('message', {
                msg: decodeURIComponent(message.data),
                ts: Date()
            });
            console.log(message);
        });
    });
});

/**
 * Start Server
 */
server.listen(app.get('port'),function() {
    console.log("Express server listening on port " + app.get('port'));
});

我试着从app.js中取出rabbitMQ代码，并将其放入api.js中，但这似乎不起作用。如有任何关于下一步行动的建议或指导，我们将不胜感激。我一直在网上和SO上搜索相关的例子/教程，但似乎找不到合适的。

Answer 1

您需要实现一种方法，用您希望客户端从中获取消息的特定路由密钥从浏览器发送消息。

获得路由密钥后，在queue.bind中使用它，而不是message.1

Answer 2

这是一个示例，解释了如何在NodeJS中使用Express、node AMQP和SocketIO:

  https://github.com/jamescarr/nodejs-amqp-example/blob/master/node/app.js

正如上面发布的old_sound，您可以使用服务器端app.js文件中的socket.send，这样可以从socket-io.中将值发送到客户端

尽管我建议使用sock.js进行扩展。