| | |
|---|
| | | "data": datas, |
|---|
| | | "request_id": f"{ClientSocketManager.CLIENT_TYPE_CMD_L2}_{round(time.time() * 1000)}"} |
|---|
| | | # root_data = socket_util.encryp_client_params_sign(root_data) |
|---|
| | | # pipe_l2.send(json.dumps(root_data)) |
|---|
| | | pipe_l2.send(f"{time.time()}") |
|---|
| | | pipe_l2.send(json.dumps(root_data)) |
|---|
| | | # pipe_l2.send(f"{time.time()}") |
|---|
| | | print("向L2发送数据") |
|---|
| | | |
|---|
| | | except Exception as e: |
|---|
| | |
|---|
| | | print("create TradeApiServer") |
|---|
| | | # 拉取交易信息 |
|---|
| | | huaxin_trade_data_update.run() |
|---|
| | | |
|---|
| | | t1 = threading.Thread(target=lambda: __set_target_codes(pipe_l2), daemon=True) |
|---|
| | | t1.start() |
|---|
| | | # |
|---|
| | | # t1 = threading.Thread(target=lambda: __set_target_codes(pipe_l2), daemon=True) |
|---|
| | | # t1.start() |
|---|
| | | |
|---|
| | | t1 = threading.Thread(target=lambda: __read_sync_task(pipe_server), daemon=True) |
|---|
| | | t1.start() |
|---|
| | | |
|---|
| | | __set_target_codes(pipe_l2) |
|---|
| | | |
|---|
| | | # 托管环境下不开启接口 |
|---|
| | | # laddr = "0.0.0.0", 10009 |
|---|
| | | # tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle) # 注意：参数是MyBaseRequestHandle |
|---|
