node.js - Redis 使用 Node Cluster、Socket.io 时多次订阅

Question

我正在使用 socket.io 处理实时帖子，

流正在实时更新，但问题是 redis 订阅发生多次，并且帖子在流中出现多次。

我正在使用 node.jscluster module创建多个节点集群。这是代码，

worker.js

var cluster    = require('cluster');
var server     = new Hapi.Server(config.port,view_options);

var socketIO   = require('socket.io');
var redis      = require("socket.io/node_modules/redis");
var RedisStore = require('socket.io/lib/stores/redis');

var io         = socketIO.listen(server.listener);
var sub        = redis.createClient();
sub.setMaxListeners(0);

io.configure(function() {
    io.set('store', new RedisStore({
        redisSub : sub
    }));
    io.set('transports', ['xhr-polling']);
    io.set('polling duration', '10');
});

if (cluster.isMaster) {
     for (var i = 0; i < numCPUs; i++) {
        cluster.fork();
    }
} 
else {
    sub.subscribe("userstreams");
    io.sockets.on('connection', function(socket) {
    // Realtime streams : subscribe to redis channel userstreams
        sub.on("message", function(channel, member_postid) {
            console.info("-----------realtime post receieved --------",member_postid);                
        });        
    });
}

发布者.js

// head
var redis      = require("socket.io/node_modules/redis");
var pub        = redis.createClient();
// inside a function 
pst = member + "::" + data.pid
pub.publish("userstreams", pst);

客户端仅发布一次 postID，但我在服务器的 userstreams 频道中获得了多个订阅。

我希望我的服务器只获得一次 redis 订阅，这样我就可以将它们通过套接字发送到用户的流中一次。

Answer 1

你需要为socket.io配置pub、sub和client：

var pub = redis.createClient();
var sub = redis.createClient();
var client = redis.createClient();

并将它们传递给 socket.io

io.set('store', new io.RedisStore({
  redisSub : sub,
  redisPub: pub,
  redisClient: client
}));