From d534b71782e55c0d5d63da74fe3a3719faf86987 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 10 八月 2023 17:47:33 +0800
Subject: [PATCH] 华鑫托管改造初步设计
---
main.py | 29 ++++++++++++++++++++++-------
1 files changed, 22 insertions(+), 7 deletions(-)
diff --git a/main.py b/main.py
index b888810..23bea13 100644
--- a/main.py
+++ b/main.py
@@ -12,9 +12,10 @@
# 浜ゆ槗鏈嶅姟
from third_data import data_server
from trade.huaxin import trade_server, trade_api_server
+import huaxin
-def createTradeServer(pipe):
+def createTradeServer(pipe_server, pipe_trade, pipe_l1):
# 鍒濆鍖栧弬鏁�
global_data_loader.init()
@@ -23,15 +24,15 @@
t1.start()
# 浜ゆ槗鎺ュ彛鏈嶅姟
- t1 = threading.Thread(target=trade_api_server.run, args=(pipe,), daemon=True)
+ t1 = threading.Thread(target=trade_api_server.run, args=(pipe_server,), daemon=True)
t1.start()
# redis鍚庡彴鏈嶅姟
- t1 = threading.Thread(target=redis_manager.RedisUtils.run_loop, daemon=True)
+ t1 = threading.Thread(target=redis_manager.RedisUtils.run_loop, daemon=True)
t1.start()
# 浜ゆ槗鏈嶅姟
- trade_server.run()
+ trade_server.run(pipe_trade, pipe_l1)
# 涓绘湇鍔�
@@ -50,9 +51,23 @@
if __name__ == '__main__':
- pipe_server, pipe_trade = multiprocessing.Pipe()
+ # 绛栫暐涓巗erver闂寸殑閫氫俊
+ pss_server, pss_strategy = multiprocessing.Pipe()
+ # 绛栫暐涓庝氦鏄撻棿鐨勯�氫俊
+ pst_trade, pst_strategy = multiprocessing.Pipe()
+ # 浜ゆ槗涓巐2涔嬮棿鐨勯�氫俊
+ ptl2_trade, ptl2_l2 = multiprocessing.Pipe()
+ # l1涓巘rade闂寸殑閫氫俊
+ pl1t_l1, pl1t_trade = multiprocessing.Pipe()
+
logger_l2_process_time.info("娴嬭瘯123")
- serverProcess = multiprocessing.Process(target=createServer, args=(pipe_server,))
+ serverProcess = multiprocessing.Process(target=createServer, args=(pss_server,))
serverProcess.start()
# 灏唗radeServer浣滀负涓昏繘绋�
- createTradeServer(pipe_trade)
+ createTradeServer(pss_strategy, pst_strategy, pl1t_trade)
+
+ tradeProcess = multiprocessing.Process(target=huaxin.trade_client.run, args=(ptl2_trade, pst_trade))
+ l2Process = multiprocessing.Process(target=huaxin.l2_client.run, args=(ptl2_l2,))
+ tradeProcess.start()
+ l2Process.start()
+ huaxin.l1_client.run_async(pl1t_l1)
--
Gitblit v1.8.0