From 46f51dfb83f6e6a2784676bde64577e5f6f28cf0 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 11 三月 2025 14:31:34 +0800
Subject: [PATCH] 新版L2订阅/L2成交处理时间日志
---
main.py | 16 +++++++++++++++-
1 files changed, 15 insertions(+), 1 deletions(-)
diff --git a/main.py b/main.py
index 0b6dc33..6f762ee 100644
--- a/main.py
+++ b/main.py
@@ -7,6 +7,7 @@
import constant
from code_attribute import gpcode_manager
+from l2.subscript import l2_subscript_manager
from log_module import log
from log_module.log import logger_l2_trade, logger_system
import logging
@@ -100,6 +101,11 @@
# ======鍒嗙粍======
# 璁板綍姣忎釜鍒嗙粍鐨勬暟閲�
channel_count_list = []
+ # 鏁版嵁鍥炶皟闃熷垪
+ data_callback_queue_list = []
+ # 娑堟伅浼犻�掗槦鍒�
+ sub_single_queue_list = []
+
for i in range(l2_process_count):
channel_count = base_channel_count + (1 if i < left_count else 0)
channel_count_list.append(channel_count)
@@ -108,10 +114,18 @@
index += channel_count
# 璁㈤槄淇″彿闃熷垪, 鏁版嵁鍥炶皟闃熷垪锛堝洖璋冮娆″皬鐨勬暟鎹�氳繃杩欑鍥炶皟锛�
sub_single_queue, data_callback_queue = multiprocessing.Queue(), multiprocessing.Queue()
+ sub_single_queue_list.append(sub_single_queue)
+ data_callback_queue_list.append(data_callback_queue)
l2_process = multiprocessing.Process(target=l2_client_v2.run,
- args=(sub_single_queue, data_callback_queue, channels,))
+ args=(sub_single_queue, data_callback_queue, channels, i, ))
l2_process.start()
+ l2_subscript_manager.process_manager = l2_subscript_manager.TargetCodeProcessManager(sub_single_queue_list, channel_count_list)
+ # 鐩戝惉L2甯傚満琛屾儏鏁版嵁
+ huaxin_trade_server.run_l2_market_info_reciever(data_callback_queue_list)
+ # 鍚姩ZMQserver锛岄拡瀵瑰鎵橀槦鍒椾笌鎴愪氦闃熷垪杩涜鐩戝惉
+ l2_subscript_manager.L2DataListener(channel_list).create_data_listener(huaxin_trade_server.my_l2_data_callback)
+
if __name__ == '__main__':
# 鍙粦瀹�16-31涔嬮棿鐨勬牳
--
Gitblit v1.8.0