改变目录

Administrator

2023-08-21 a019311b0edee6df82a8ec7c0b28b06b22aa4d31

 main.py

@@ -7,9 +7,9 @@
import sys

from db import redis_manager_delegate as redis_manager
import huaxin_api.trade_client
import huaxin_api.l2_client
import huaxin_api.l1_client
import huaxin_client.trade_client
import huaxin_client.l2_client
import huaxin_client.l1_client
from log_module import log
from log_module.log import logger_l2_trade, logger_system, logger_local_huaxin_l1

@@ -86,13 +86,13 @@

    # 交易进程与L2进程

    l2Process = multiprocessing.Process(target=huaxin_api.l2_client.run, args=(ptl2_l2, psl2_l2,))
    l2Process = multiprocessing.Process(target=huaxin_client.l2_client.run, args=(ptl2_l2, psl2_l2,))
    l2Process.start()
    #
    tradeProcess = multiprocessing.Process(target=huaxin_api.trade_client.run, args=(ptl2_trade, pst_trade,))
    tradeProcess = multiprocessing.Process(target=huaxin_client.trade_client.run, args=(ptl2_trade, pst_trade,))
    tradeProcess.start()
    # L1订阅数据
    huaxin_api.l1_client.run(pl1t_l1)
    huaxin_client.l1_client.run(pl1t_l1)
    # 将tradeServer作为主进程
    tradeServerProcess.join()
    tradeProcess.join()