From b874fdb322d0740838f73e5ed260f800bf43ad1a Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 22 三月 2024 15:51:57 +0800
Subject: [PATCH] 增加外部端口
---
middle_server.py | 13 ++++++++-----
1 files changed, 8 insertions(+), 5 deletions(-)
diff --git a/middle_server.py b/middle_server.py
index cdfc913..cd761a7 100644
--- a/middle_server.py
+++ b/middle_server.py
@@ -97,7 +97,7 @@
encoding='utf-8')))
continue
type_ = data_json["type"]
- log.request_info("middle_server", f"璇锋眰寮�濮嬶細{type_}")
+ __start_time = time.time()
try:
if data_json["type"] == 'register':
client_type = data_json["data"]["client_type"]
@@ -285,14 +285,17 @@
push_msg_manager.push_msg(_type, data)
result_str = json.dumps({"code": 0, "data": {}})
sk.sendall(socket_util.load_header(result_str.encode(encoding='utf-8')))
+ except Exception as e:
+ log.logger_tuoguan_request_debug.exception(e)
finally:
- log.request_info("middle_server", f"璇锋眰缁撴潫")
-
+ if time.time() - __start_time > 2:
+ log.logger_tuoguan_request_debug.info(f"鑰楁椂锛歿int(time.time() - __start_time)}s 鏁版嵁锛歿data_json}")
else:
# 鏂紑杩炴帴
break
# sk.close()
except Exception as e:
+ # log.logger_tuoguan_request_debug.exception(e)
logging.exception(e)
break
@@ -323,12 +326,12 @@
pass
-def run():
+def run(port = constant.MIDDLE_SERVER_PORT):
print("create MiddleServer")
t1 = threading.Thread(target=lambda: clear_invalid_client(), daemon=True)
t1.start()
- laddr = "0.0.0.0", constant.MIDDLE_SERVER_PORT
+ laddr = "0.0.0.0", port
print("MiddleServer is at: http://%s:%d/" % (laddr))
tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle) # 娉ㄦ剰锛氬弬鏁版槸MyBaseRequestHandle
tcpserver.serve_forever()
--
Gitblit v1.8.0