编辑:在 Socket.IO 1.0+ 中,不再需要使用多个 Redis 客户端设置存储,现在可以使用更简单的 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) {
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() {
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 = *
运行您的Node应用程序。 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 <
Client <
Client <
Client <
正如您所看到的,当您从工作进程发出时,它将向Redis发布该发射,并会从已订阅Redis数据库的其他工作进程进行镜像。这也意味着您可以使用连接到同一实例的多个套接字服务器,一个服务器上的发射将在所有连接的服务器上触发。
使用集群时,当客户端连接时,它将连接到您的四个工作进程之一,而不是全部四个。这也意味着您从该工作进程发出的任何内容只会显示一次给客户端。因此,是的,应用正在扩展,但是您的方式是从所有四个工作进程发出,而Redis数据库使其好像您在单个工作进程上调用了四次。如果客户端实际上连接到您的所有四个套接字实例,则每秒将接收到16条消息,而不是4条。
套接字处理类型取决于您要拥有的应用程序类型。如果您要单独处理客户端,则不应该有问题,因为连接事件仅对每个客户端的一个工作进程触发。如果您需要全局“心跳”,则可以在主进程中拥有套接字处理程序。由于工作进程在主进程死亡时死亡,因此您应该将连接负载偏移主进程,并让子进程处理连接。以下是一个示例:
var cluster = require('cluster');
var os = require('os');
if (cluster.isMaster) {
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() {
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()
,因此该进程上没有连接开销。但是,如果您在主进程上调用 emit,则会将其发布到 Redis,并且四个工作进程将在其客户端上执行 emit。这将连接负载偏移给工作进程,如果一个工作进程死亡,则主进程中的主要应用程序逻辑将不受影响。
请注意,在 Redis 中,所有的 emit,即使在命名空间或房间中,也会被其他工作进程处理,就好像您从该进程触发了 emit 一样。换句话说,如果您有两个 Socket.IO 实例和一个 Redis 实例,在第一个工作进程中调用
emit()
将向其客户端发送数据,而第二个工作进程将执行与从该工作进程调用 emit 相同的操作。