编辑：在 Socket.IO 1.0+ 中，现在可以使用更简单的 Redis 适配器module，而不是设置具有多个 Redis 客户端的存储。
var io = require('socket.io')(3000);
var redis = require('socket.io-redis');
io.adapter(redis({ host: 'localhost', port: 6379 }));
下面显示的示例看起来更像这样：
var cluster = require('cluster');
var os = require('os');
if (cluster.isMaster) {
// we create a HTTP server, but we do not use listen
// that way, we have a socket.io server that doesn't accept connections
var server = require('http').createServer();
var io = require('socket.io').listen(server);
var redis = require('socket.io-redis');
io.adapter(redis({ host: 'localhost', port: 6379 }));
setInterval(function() {
// all workers will receive this in Redis, and emit
io.emit('data', 'payload');
}, 1000);
for (var i = 0; i < os.cpus().length; i++) {
cluster.fork();
}
cluster.on('exit', function(worker, code, signal) {
console.log('worker ' + worker.process.pid + ' died');
});
}
if (cluster.isWorker) {
var express = require('express');
var app = express();
var http = require('http');
var server = http.createServer(app);
var io = require('socket.io').listen(server);
var redis = require('socket.io-redis');
io.adapter(redis({ host: 'localhost', port: 6379 }));
io.on('connection', function(socket) {
socket.emit('data', 'connected to worker: ' + cluster.worker.id);
});
app.listen(80);
}
如果您有一个主节点需要发布到其他 Socket.IO 进程，但本身不接受套接字连接，请使用socket.io-emitter而不是socket.io-redis。
如果您在扩展时遇到问题，请使用DEBUG=*. Socket.IO 现在实现了debug，它也会打印出 Redis 适配器调试消息。示例输出：
socket.io:server initializing namespace / +0ms
socket.io:server creating engine.io instance with opts {"path":"/socket.io"} +2ms
socket.io:server attaching client serving req handler +2ms
socket.io-parser encoding packet {"type":2,"data":["event","payload"],"nsp":"/"} +0ms
socket.io-parser encoded {"type":2,"data":["event","payload"],"nsp":"/"} as 2["event","payload"] +1ms
socket.io-redis ignore same uid +0ms
如果您的主进程和子进程都显示相同的解析器消息，那么您的应用程序正在正确扩展。
如果您是从单个工作人员发出的，那么您的设置应该没有问题。您正在做的是从所有四个工作人员发出，并且由于 Redis 发布/订阅，消息不会重复，而是按照您要求应用程序的方式写入四次。这是Redis所做的简单图表：
Client <-- Worker 1 emit --> Redis
Client <-- Worker 2 <----------|
Client <-- Worker 3 <----------|
Client <-- Worker 4 <----------|
如您所见，当您从一个 worker 发出时，它会将发出的内容发布到 Redis，并且会从其他订阅了 Redis 数据库的 worker 镜像。这也意味着您可以使用多个连接到同一个实例的套接字服务器，并且一个服务器上的发射将在所有连接的服务器上被触发。
使用集群，当客户端连接时，它将连接到您的四个工作人员之一，而不是全部四个。这也意味着您从该工作人员发出的任何内容都只会向客户端显示一次。所以是的，应用程序正在扩展，但是你这样做的方式，你从所有四个工作人员发出，Redis 数据库使它好像你在一个工作人员上调用它四次。如果客户端实际上连接到所有四个套接字实例，他们将每秒接收 16 条消息，而不是 4 条。
套接字处理的类型取决于您将拥有的应用程序类型。如果您要单独处理客户端，那么您应该没有问题，因为连接事件只会为每个客户端的一个工作人员触发。如果您需要全局“心跳”，那么您可以在主进程中有一个套接字处理程序。由于工人在主进程死亡时死亡，因此您应该抵消主进程的连接负载，并让子进程处理连接。下面是一个例子：
var cluster = require('cluster');
var os = require('os');
if (cluster.isMaster) {
// we create a HTTP server, but we do not use listen
// that way, we have a socket.io server that doesn't accept connections
var server = require('http').createServer();
var io = require('socket.io').listen(server);
var RedisStore = require('socket.io/lib/stores/redis');
var redis = require('socket.io/node_modules/redis');
io.set('store', new RedisStore({
redisPub: redis.createClient(),
redisSub: redis.createClient(),
redisClient: redis.createClient()
}));
setInterval(function() {
// all workers will receive this in Redis, and emit
io.sockets.emit('data', 'payload');
}, 1000);
for (var i = 0; i < os.cpus().length; i++) {
cluster.fork();
}
cluster.on('exit', function(worker, code, signal) {
console.log('worker ' + worker.process.pid + ' died');
});
}
if (cluster.isWorker) {
var express = require('express');
var app = express();
var http = require('http');
var server = http.createServer(app);
var io = require('socket.io').listen(server);
var RedisStore = require('socket.io/lib/stores/redis');
var redis = require('socket.io/node_modules/redis');
io.set('store', new RedisStore({
redisPub: redis.createClient(),
redisSub: redis.createClient(),
redisClient: redis.createClient()
}));
io.sockets.on('connection', function(socket) {
socket.emit('data', 'connected to worker: ' + cluster.worker.id);
});
app.listen(80);
}
在示例中，有五个 Socket.IO 实例，一个是主实例，四个是子实例。主服务器从不调用，listen()因此该进程没有连接开销。但是，如果您在主进程上调用一个发射，它将被发布到 Redis，四个工作进程将在它们的客户端上执行发射。这会抵消工作人员的连接负载，如果工作人员死亡，您的主要应用程序逻辑将在主服务器中保持不变。
请注意，使用 Redis，即使在命名空间或房间中的所有发出都将由其他工作进程处理，就好像您从该进程触发了发出一样。换句话说，如果您有两个 Socket.IO 实例和一个 Redis 实例，则调用emit()第一个工作线程中的套接字会将数据发送到其客户端，而第二工作线程将执行相同的操作，就像您从该工作线程调用发射一样。