async-sess-storage.js

var cluster = require('cluster'),
    https = require('https'),
    fs = require('fs'),
    Buffer = require('buffer').Buffer;

var redis = require('redis').createClient();

function start() {
  var options = {
    key: fs.readFileSync('./test/fixtures/test_key.pem'),
    cert: fs.readFileSync('./test/fixtures/test_cert.pem')
  };

  var server = https.createServer(options, function (req, res) {
    if (req.url === '/abc') process.exit();
    res.end('hello');
  });

  server.listen(44300, function() {
    console.log('listening!');
  });

  server.on('resumeTlsSession', function(key, callback) {
    redis.get('tls_sessions:' + key.toString('base64'), function(err, sess) {
      if (err || !sess) return callback(err, sess);
      callback(null, new Buffer(sess, 'base64'));
    });
  });

  server.on('newTlsSession', function(key, session) {
    var rkey = 'tls_sessions:' + key.toString('base64');
    redis.set(rkey, session.toString('base64'));
    redis.expire(rkey, 300);
  });
}

if (cluster.isMaster) {
  for (var i = 0; i < 4; i++) {
    cluster.fork();
  }

  cluster.on('exit', function(worker, code, signal) {
    cluster.fork();
  });
} else {
  start();
}