添加系统日志

Administrator

2023-08-31 b217ca6db84c273f0d1c24eed3fae6bec2431dbe

 trade/huaxin/trade_server.py

@@ -798,38 +798,41 @@


def run(pipe_trade, pipe_l1, pipe_l2, trade_cmd_callback):
    # 执行一些初始化数据
    block_info.init()

    # 启动外部接口监听
    manager = outside_api_command_manager.ApiCommandManager()
    manager.init(middle_api_protocol.SERVER_HOST,
                 middle_api_protocol.SERVER_PORT,
                 OutsideApiCommandCallback())
    manager.run(blocking=False)

    # 启动交易服务
    huaxin_trade_api.run_pipe_trade(pipe_trade, trade_cmd_callback)

    # 监听l1那边传过来的代码
    t1 = threading.Thread(target=lambda: __recv_pipe_l1(pipe_l1), daemon=True)
    t1.start()

    # 同步异步日志
    t1 = threading.Thread(target=lambda: async_log_util.run_sync(), daemon=True)
    t1.start()

    logger_system.info("create TradeServer")
    t1 = threading.Thread(target=lambda: clear_invalid_client(), daemon=True)
    t1.start()

    laddr = "0.0.0.0", 10008
    tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle)  # 注意：参数是MyBaseRequestHandle
    try:
        tcpserver.serve_forever()
        # 执行一些初始化数据
        block_info.init()

        # 启动外部接口监听
        manager = outside_api_command_manager.ApiCommandManager()
        manager.init(middle_api_protocol.SERVER_HOST,
                     middle_api_protocol.SERVER_PORT,
                     OutsideApiCommandCallback())
        manager.run(blocking=False)

        # 启动交易服务
        huaxin_trade_api.run_pipe_trade(pipe_trade, trade_cmd_callback)

        # 监听l1那边传过来的代码
        t1 = threading.Thread(target=lambda: __recv_pipe_l1(pipe_l1), daemon=True)
        t1.start()

        # 同步异步日志
        t1 = threading.Thread(target=lambda: async_log_util.run_sync(), daemon=True)
        t1.start()

        logger_system.info("create TradeServer")
        t1 = threading.Thread(target=lambda: clear_invalid_client(), daemon=True)
        t1.start()

        laddr = "0.0.0.0", 10008
        tcpserver = MyThreadingTCPServer(laddr, MyBaseRequestHandle)  # 注意：参数是MyBaseRequestHandle
        try:
            tcpserver.serve_forever()
        except Exception as e:
            logger_system.exception(e)
            logger_system.error(f"端口服务器：{laddr[1]} 启动失败")
    except Exception as e:
        logger_system.exception(e)
        logger_system.error(f"端口服务器：{laddr[1]} 启动失败")


if __name__ == "__main__":