zmq-xpub-xsub

zmq-xpub-xsub

Central hub for ZeroMQ that allows multiple publisher and subscribers on same port.

Dependencies

• ZeroMQ

Options

• xSubPort - defaults to 8700 if not provided
• xPubPort - default to 8701 if not provided

Starting zmq-xpub-xsub

zmq-xpub-xsub can be started directly from terminal or it can be required and started from hosted application. Host application can be used for purpose of deploying to different environments where host application will define deployment configuration.

1. Starting zmq-xpub-xsub with host application

const ZmqPs= require('zmq-xpub-xsub');

// Log xSubPort and XpubPort to console
ZmqPs.set('debug', true);

// zmq-xpub-xsub are launched and listening at provided ports
ZmqPs.run({ xSubPort: 8000, xPubPort: 8001 });

1. Starting zmq-xpub-xsub from terminal (after running npm install zmq-xpub-xsub -g)

>> zqm-xpub-xsub --xSubPort 8000 --xPubPort 8001

// If we want to see ports on which xpub-xsub is listening we can provide --debug flag
>> zmq-xpub-xsub --debug

Example of usage

1. Install and configure ZeroMq.
2. Start zmq-xpub-xsub lib
3. Example below illustrate usage of xpub/xsub application as a messaging hub.

// Not required! used for example only
const zmq = require('zmq'); //https://github.com/JustinTulloss/zeromq.node

const options = {
  baseAddress: 'tcp://127.0.0.1',
  xSubPort: 8000,
  xPubPort: 8001
}

// Subscriber
const subscriber = zmq.socket('sub');
subscriber.connect(`${options.baseAddress}:${options.xPubPort}`);

subscriber.on('message', (key, message) => {
  console.log('Message is recived:', key, message);
}));

// Publisher
const publisher = zmq.socket('pub');
publisher.connect(`${options.baseAddress}:${options.xSubPort}`);

publisher.send(['key', 'message'])