redis_sampler_server_starter.py 文件源码

def __init__(self, host="localhost", port=6379):
        conn = psutil.net_connections()
        ports = [c.laddr[1] for c in conn]
        port = max(ports) + 1
        self.__port = port
        self.__redis_server = Popen(["redis-server", "--port", str(port)])
        sleep(1)
        self.__worker = [
            Process(target=work,
                    args=(["--host", "localhost", "--port", str(port)],),
                    daemon=False)
            for _ in range(2)
        ]
        for p in self.__worker:
            p.start()
        super().__init__(host, port)