controller.py 文件源码

def __init__(self, cfg, target=None, args=[]):
        (self.target,self.args) = (target,args)

        # Set up server socket
        self.context = zmq.Context()
        self.socket = self.context.socket(zmq.ROUTER)
        self.port = self.socket.bind_to_random_port('tcp://*', min_port=cfg["port_min"], max_port=cfg["port_max"], max_tries=100)
        self.uri = "tcp://127.0.0.1:%d"%(self.port)
        print "Controller listening on %s"%(self.uri)

        self.start()