agents.py 文件源码

def sub_task(self, name, ip_port_sub):
        if (ip_port_sub == "0"):
            return
        ctx = zmq.Context()
        # subscribe socket
        socket_sub = ctx.socket(zmq.SUB)
        socket_sub.connect("tcp://%s" % ip_port_sub)
        socket_sub.setsockopt(zmq.SUBSCRIBE, '')
        total_value = 0
        self.sub_msg_cnt = 0
        while not self.shutdown:
            string = socket_sub.recv()
            topic, messageData = string.split()
            total_value += int(messageData)
            self.sub_msg_cnt += 1
            print("SUB:: [%d] %s %s" % (self.sub_msg_cnt, topic, messageData))