/0MQ

Basic Examples of a messaging service using Node and 0MQ

Primary LanguageJavaScript

Building Distributed Systems with Node.js and ØMQ

Examples built from: Building Distributed Systems with Node.js and ØMQ

Installing ØMQ

Mac OSX

brew install zmq

Ubuntu

sudo apt-get install libtool autoconf automake uuid-dev build-essential
wget http://download.zeromq.org/zeromq-3.2.2.tar.gz
tar zxvf zeromq-3.2.2.tar.gz && cd zeromq-3.2.2
./configure
make
sudo make install

Testing the base library.

man zmq

Install the zmq node module.

npm install zmq

Testing the module.

node --harmony -p -e 'require("zmq")'

First pass at troubleshooting (update system library cache):

sudo ldconfig

PUB/SUB with ØMQ

Same beacon application.

PUB program: zmq-beacon-pub.js

SUB program: zmq-beacon-sub.js

REQ/REP with ØMQ

Application requests the current time.

REP program: zmq-time-rep.js

REQ program: zmq-time-req.js

DEALER/ROUTER cluster with ØMQ

DEALER = parallel REQ

ROUTER = parallel REP

Figure of REP cluster using DEALER/ROUTER

Cluster responds to time requests just like the previous example.

REP cluster program: zmq-time-rep-cluster.js

PUSH/PULL with ZMQ

Simple work queue using PUSH/PULL.

PUSH program: zmq-work-push.js

PULL program: zmq-work-pull.js

Cluster to demonstrate the First Joiner problem.

PULL cluster program: zmq-work-pull-cluster.js