Как настроить кластер на Node.js Express4 Socket.IO?

Question

[pik_os]

/bin/www:

#!/usr/bin/env node

/**
 * Module dependencies.
 */
var app = require('../app');
var debug = require('debug')('server:server');
var http = require('http');

/**
 * Get port from environment and store in Express.
 */

var port = normalizePort(process.env.PORT || '3000');
app.set('port', port);

/**
 * Create HTTP server.
 */

var server = http.createServer(app);

var io               = require("socket.io")(server),
    passportSocketIo = require("passport.socketio"),
    express = require('express'),
    cookieParser = require('cookie-parser'),
    redis = require('redis'),
    session = require('express-session'),
    redisStore = require('connect-redis')(session);
var client = redis.createClient();

io.use(passportSocketIo.authorize({
  cookieParser: cookieParser,
  key:         '***',       // the name of the cookie where express/connect stores its session_id
  secret:      '*********',    // the session_secret to parse the cookie
  store: new redisStore({ host: '*****', port: *******, client: client }),
  success:     onAuthorizeSuccess,  // *optional* callback on success - read more below
  fail:        onAuthorizeFail    // *optional* callback on fail/error - read more below
}));


var ioHandlers = require('../sockets')(io,passportSocketIo);

/**
 * Listen on provided port, on all network interfaces.
 */

server.listen(port);
server.on('error', onError);
server.on('listening', onListening);

в какой момент лучше породить дочерний процесс?
Возможно, есть модули, которые сюда подойдут лучше встроенного cluster.
Гугл выдаёт множество способов включения кластера, но они все как-то не похожи на то, что у меня.
Если дочерний процесс порождать в app.js, то сокеты продолжат выполняться в одном потоке.

Answer 1

[Тимур Шемсединов]

Потоки в ноде нужно порождать при старте приложения, это можно делать при помощи require('child_process').fork а вот require('cluster').fork это просто обертка вокруг него, которая позволяет передавать сокеты из родительского процесса в дочерние, чтобы распылить нагрузку на потоки. Если Вы не хотите использовать cluster, то нужно будет самому передавать handle сокета в дочерние процессы, порожденные через require('child_process').fork, через IPC, и самостоятельно организовывать алгоритм распыления, например, простой Round Robin или взвешенный Round Robin или приклеивание по IP. Чем Вас не устраивает cluster? Еще год-два назад он работал нестабильно, согласен, сам делал к нему заплаты, но теперь то cluster работает отлично как в node.js, так и в io.js

Comments

[pik_os]

Спасибо большое за совет. Этот файл является точкой входа в приложение. Как его правильно изменить для запуска приложения в кластере?

[Тимур Шемсединов]

Все как написано в доках по кластеру https://nodejs.org/api/cluster.html и пример там есть.
В мастер-процессе делаем for (var i = 0; i < require('os').cpus().length; i++) cluster.fork();
А а каждом дочернем http.createServer(app); и server.listen(port);

[Al]

Тимур Шемсединов: Я настроил socket.io в кластере с липкими сессиями, все работает, но столкнулся с проблемой отправки сообщений клиентам которые авторизовались на разных процессах: Как с помощью socket.io отправить сообщение конкретному клиенту если приложение использует cluster и работает в нескольких процессах на разных портах?
И досихпор не могу найти решения

[Тимур Шемсединов]

Alexander K.: Все правильно, это потому, что нет такого решения

[Al]

Тимур Шемсединов: а как же решать задачи такого рода? не могут же все приложения использующие socket.io работать в одном потоке или пределах одной физ. машины... Ресурс сервера же не резиновый(

[Тимур Шемсединов]

Alexander K.: Почему не может, может, даже работает. А вот для масштабирования сокет.ио не предназначен. Вообще сокет.ио ни для чего не нужен. Все делают свои решения для этого на вебсокетах, а готового ничего нет.

[Al]

Тимур Шемсединов: а вот в моем вопросе юзер "@Sanasol" говорит что это возможно, только я не пойму что он хочет сказать, может вы вмешаетесь в обсуждение и дадите свой комментарий по этому поводу?