4

我正在尝试使用带有 Redis 的 Node.js 和 Socket.io 将应用程序部署到 Heroku。我已经将 Socket.io 设置为使用Heroku 指定的XHR 长轮询，如果我只有一个测功机，它可以完美地工作，但是当我将它缩放以使用多个测功机时它就不起作用了。

最初我在 Socket.io 中使用 MemoryStore，当我使用“heroku ps:scale web=2”对其进行扩展时，它开始间歇性地工作，并在客户端出现此错误：

未捕获的类型错误：对象#<Transport> 的属性“打开”不是函数

我在Socket.io 文档中发现“如果你想扩展到多个进程和/或多个服务器，你可以使用我们的 RedisStore，它使用 Redis NoSQL 数据库作为中间人”

所以，我创建了一个 RedisStore：

var newRedisStore = new RedisStore({
  redisPub : pub,
  redisSub : sub,
  redisClient : client
});

并配置了 Socket.io 来使用它：

//set up Web Socket Server
io.configure(function () { 
  io.set("transports", ["xhr-polling"]);
  io.set("polling duration", 10);
  io.set('store', newRedisStore);
});

这一切都可以在本地完美运行，并且在 Heroku 中使用一个 web dyno。但是，一旦我将它扩展到多个进程，它就会间歇性地开始不再工作，尽管现在我不再收到错误了。所以，我不知道从这里去哪里。

这些是我从 Heroku 获得的具有 2 个进程的日志：

2012-06-16T15:36:12+00:00 app[web.2]：调试：设置轮询超时
2012-06-16T15:36:12+00:00 app[web.2]：调试：清除轮询超时
2012-06-16T15:36:12+00:00 app[web.2]：调试：xhr-polling 写入
7:::1+0 2012-06-16T15:36:12+00:00 app[web. 2]：警告：客户端未
握手客户端应重新连接 2012-06-16T15:36:12+00:00
app[web.2]：调试：为客户端设置关闭超时 15718037491002932534
2012-06-16T15:36:12+00 ：00 应用程序 [web.2]：调试：清除
客户端 15718037491002932534 的关闭超时 2012-06-16T15:36:12+00:00 应用程序 [web.2]：
信息：传输端（错误）2012-06-16T15： 36:12+00:00 app[web.2]：
调试：丢弃传输

4

2 回答 2

1

您是否尝试过使用 Node 中的 Cluster 模块？ http://nodejs.org/api/cluster.html

喜欢：

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();
  }

  cluster.on('death', function(worker) {
    console.log('worker ' + worker.pid + ' died');
  });
} else {
  // Worker processes have a http server.
  http.Server(function(req, res) {
    res.writeHead(200);
    res.end("hello world\n");
  }).listen(8000);
}

或者：

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);
    })
  });
}

就像你在这里看到的一样。

于 2012-06-16T16:05:26.433 回答
0

heroku 的缩放是使用 heroku ps:scale {number} 完成的，你不能在那里产生进程。我现在有同样的问题。

https://github.com/LearnBoost/socket.io/issues/939

于 2012-07-03T16:22:32.263 回答