| | |
|---|
| | | from trade.huaxin import huaxin_trade_server, huaxin_trade_api_server |
|---|
| | | |
|---|
| | | # from huaxin_api import trade_client, l2_client, l1_client |
|---|
| | | from utils import tool |
|---|
| | | from utils import tool, server_util |
|---|
| | | |
|---|
| | | |
|---|
| | | def createTradeServer(pipe_server, queue_strategy_r_trade_w_: multiprocessing.Queue, |
|---|
| | |
|---|
| | | server.global_data_loader.init() |
|---|
| | | |
|---|
| | | # # 数据服务 |
|---|
| | | t1 = threading.Thread(target=createDataServer, name="createDataServer", daemon=True) |
|---|
| | | t1 = threading.Thread(target=server_util.run_data_server, name="createDataServer", daemon=True) |
|---|
| | | t1.start() |
|---|
| | | # |
|---|
| | | # 交易接口服务 |
|---|
| | |
|---|
| | | logger_system.exception(e) |
|---|
| | | logger_system.error(f"端口服务器：{laddr[1]} 启动失败") |
|---|
| | | |
|---|
| | | |
|---|
| | | def createDataServer(): |
|---|
| | | logger_system.info("create DataServer") |
|---|
| | | logger_system.info(f"createDataServer 线程ID:{tool.get_thread_id()}") |
|---|
| | | tcpserver = data_server.run("", 9004) |
|---|
| | | tcpserver.serve_forever() |
|---|
| | | try: |
|---|
| | | tcpserver.serve_forever() |
|---|
| | | except Exception as e: |
|---|
| | | logger_system.exception(e) |
|---|
| | | logger_system.error(f"端口服务器：{9004} 启动失败") |
|---|
| | | |
|---|
| | | |
|---|
| | | if __name__ == '__main__1': |
|---|
