processcom

Master Develop communicate and launch multi node process on same machine

Installation

$ npm install processcom

Exemple

create 4 files

Master process file

'use strict'
//read config file
var config = require('./config.json');
 
//create master process
var master = require('processcom').createMaster(config);
 
//listen event when a process child created
//proc is a process object (see node process)
 
master.on(master.ON_PROCESS_CREATED, function(proc){
  console.log('process created');
})
 
//launch master process
master.start();
 
//add a process after start
master.createProcess({name:"child3", process:"child_3"});

child_1.js process file

'use strict'
//create child process communication
var child = require('processcom').createChild();
 
//listen when a message has been send by master
child.on('message', function(data){
        console.log(this.processName,' received data :', data);
});
 

child_2.js process file

'use strict'
//create child process communication
var child = require('processcom').createChild();
 
//listen when a message has been send by master
child.on('message', function(data){
        console.log(this.processName,' received data :',data );
});
 
//send message to child1 process
setInterval(child.sendMessage.bind(child, {to:'child1', content:'hello from child process 2'}),5000);
 

child_3.js process file

'use strict'
//create child process communication
var child = require('processcom').createChild();
 
//listen when a message has been send by master
child.on('message', function(data){
        console.log(this.processName,' received data :',data );
});
 
//send message to child1 process
setInterval(child.sendMessage.bind(child, {to:'child1', content:{x:1, y:2, message:'boyagaa'}}),5000);
 

config.json file

{
  "child_process":[
                  { "name":"child1",
                    "process":"child_1",
                    "autoRestart":true
                  },
                  { "name":"child2",
                    "process":"child_2",
                     "autoRestart":true
                  }
    			]
}