Server ZeroMQ + pyzmq

zmq_server.py

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

import logging
import zmq


def main():
    logging.basicConfig(level=logging.INFO)
    
    # Creamos contexto de ZeroMQ
    ctx = zmq.Context()
    
    # Creamos un "socket"
    zocket = ctx.socket(zmq.REP)
    zocket.bind("tcp://0.0.0.0:12345")

    while True:
        # Esperamos request (bloquea hasta que recivimos uno)
        logging.info("Esperando mensaje...")
        
        # Y obtenemos el mensaje como un objeto Python
        msg = zocket.recv_pyobj()
        
        # Hacemos algo con request
        logging.info("Msg recibido: %r", msg)
        
        # Y enviamos respuesta
        zocket.send_pyobj({'status': 'ok'})

if __name__ == '__main__':
    main()