added new device examples

barnabyc · Mar 15, 2012 · 157e420 · 157e420
1 parent 1be1295
commit 157e420
Show file tree

Hide file tree

Showing 3 changed files with 217 additions and 0 deletions.
diff --git a/examples/devices/forwarder.js b/examples/devices/forwarder.js
@@ -0,0 +1,70 @@
+/*
+ *
+ * Forwarder device
+ *
+ */
+
+var cluster = require('cluster'),
+    zeromq = require('zmq'),
+    frontPort = 'tcp://127.0.0.1:12345',
+    backPort = 'tcp://127.0.0.1:12346';
+
+function createClient (port) {
+    var socket = zeromq.socket('pub');
+
+    socket.identity = 'client' + process.pid;
+
+    socket.connect(port);
+    console.log('client connected!');
+
+    setInterval(function() {
+        var value = Math.floor(Math.random()*100);
+
+        console.log(socket.identity + ': broadcasting ' + value);
+        socket.send(value);
+    }, 100);
+};
+
+function createWorker (port) {
+    var socket = zeromq.socket('sub');
+
+    socket.identity = 'worker' + process.pid;
+
+    socket.subscribe('');
+    socket.on('message', function(data) {
+        console.log(socket.identity + ': got ' + data.toString());
+    });
+
+    socket.connect(port, function(err) {
+        if (err) throw err;
+        console.log('worker connected!');
+    });
+};
+
+function createForwarderDevice(frontPort, backPort) {
+    var frontSocket = zeromq.socket('sub'),
+        backSocket = zeromq.socket('pub');
+
+    frontSocket.identity = 'sub' + process.pid;
+    backSocket.identity = 'pub' + process.pid;
+
+    frontSocket.subscribe('');
+    frontSocket.bind(frontPort, function (err) {
+        console.log('bound', frontPort);
+    });
+
+    frontSocket.on('message', function() {
+        //pass to back
+        console.log('forwarder: recasting', arguments[0].toString());
+        backSocket.send(Array.prototype.slice.call(arguments));
+    });
+
+    backSocket.bind(backPort, function (err) {
+        console.log('bound', backPort);
+    });
+}
+
+createForwarderDevice(frontPort, backPort);
+
+createClient(frontPort);
+createWorker(backPort);   
diff --git a/examples/devices/queue.js b/examples/devices/queue.js
@@ -0,0 +1,79 @@
+/*
+ *
+ * Queue device
+ *
+ */
+
+var cluster = require('cluster'),
+    zeromq = require('zmq'),
+    frontPort = 'tcp://127.0.0.1:12345',
+    backPort = 'tcp://127.0.0.1:12346';
+
+function createClient (port) {
+    var socket = zeromq.socket('req');
+
+    socket.identity = 'client' + process.pid;
+
+    socket.on('message', function(data) {
+        console.log(socket.identity + ': answer data ' + data);
+    });
+
+    socket.connect(port);
+    console.log('client connected!');
+
+    setInterval(function() {
+        var value = Math.floor(Math.random()*100);
+
+        console.log(socket.identity + ': asking ' + value);
+        socket.send(value);
+    }, 100);
+};
+
+function createServer (port) {
+    var socket = zeromq.socket('rep');
+
+    socket.identity = 'server' + process.pid;
+
+    socket.on('message', function(data) {
+        console.log(socket.identity + ': received ' + data.toString());
+        socket.send(data * 2);
+    });
+
+    socket.connect(port, function(err) {
+        if (err) throw err;
+        console.log('server connected!');
+    });
+};
+
+function createQueueDevice(frontPort, backPort) {
+    var frontSocket = zeromq.socket('router'),
+        backSocket = zeromq.socket('dealer');
+
+    frontSocket.identity = 'router' + process.pid;
+    backSocket.identity = 'dealer' + process.pid;
+
+    frontSocket.bind(frontPort, function (err) {
+        console.log('bound', frontPort);
+    });
+
+    frontSocket.on('message', function() {
+        //pass to back
+        console.log('router: sending to server', arguments[0].toString(), arguments[2].toString());
+        backSocket.send(Array.prototype.slice.call(arguments));
+    });
+
+    backSocket.bind(backPort, function (err) {
+        console.log('bound', backPort);
+    });
+
+    backSocket.on('message', function() {
+        //pass to front
+        console.log('dealer: sending to client', arguments[0].toString(), arguments[2].toString());
+        frontSocket.send(Array.prototype.slice.call(arguments));
+    });
+}
+
+createQueueDevice(frontPort, backPort);
+
+createClient(frontPort);
+createServer(backPort);   
diff --git a/examples/devices/streamer.js b/examples/devices/streamer.js
@@ -0,0 +1,68 @@
+/*
+ *
+ * Forwarder device
+ *
+ */
+
+var cluster = require('cluster'),
+    zeromq = require('zmq'),
+    frontPort = 'tcp://127.0.0.1:12345',
+    backPort = 'tcp://127.0.0.1:12346';
+
+function createClient (port) {
+    var socket = zeromq.socket('push');
+
+    socket.identity = 'client' + process.pid;
+
+    socket.connect(port);
+    console.log('client connected!');
+
+    setInterval(function() {
+        var value = Math.floor(Math.random()*100);
+
+        console.log(socket.identity + ': pushing ' + value);
+        socket.send(value);
+    }, 100);
+};
+
+function createWorker (port) {
+    var socket = zeromq.socket('pull');
+
+    socket.identity = 'worker' + process.pid;
+
+    socket.on('message', function(data) {
+        console.log(socket.identity + ': pulled ' + data.toString());
+    });
+
+    socket.connect(port, function(err) {
+        if (err) throw err;
+        console.log('worker connected!');
+    });
+};
+
+function createStreamerDevice(frontPort, backPort) {
+    var frontSocket = zeromq.socket('pull'),
+        backSocket = zeromq.socket('push');
+
+    frontSocket.identity = 'sub' + process.pid;
+    backSocket.identity = 'pub' + process.pid;
+
+    frontSocket.bind(frontPort, function (err) {
+        console.log('bound', frontPort);
+    });
+
+    frontSocket.on('message', function() {
+        //pass to back
+        console.log('forwarder: sending downstream', arguments[0].toString());
+        backSocket.send(Array.prototype.slice.call(arguments));
+    });
+
+    backSocket.bind(backPort, function (err) {
+        console.log('bound', backPort);
+    });
+}
+
+createStreamerDevice(frontPort, backPort);
+
+createClient(frontPort);
+createWorker(backPort);