| | |
|---|
| | | def createTradeServer(pipe_server, queue_strategy_r_trade_w_: multiprocessing.Queue, |
|---|
| | | queue_l1_w_strategy_r_: multiprocessing.Queue, |
|---|
| | | queue_strategy_w_trade_r_: multiprocessing.Queue, |
|---|
| | | queue_strategy_w_trade_r_for_read_: multiprocessing.Queue, queue_l1_trade_r_strategy_w_, queue_l1_trade_w_strategy_r_): |
|---|
| | | queue_strategy_w_trade_r_for_read_: multiprocessing.Queue, queue_l1_trade_r_strategy_w_, |
|---|
| | | queue_l1_trade_w_strategy_r_, trade_ipc_addr): |
|---|
| | | """ |
|---|
| | | 策略进程 |
|---|
| | | @param pipe_server: |
|---|
| | | @param queue_strategy_r_trade_w_: |
|---|
| | | @param queue_l1_w_strategy_r_: |
|---|
| | | @param queue_strategy_w_trade_r_: |
|---|
| | | @param queue_strategy_w_trade_r_for_read_: |
|---|
| | | @param queue_l1_trade_r_strategy_w_: |
|---|
| | | @param queue_l1_trade_w_strategy_r_: |
|---|
| | | @param trade_ipc_addr: 交易ipc地址(下单地址, 撤单地址) |
|---|
| | | @return: |
|---|
| | | """ |
|---|
| | | logger_system.info("策略进程ID：{}", os.getpid()) |
|---|
| | | log.close_print() |
|---|
| | | # 初始化参数 |
|---|
| | |
|---|
| | | # 启动华鑫交易服务 |
|---|
| | | huaxin_trade_server.run(queue_strategy_r_trade_w_, queue_l1_w_strategy_r_, queue_strategy_w_trade_r_, |
|---|
| | | queue_strategy_w_trade_r_for_read_, |
|---|
| | | queue_l1_trade_w_strategy_r_) |
|---|
| | | queue_l1_trade_w_strategy_r_, trade_ipc_addr) |
|---|
| | | |
|---|
| | | |
|---|
| | | # 主服务 |
|---|
| | |
|---|
| | | # 策略读交易写 |
|---|
| | | queue_strategy_r_trade_w = multiprocessing.Queue() |
|---|
| | | |
|---|
| | | # 下单,撤单ipc地址 |
|---|
| | | order_ipc_addr, cancel_order_ipc_addr = "ipc://trade_order.ipc", "ipc://trade_cancel_order.ipc" |
|---|
| | | |
|---|
| | | # 托管环境下不创建 |
|---|
| | | # serverProcess = multiprocessing.Process(target=createServer, args=(pss_server,)) |
|---|
| | | # serverProcess.start() |
|---|
| | |
|---|
| | | # 交易进程 |
|---|
| | | tradeProcess = multiprocessing.Process( |
|---|
| | | target=huaxin_client.trade_client.run, |
|---|
| | | args=(None, queue_other_w_l2_r, queue_strategy_r_trade_w, queue_strategy_w_trade_r, |
|---|
| | | args=(order_ipc_addr, cancel_order_ipc_addr, queue_strategy_r_trade_w, queue_strategy_w_trade_r, |
|---|
| | | queue_strategy_w_trade_r_for_read)) |
|---|
| | | tradeProcess.start() |
|---|
| | | # 此处将L2的进程与策略进程合并 |
|---|
| | |
|---|
| | | # 主进程 |
|---|
| | | createTradeServer(pss_strategy, queue_strategy_r_trade_w, queue_l1_w_strategy_r, queue_strategy_w_trade_r, |
|---|
| | | queue_strategy_w_trade_r_for_read, queue_l1_trade_r_strategy_w, |
|---|
| | | queue_l1_trade_w_strategy_r) |
|---|
| | | queue_l1_trade_w_strategy_r,trade_ipc_addr) |
|---|
| | | |
|---|
| | | # 将tradeServer作为主进程 |
|---|
| | | l1Process.join() |
|---|
