initial commit

Author: codecraf8

.gitignore

@@ -0,0 +1 @@
+*.pyc

README.md

@@ -0,0 +1,13 @@
+#### 1. Build the publisher first
+
+sudo docker build -t docker-zmq-pub .
+docker run --name docker-pub-server -p 5000:5000 -p 4444:4444 -t docker-zmq-pub
+
+#### 2. Run the Client
+
+python zmqclient.py
+
+Make a request to localhost:5000/downcase/?Param=Hello
+
+Messages from publisher will start to get recorded in the client.
+Additonally if the client runs as a daemon, it logs to a file called sibscriber.log

client/zmqclient.py

@@ -0,0 +1,38 @@
+# client.py
+import zmq
+import sys
+import time
+import logging
+import os
+
+HOST = '127.0.0.1'
+PORT = '4444'
+
+logging.basicConfig(filename='subscriber.log', level=logging.INFO)
+
+
+class ZClient(object):
+
+    def __init__(self, host=HOST, port=PORT):
+        """Initialize Worker"""
+        self.host = host
+        self.port = port
+        self._context = zmq.Context()
+        self._subscriber = self._context.socket(zmq.SUB)
+        print "Client Initiated"
+
+    def receive_message(self):
+        """Start receiving messages"""
+        self._subscriber.connect('tcp://{}:{}'.format(self.host, self.port))
+        self._subscriber.setsockopt(zmq.SUBSCRIBE, b"")
+
+        while True:
+            print 'listening on tcp://{}:{}'.format(self.host, self.port)
+            message = self._subscriber.recv()
+            print message
+            logging.info(
+                '{}   - {}'.format(message, time.strftime("%Y-%m-%d %H:%M")))
+
+if __name__ == '__main__':
+    zs = ZClient()
+    zs.receive_message()

server/Dockerfile

@@ -0,0 +1,19 @@
+FROM ubuntu:14.04
+
+RUN apt-get update
+RUN apt-get install -y --force-yes python python-dev python-setuptools software-properties-common gcc python-pip
+RUN apt-get clean all
+
+RUN pip install pyzmq
+
+RUN pip install Flask
+
+ADD zmqserver.py /tmp/zmqserver.py
+
+# Flask Port
+EXPOSE 5000
+
+# Zmq Sub Server
+EXPOSE 4444
+
+CMD ["python","/tmp/zmqserver.py"]

server/pub_server.py

@@ -0,0 +1,21 @@
+import zmq
+import random
+import sys
+import time
+
+port = "4444"
+
+if len(sys.argv) > 1:
+    port = sys.argv[1]
+    int(port)
+
+context = zmq.Context()
+socket = context.socket(zmq.PUB)
+socket.bind("tcp://*:%s" % port)
+
+while True:
+    topic = random.randrange(9999, 10005)
+    messagedata = random.randrange(1, 215) - 80
+    print "%d %d" % (topic, messagedata)
+    socket.send("%d %d" % (topic, messagedata))
+    time.sleep(1)

server/zmqserver.py

@@ -0,0 +1,43 @@
+# server.py
+import time
+import zmq
+
+HOST = '127.0.0.1'
+PORT = '4444'
+
+_context = zmq.Context()
+_publisher = _context.socket(zmq.PUB)
+url = 'tcp://{}:{}'.format(HOST, PORT)
+
+
+def publish_message(message):
+
+    try:
+        _publisher.bind(url)
+        time.sleep(1)
+        print "sending message : {0}".format(message, _publisher)
+        _publisher.send(message)
+
+    except Exception as e:
+        print "error {0}".format(e)
+
+    finally:
+        print "unbinding"
+        _publisher.unbind(url)
+
+
+from flask import Flask
+from flask import request
+app = Flask(__name__)
+
+
+@app.route("/downcase/", methods=['GET'])
+def lowerString():
+
+    _strn = request.args.get('param')
+    response = 'lower case of {} is {}'.format(_strn, _strn.lower())
+    publish_message(response)
+    return response
+
+if __name__ == '__main__':
+    app.run(host='0.0.0.0', debug=False)