Super Simple ZeroMQ request - reply example

zmqReqRepExample.js

//Please run in separated file - requester.js AND replier.js.

//requester.js

var zmq = require('zmq')
  , sock = zmq.socket('req');

sock.connect('tcp://127.0.0.1:3000');
console.log('Requester bound to port 3000');

setInterval(function () {
  console.log('sending work');
  sock.send('some work');
}, 500);


sock.on('message', function (msg) {
	console.log('%s', msg);
});


//replier.js

var zmq = require('zmq')
  , sock = zmq.socket('rep');

sock.bindSync('tcp://127.0.0.1:3000');
console.log('Worker connected to port 3000');


sock.on('message', function(msg){
	console.log('%s', msg)
  	sock.send('hello');
});