Example of Request Reply with zmq

zmq_client.py

import zmq
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect("tcp://127.0.0.1:5000")

for i in range(10):
    msg = "msg %s" % i
    socket.send(msg)
    print "Sending", msg
    msg_in = socket.recv()

zmq_server.py

import time
import zmq
import sys

context = zmq.Context()
socket = context.socket(zmq.REP)
socket.bind("tcp://127.0.0.1:5000")
print("Listening for incoming messages.")

while True:
    msg = socket.recv()
    print("Processing %s" % msg, end='')
    for i in range(5):
        time.sleep(1)
        print(".", end='')
        sys.stdout.flush()
    print('')
    sys.stdout.flush()
    socket.send(msg)