client.py 文件源码

def __init__(self, timeout,max_msg_count,msg,connect_num,dst_addr):
        import logger, tcp_client
        self.logger = logger.Logger()
        self.tcp_client = tcp_client.TcpClient(timeout, self.logger)
        self.tcp_client.set_app_data_callback(self.on_app_data)
        self.io_thread = threading.Thread(target=self.io_thread_func)
        self.io_thread.setDaemon(True)
        self.io_thread.start()


        self._max_msg_count=max_msg_count#?????????
        self._msg=msg
        self._connect_num=connect_num
        self._dst_addr=dst_addr

        self.start_time = 0#???????
        self.end_time = 0  # ??????

        self.recv_bytes=0#??????
        self.recv_msg_count=0