++++++++++++++++ bug修复-

Administrator

2023-08-15 980eb7c740a698c71cdb43f74b23bea84b78af1e

 main.py

@@ -5,13 +5,16 @@
import multiprocessing

from db import redis_manager_delegate as redis_manager
import huaxin_api.trade_client
import huaxin_api.l2_client
import huaxin_api.l1_client

from server import *

# 交易服务
from third_data import data_server
from trade.huaxin import trade_server, trade_api_server
from huaxin import trade_client,l2_client,l1_client
# from huaxin_api import trade_client, l2_client, l1_client


def createTradeServer(pipe_server, pipe_trade, pipe_l1):
@@ -62,11 +65,11 @@
    serverProcess = multiprocessing.Process(target=createServer, args=(pss_server,))
    serverProcess.start()
    # 交易进程与L2进程
    tradeProcess = multiprocessing.Process(target=trade_client.run, args=(ptl2_trade, pst_trade))
    l2Process = multiprocessing.Process(target=l2_client.run, args=(ptl2_l2,))
    tradeProcess = multiprocessing.Process(target=huaxin_api.trade_client.run, args=(ptl2_trade, pst_trade))
    l2Process = multiprocessing.Process(target=huaxin_api.l2_client.run, args=(ptl2_l2,))
    tradeProcess.start()
    l2Process.start()
    # L1订阅数据
    l1_client.run_async(pl1t_l1)
    huaxin_api.l1_client.run_async(pl1t_l1)
    # 将tradeServer作为主进程
    createTradeServer(pss_strategy, pst_strategy, pl1t_trade)