ZMQStream with multiprocessing.

gistfile1.py

from multiprocessing import Process

import zmq, random

from zmq.eventloop import ioloop, zmqstream
ioloop.install()

def child(port, i):
    def on_message(message):
        print message

    def send():
        stream.send("Message from %i" % i)

    context = zmq.Context()
    loop = ioloop.IOLoop()

    socket = context.socket(zmq.PAIR)
    socket.connect("tcp://127.0.0.1:%d" % port)
    stream = zmqstream.ZMQStream(socket, loop)
    stream.on_recv(on_message)

    ioloop.PeriodicCallback(send, random.randint(750, 1500), loop).start()

    loop.start()

def parent():
    def on_message(message, stream):
        print message
        stream.send("ACK")

    context = zmq.Context()
    loop = ioloop.IOLoop()

    for i in xrange(10):
        port = random.randint(4000, 40000)
        
        socket = context.socket(zmq.PAIR)
        socket.bind("tcp://127.0.0.1:%d" % port)
        stream = zmqstream.ZMQStream(socket, loop)
        stream.on_recv(lambda x: on_message(x, stream))

        p = Process(target=child, args=(port, i))
        p.start()

    loop.start()

if __name__ == "__main__":
    parent()