__init__.py 文件源码

def start(ip_address='127.0.0.1', port=5555):
    """
    Connect to master node and each one second send data.
    """
    context = zmq.Context()
    socket = context.socket(zmq.PUB)
    socket.connect("tcp://%s:%s" % (ip_address, port))
    socket.sndhwm = 1
    handler_signal_keyboard(socket, context)

    process_send_data(socket, context)