main.js：

var cluster = require( 'cluster' );
var os = require( 'os' );

if( cluster.isMaster ) {
    cluster.on( 'exit', function( worker, code, signal ) {
        console.log( 'worker #' + worker.id + ' died, and try restarting...' );
        cluster.fork();
    });
    cluster.on( 'fork', function( worker ) {
        console.log( 'worker #' + worker.id + ' is forking.' );
    });
    cluster.on( 'online', function( worker ) {
        console.log( 'Yay, the worker responded after it was forked' );
    });
    cluster.on( 'listening', function( worker, address ) {
        console.log( 'A worker with #'+ worker.id + ' is now connected to ' + address.address + ':' + address.port );
    });
    cluster.on( 'disconnect', function( worker ) {
        console.log( 'The worker #' + worker.id + ' has disconnected' );
    });
    os.cpus().forEach(function() {
        cluster.fork();
    });
} else {
    var server = require( 'server.js' );
    var router = require( 'router.js' );

    server.start( router.route );
}

process.on( 'SIGTERM', function() {
    for( var id in cluster.workers ) {
        process.kill( id );
    }
    process.exit( 0 );
});

process.on( 'message', function( msg ) {
    console.log( 'process on message,and msg is : ' + msg );
});

server.js：

var net = require( 'net' );
var HOST = '127.0.0.1';
var PORT = 6969;
var Server = {};
var cluster = require( 'cluster' );

function start( route ) {
    Server = net.createServer( function( socket ) {
        //多进程监控接受
        console.log('Worker #' + cluster.worker.id + ' has a request');
        socket.on( 'data', function( data ) {
            //下面是业务相关代码
            route( socket, data );
        });
        socket.on( 'error', function( err ) {
            if( err.code == 'EADDRINUSE' ) {
                console.log( 'port ' + PORT + 'is using by other Server' );
            }
        });
        socket.on( 'close', function( msg ) {
            console.log( 'socket closed' );
        });
    });
    Server.listen( PORT, HOST );
    console.log( 'Server on.' );
}

exports.start = start;