admin
2024-01-08 b4ff4ac715060ce313cdaee2345617b4b7a979ea
middle_server.py
@@ -9,6 +9,7 @@
import time
import constant
import log
import socket_manager
from db import mysql_data
from db.redis_manager import RedisUtils, RedisManager
@@ -93,8 +94,8 @@
                            {"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"]
@@ -261,7 +262,8 @@
                            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