Cliente básico con pyzmq

zmq_client_1.py

# -*- coding: utf-8 -*-

import logging
import zmq


def main():
    logging.basicConfig(level=logging.INFO)
    msg = {'un': 'dict'}

    context = zmq.Context()
    zocket = context.socket(zmq.REQ)
    zocket.connect("tcp://127.0.0.1:12345")

    # Enviamos msg
    logging.info("Enviando msg: %r", msg)
    
    # Si el servidor está andando y recibe el mensaje,
    #    este método se ejecuta inmediatamente.
    # Si el servidor NO está andando, este método bloquea hasta
    #    que el servidor recibe el mensaje
    zocket.send_pyobj(msg)
    
    # Esperamos respuesta
    logging.info("Esperando respuesta...")
    msg_in = zocket.recv_pyobj()
    logging.info("Mensaje recivido: %r", msg_in)


if __name__ == '__main__':
    main()