From ca310f014336d93eba73ed5010c1c5645424a1e0 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 04 八月 2023 16:06:28 +0800
Subject: [PATCH] 交易优化
---
command_manager.py | 6 ++++--
1 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/command_manager.py b/command_manager.py
index e67f0fa..20f8a7d 100644
--- a/command_manager.py
+++ b/command_manager.py
@@ -88,6 +88,7 @@
# 鍙戦�佸績璺�
cls.__heartbeats_thread(type, key, sk)
cls.__listen_command_thread(type, key, sk)
+ print("create_and_run_client success",type,key)
return key, sk
@classmethod
@@ -162,6 +163,7 @@
if _type == CLIENT_TYPE_TRADE:
if client_id in cls.trade_client_dict:
cls.trade_client_dict.pop(client_id)
+ print("pop trade client", client_id)
elif _type == CLIENT_TYPE_MONEY:
cls.money_client = None
elif _type == CLIENT_TYPE_DEAL_LIST:
@@ -185,7 +187,7 @@
json.dumps({"type": "heart", "client_id": client_id}).encode('utf-8')))
# print("蹇冭烦淇℃伅鍙戦�佹垚鍔�", client_id)
except Exception as e:
- print("蹇冭烦淇℃伅鍙戦�佸け璐�")
+ print("蹇冭烦淇℃伅鍙戦�佸け璐�",_type,client_id)
logging.exception(e)
if _type == CLIENT_TYPE_TRADE:
if client_id in cls.trade_client_dict:
@@ -223,7 +225,7 @@
while True:
try:
if len(cls.trade_client_dict) < cls.trade_client_count:
- print("__maintain_client", CLIENT_TYPE_TRADE)
+ print("__maintain_client", CLIENT_TYPE_TRADE, cls.trade_client_count - len(cls.trade_client_dict))
for i in range(cls.trade_client_count - len(cls.trade_client_dict)):
result = cls.__create_and_run_client(CLIENT_TYPE_TRADE)
cls.trade_client_dict[result[0]] = result[1]
--
Gitblit v1.8.0