| | |
|---|
| | | print("L2客户端接受到数据") |
|---|
| | | data = json.loads(val) |
|---|
| | | if data["type"] == "l2_cmd": |
|---|
| | | data = data["data"] |
|---|
| | | # data = data["data"] |
|---|
| | | l2CommandManager.process_command(command_manager.CLIENT_TYPE_CMD_L2, None, data) |
|---|
| | | except Exception as e: |
|---|
| | | logging.exception(e) |
|---|
| | |
|---|
| | | root_data = {"type": ClientSocketManager.CLIENT_TYPE_CMD_L2, |
|---|
| | | "data": datas, |
|---|
| | | "request_id": f"{ClientSocketManager.CLIENT_TYPE_CMD_L2}_{round(time.time() * 1000)}"} |
|---|
| | | # root_data = socket_util.encryp_client_params_sign(root_data) |
|---|
| | | root_data = socket_util.encryp_client_params_sign(root_data) |
|---|
| | | pipe_l2.send(json.dumps(root_data)) |
|---|
| | | # pipe_l2.send(f"{time.time()}") |
|---|
| | | print("向L2发送数据") |
|---|
| | | |
|---|
| | | except Exception as e: |
|---|
