matplotlib-client.py 文件源码

def __init__(self, host, port=7772):
        QtCore.QObject.__init__(self)

        self.context = zmq.Context()
        self.socket = self.context.socket(zmq.SUB)
        self.socket.connect("tcp://{}:{}".format(host, port))
        self.socket.setsockopt_string(zmq.SUBSCRIBE, "data")
        self.socket.setsockopt_string(zmq.SUBSCRIBE, "done")
        self.poller = zmq.Poller()
        self.poller.register(self.socket, zmq.POLLIN)
        self.running = True