融入交易

admin

2024-05-22 4ee1bd5de9ca76a69adac6e17a11bd686c742ef3

 main.py

@@ -1,18 +1,23 @@
import multiprocessing
import threading

import constant
import data_server
import log
import middle_api_server
import middle_cb_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

if __name__ == "__main__":
    t1 = threading.Thread(target=lambda: middle_api_server.run(), daemon=True)
    t1.start()
    t1 = threading.Thread(target=lambda: data_server.run("0.0.0.0", constant.DATA_SERVER_PORT), daemon=True)
    t1.start()
    t1 = threading.Thread(target=lambda: log.async_log_util.run_sync(), daemon=True)
    t1 = threading.Thread(target=lambda: async_log_util.run_sync(), daemon=True)
    t1.start()
    t1 = threading.Thread(target=lambda: middle_server.run(12880), daemon=True)
    t1.start()
@@ -21,4 +26,15 @@
    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()