From 287c506725b2d970f721f80169f83c2418cb0991 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 04 六月 2025 18:39:02 +0800
Subject: [PATCH] 添加新版低吸中间服务器
---
main.py | 19 +++++--------------
1 files changed, 5 insertions(+), 14 deletions(-)
diff --git a/main.py b/main.py
index b98d5a8..2826191 100644
--- a/main.py
+++ b/main.py
@@ -5,13 +5,12 @@
import data_server
import middle_api_server
import middle_cb_api_server
+import middle_ls_api_server
import middle_server
-# from huaxin_client import huaxin_trade_client
-# from trade import huaxin_trade_api
-# from huaxin_client import huaxin_trade_client
from log_module import async_log_util
-# from trade import huaxin_trade_api
+# cd /usr/local/middle_server_source/gp-server
+# PYTHONPATH=../../gp_server_source/lib python3 main.py
if __name__ == "__main__":
t1 = threading.Thread(target=lambda: middle_api_server.run(), daemon=True)
t1.start()
@@ -24,17 +23,9 @@
# 鍙浆鍊篈PI绔彛涓�13008
t1 = threading.Thread(target=lambda: middle_cb_api_server.run(13008), daemon=True)
t1.start()
+ t1 = threading.Thread(target=lambda: middle_ls_api_server.run(14008), daemon=True)
+ t1.start()
# t1 = threading.Thread(target=lambda: middle_l1_data_server.run(12881), daemon=True)
# t1.start()
-
- # 杩愯浠跨湡浜ゆ槗
- # queue_strategy_r_trade_w, queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query = multiprocessing.Queue(), multiprocessing.Queue(), multiprocessing.Queue()
- # huaxin_trade_api.run_trade(queue_strategy_r_trade_w, queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query)
-
- # ===========杩愯浜ゆ槗绔�==========
- # tradeProcess = multiprocessing.Process(
- # target=huaxin_trade_client.run,
- # args=(queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query, queue_strategy_r_trade_w,))
- # tradeProcess.start()
middle_server.run()
--
Gitblit v1.8.0