Basic pyzmq client/server

client.py

from datetime import datetime
import os
import sys
import time

import zmq


port = int(sys.argv[1])
n = int(sys.argv[2])

context = zmq.Context()
socket = context.socket(zmq.REQ)
socket.connect('tcp://localhost:{}'.format(port))

for i in range(n):
    time.sleep(1)
    socket.send_json([os.getpid(), i, n])
    message = socket.recv_json()
    print(datetime.now(), message)
    time.sleep(1)

server.py

import sys
from datetime import datetime
from itertools import count

import zmq


data = count()


def handle(message):
    return (message, next(data))


if __name__ == '__main__':

    port = int(sys.argv[1])

    context = zmq.Context()
    socket = context.socket(zmq.REP)
    socket.bind('tcp://*:{}'.format(port))

    while True:
        message = socket.recv_json()
        print(datetime.now(), message)
        response = handle(message)
        socket.send_json(response)