From 2324df309e160a0e47992718ccdb37271ccee05f Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 07 七月 2023 14:24:36 +0800
Subject: [PATCH] 华鑫适配
---
main.py | 34 +++-------------------------------
1 files changed, 3 insertions(+), 31 deletions(-)
diff --git a/main.py b/main.py
index 369b7fc..41d7fdb 100644
--- a/main.py
+++ b/main.py
@@ -11,25 +11,6 @@
import l2.l2_data_util
-def __read_server_pipe(pipe):
- if pipe:
- while True:
- value = pipe.recv()
- if value is not None:
- value = json.loads(value)
- if value.get("type") == "clear_l2":
- code = value["data"]["code"]
- print("娓呴櫎l2鏁版嵁", code)
- if len(code) != 6:
- continue
- l2_data_manager.clear_l2_data(code)
- # 鍒犻櫎level2鐨勬暟鎹�
- if l2.l2_data_util.local_today_datas and code in l2.l2_data_util.local_today_datas:
- l2.l2_data_util.local_today_datas.pop(code)
- if l2.l2_data_util.local_latest_datas and code in l2.l2_data_util.local_latest_datas:
- l2.l2_data_util.local_latest_datas.pop(code)
-
- time.sleep(0.1)
# 浜ゆ槗鏈嶅姟
@@ -45,14 +26,10 @@
# 涓绘湇鍔�
-def createServer(pipe_juejin, pipe_gui):
+def createServer():
print("create Server")
-
- t1 = threading.Thread(target=lambda: __read_server_pipe(pipe_gui), daemon=True)
- t1.start()
-
laddr = "", 9001
- tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle, pipe_juejin=pipe_juejin) # 娉ㄦ剰锛氬弬鏁版槸MyBaseRequestHandle
+ tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle, pipe_juejin=None) # 娉ㄦ剰锛氬弬鏁版槸MyBaseRequestHandle
# tcpserver.handle_request() # 鍙帴鍙椾竴涓鎴风杩炴帴
tcpserver.serve_forever() # 姘镐箙寰幆鎵ц,鍙互鎺ュ彈澶氫釜瀹㈡埛绔繛鎺�
@@ -64,12 +41,7 @@
if __name__ == '__main__':
- # tradeServerProcess = multiprocessing.Process(target=createTradeServer)
- serverProcess = multiprocessing.Process(target=createServer, args=(None, None,))
- jueJinTradeProcess = multiprocessing.Process(target=trade_juejin.run)
-
- # tradeServerProcess.start()
+ serverProcess = multiprocessing.Process(target=createServer)
serverProcess.start()
- jueJinTradeProcess.start()
# 灏唗radeServer浣滀负涓昏繘绋�
createTradeServer()
--
Gitblit v1.8.0