| | |
| | | # 初始化参数 |
| | | server.global_data_loader.init() |
| | | |
| | | # 测试 |
| | | # # 数据服务 |
| | | # t1 = threading.Thread(target=server_util.run_data_server, name="createDataServer", daemon=True) |
| | | # t1.start() |
| | | # |
| | | # 数据服务 |
| | | t1 = threading.Thread(target=server_util.run_data_server, name="createDataServer", daemon=True) |
| | | t1.start() |
| | | |
| | | # 交易接口服务 |
| | | t1 = threading.Thread(target=huaxin_trade_api_server.run, name="trade_api_server", |
| | | args=(pipe_server, queue_other_w_l2_r, queue_l1_trade_r_strategy_w_), |
| | |
| | | except Exception as e: |
| | | logger_system.exception(e) |
| | | logger_system.error(f"端口服务器:{laddr[1]} 启动失败") |
| | | |
| | | |
| | | |
| | | if __name__ == '__main__1': |