mw_graphs_qt.py 文件源码

def _data_listener(self):
        if len(sys.argv) > 1:
            for l in open(sys.argv[1]).readlines():
                QtCore.QMetaObject.invokeMethod(
                    self, "_on_server_message",
                    QtCore.Qt.QueuedConnection,
                    QtCore.Q_ARG(dict, json.loads(l)))

        port = 9876
        context = zmq.Context()
        socket = context.socket(zmq.SUB)

        socket.connect ("tcp://localhost:%d" % port)
        socket.setsockopt(zmq.SUBSCRIBE, '')
        while True:
            msg = socket.recv_json()
            try:
                QtCore.QMetaObject.invokeMethod(
                    self, "_on_server_message",
                    QtCore.Qt.QueuedConnection,
                    QtCore.Q_ARG(dict, msg))
            except AttributeError:
                pass