Node.js, multi-threading i Socket.io

Question

Szukam, aby Socket.io działał wielowątkowo z native load balancing ("cluster") w Node.js w wersji 0.6.0 i nowszych.

Z tego co rozumiem, Socket.io używa Redis do przechowywania swoich wewnętrznych danych. Moje rozumienie jest następujące: zamiast tworzenia nowej instancji Redis dla każdego pracownika, chcemy zmusić pracowników do korzystania z tej samej instancji Redis, co master. W związku z tym dane dotyczące połączenia będą udostępniane wszystkim pracownikom.

Coś takiego w Master:

RedisInstance = new io.RedisStore; 

musimy jakoś przejść RedisInstance do robotników i wykonaj następujące czynności:

io.set('store', RedisInstance); 

Zainspirowany this implementation pomocą starego, moduł klastra 3rd party Mam następujące niedziałające wdrożenie:

var cluster = require('cluster'); 
var http = require('http'); 
var numCPUs = require('os').cpus().length; 

if (cluster.isMaster) { 
    // Fork workers. 
    for (var i = 0; i < numCPUs; i++) { 
    cluster.fork(); 
    } 

    var sio = require('socket.io') 
    , RedisStore = sio.RedisStore 
    , io = sio.listen(8080, options); 

    // Somehow pass this information to the workers 
    io.set('store', new RedisStore); 

} else { 
    // Do the work here 
    io.sockets.on('connection', function (socket) { 
    socket.on('chat', function (data) { 
     socket.broadcast.emit('chat', data); 
    }) 
    }); 
} 

Myśli? Być może idę całkowicie w złą stronę, czy ktoś może wskazać jakieś pomysły?

Answer 1

Właściwie Twój kod powinien wyglądać tak:

var cluster = require('cluster'); 
var http = require('http'); 
var numCPUs = require('os').cpus().length; 

if (cluster.isMaster) { 
    // Fork workers. 
    for (var i = 0; i < numCPUs; i++) { 
    cluster.fork(); 
    } 
} else { 
    var sio = require('socket.io') 
    , RedisStore = sio.RedisStore 
    , io = sio.listen(8080, options); 

    // Somehow pass this information to the workers 
    io.set('store', new RedisStore); 

    // Do the work here 
    io.sockets.on('connection', function (socket) { 
    socket.on('chat', function (data) { 
     socket.broadcast.emit('chat', data); 
    }) 
    }); 
} 

Innym rozwiązaniem jest otwarcie Socket.IO słuchać na wielu portów i mieć coś podobnego HAProxy obciążenia bilansu rzeczy. W każdym razie wiesz najważniejszą rzeczą: używanie RedisStore do skalowania poza procesem!

Zasoby:

http://nodejs.org/docs/latest/api/cluster.html
How can I scale socket.io?
How to reuse redis connection in socket.io?
Node: Scale socket.io/nowjs - scale across different instances
http://delicious.com/alessioaw/socket.io