| | |
|---|
| | | if val: |
|---|
| | | print("L2客户端接受到数据") |
|---|
| | | data = json.loads(val) |
|---|
| | | if data["type"] == "l2_cmd": |
|---|
| | | if data["data"]["type"] == "l2_cmd": |
|---|
| | | # data = data["data"] |
|---|
| | | l2CommandManager.process_command(command_manager.CLIENT_TYPE_CMD_L2, None, data) |
|---|
| | | except Exception as e: |
|---|
| | |
|---|
| | | while True: |
|---|
| | | try: |
|---|
| | | datas = test_data |
|---|
| | | root_data = {"type": ClientSocketManager.CLIENT_TYPE_CMD_L2, |
|---|
| | | "data": datas, |
|---|
| | | root_data = {"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) |
|---|
| | | pipe_l2.send(json.dumps(root_data)) |
|---|
