将redis pubsub消息转发到express中的特定Socket.io客户端

Question

js lang-js prettyprint-override">var redis = require('redis');
var server = require('http').createServer(app);
var io = require("socket.io")(server);

io.on('connection', function (socket) {

   socket.on('whatever_event', function() {
       socket.broadcast.to(mySocketID).emit('TEST', 'hello ' + mySocketID);
   }
}

var subscriber = redis.createClient();

subscriber.on('message', function (channel, redisMessage) {

// I want to send redisMessage to the websocket client
// Can I access to "socket" in io.on('connection' ...) ? 

});

Answer 1

不久前，我用WebSockets做了类似的事情（如果我明白您想做什么的话）。实际上，我必须在Redis pub/sub（普通的OL'EventEmitter)和WebSocket之间创建一个进程内事件代理层。如果没有这一层，您将有大量不必要的连接开销，通过使用它，您可以限制Redis的打开连接数。

因此，subscriber.on节发送一个EventEmitter事件(youreventsobject.emit(/*...*/))。然后，在socket.io连接回调中，使用侦听器(youreventsobject.on(/*...*/))响应这些事件。当socket.io连接关闭时，您需要确保并清理这些EventEmitter监听器，这样就不会在关闭的套接字中出现错误。

以下是完整的文件和描述WebSockets问题/解决方案的文章。