mStirner/http.master.js

## http.master.js
const net = require("net");
const ip = require('ip');
const os = require("os");
const cluster = require("cluster");

module.exports = function (seed) {


  /**
   * Hash IP
   * @type Number|seed
   */
  function hashHelper(ip) {

    var hash = seed;

    for (var i = 0; i < ip.length; i++) {
      var num = ip[i];

      hash += num;
      hash %= 2147483648;
      hash += (hash << 10);
      hash %= 2147483648;
      hash ^= hash >> 6;
    }

    hash += hash << 3;
    hash %= 2147483648;
    hash ^= hash >> 11;
    hash += hash << 15;
    hash %= 2147483648;

    return hash >>> 0;

  }

  // workers
  let workers = [];

  let tcp = net.Server({
    pauseOnConnect: true
  }, function balance(socket) {

    var addr = ip.toBuffer(socket.remoteAddress || '127.0.0.1');
    var hash = hashHelper(addr);

    // feedback
    console.log('balancing connection %j', addr);

    // send request to worker
    workers[hash % workers.length].send('sticky:balance', socket);

  });

  // liste for listening event
  tcp.once('listening', function () {

    let addr = this.address();
    console.log('Cluster (master) listening on %s:%d', addr.address, addr.port);

    for (var i = 0; i < os.cpus().length; i++) {

      let worker = cluster.fork();
      workers.push(worker);

      // feedback
      console.log('worker=%d spawn', worker.process.pid);

    }

  });

  // start tcp server
  tcp.listen(3000, "127.0.0.1");

};

## http.worker.js
const http = require("http");
const fs = require("fs");


module.exports = function () {


  // create standard http server
  // can be in the cluster.isMaster else statemant (is slave/!isMaster)
  var server = http.createServer(function (req, res) {
    res.write(fs.readFileSync(__dirname + "/public/index.html", ));
    res.end();
  });


  // FOR DEMO PURPOSE ONLY!
  var io = require('socket.io')(server);
  io.on('connection', function (socket) {
    console.log('a user connected');
  });


  process.on('message', function (msg, socket) {

    if (msg !== 'sticky:balance' || !socket) {
      return;
    }

    server._connections++;
    socket.server = server;
    server.emit('connection', socket);

  });


};

## index.html
<html>
  <head>
    <script src="/socket.io/socket.io.js"></script>
<script>
  var socket = io.connect('http://127.0.0.1:3000');
  socket.on('news', function (data) {
    console.log(data);
    socket.emit('my other event', { my: 'data' });
  });
</script>
  </head>
  <body>
    socket.io demo
  </body>
</html>

## service.http.js
const cluster = require("cluster");

// create seed
const seed = (Math.random() * 0xffffffff) | 0;


if (cluster.isMaster) {
  require("./http.master.js")(seed);
} else {
  require("./http.worker.js")(seed);
}
	const net = require("net");
	const ip = require('ip');
	const os = require("os");
	const cluster = require("cluster");

	module.exports = function (seed) {


	/**
	* Hash IP
	* @type Number\|seed
	*/
	function hashHelper(ip) {

	var hash = seed;

	for (var i = 0; i < ip.length; i++) {
	var num = ip[i];

	hash += num;
	hash %= 2147483648;
	hash += (hash << 10);
	hash %= 2147483648;
	hash ^= hash >> 6;
	}

	hash += hash << 3;
	hash %= 2147483648;
	hash ^= hash >> 11;
	hash += hash << 15;
	hash %= 2147483648;

	return hash >>> 0;

	}

	// workers
	let workers = [];

	let tcp = net.Server({
	pauseOnConnect: true
	}, function balance(socket) {

	var addr = ip.toBuffer(socket.remoteAddress \|\| '127.0.0.1');
	var hash = hashHelper(addr);

	// feedback
	console.log('balancing connection %j', addr);

	// send request to worker
	workers[hash % workers.length].send('sticky:balance', socket);

	});

	// liste for listening event
	tcp.once('listening', function () {

	let addr = this.address();
	console.log('Cluster (master) listening on %s:%d', addr.address, addr.port);

	for (var i = 0; i < os.cpus().length; i++) {

	let worker = cluster.fork();
	workers.push(worker);

	// feedback
	console.log('worker=%d spawn', worker.process.pid);

	}

	});

	// start tcp server
	tcp.listen(3000, "127.0.0.1");

	};
	const http = require("http");
	const fs = require("fs");



	module.exports = function () {



	// create standard http server
	// can be in the cluster.isMaster else statemant (is slave/!isMaster)
	var server = http.createServer(function (req, res) {
	res.write(fs.readFileSync(__dirname + "/public/index.html", ));
	res.end();
	});



	// FOR DEMO PURPOSE ONLY!
	var io = require('socket.io')(server);
	io.on('connection', function (socket) {
	console.log('a user connected');
	});




	process.on('message', function (msg, socket) {

	if (msg !== 'sticky:balance' \|\| !socket) {
	return;
	}

	server._connections++;
	socket.server = server;
	server.emit('connection', socket);

	});


	};
	<html>
	<head>
	<script src="/socket.io/socket.io.js"></script>
	<script>
	var socket = io.connect('http://127.0.0.1:3000');
	socket.on('news', function (data) {
	console.log(data);
	socket.emit('my other event', { my: 'data' });
	});
	</script>
	</head>
	<body>
	socket.io demo
	</body>
	</html>
	const cluster = require("cluster");

	// create seed
	const seed = (Math.random() * 0xffffffff) \| 0;


	if (cluster.isMaster) {
	require("./http.master.js")(seed);
	} else {
	require("./http.worker.js")(seed);
	}