| | |
| | | import time |
| | | |
| | | import constant |
| | | import log |
| | | import socket_manager |
| | | from db import mysql_data |
| | | from db.redis_manager import RedisUtils, RedisManager |
| | |
| | | {"code": 100, "msg": f"JSON解析失败"}).encode( |
| | | encoding='utf-8'))) |
| | | continue |
| | | thread_id = random.randint(0, 1000000) |
| | | logger_request_debug.info(f"middle_server 请求开始({thread_id}):{data_json.get('type')}") |
| | | type_= data_json["type"] |
| | | log.request_info("middle_server", f"请求开始:{type_}") |
| | | try: |
| | | if data_json["type"] == 'register': |
| | | client_type = data_json["data"]["client_type"] |
| | |
| | | sk.sendall(socket_util.load_header(result_str.encode(encoding='utf-8'))) |
| | | pass |
| | | finally: |
| | | logger_request_debug.info(f"middle_server 请求结束({thread_id}):{data_json.get('type')}") |
| | | log.request_info("middle_server", f"请求结束") |
| | | |
| | | else: |
| | | # 断开连接 |
| | | break |