Administrator
2023-08-28 a57f21733946c1414fb7f7ba76f30a144209a059
增加L2订阅日志
3个文件已修改
18 ■■■■ 已修改文件
huaxin_client/l2_client.py 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
huaxin_client/trade_client.py 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
utils/socket_util.py 14 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
huaxin_client/l2_client.py
@@ -580,7 +580,7 @@
    global l2CommandManager
    l2CommandManager = command_manager.L2CommandManager()
    l2CommandManager.init(MyL2ActionCallback())
    logger_system.info("l2_client启动成功")
    logger_system.info("L2订阅服务启动成功")
    while True:
        time.sleep(2)
huaxin_client/trade_client.py
@@ -1033,8 +1033,8 @@
    global tradeCommandManager
    tradeCommandManager = command_manager.TradeCommandManager()
    tradeCommandManager.init(MyTradeActionCallback(), l2pipe, pipe_strategy)
    logger_system.info("华鑫交易服务启动")
    tradeCommandManager.run()
    logger_system.info("trade_client启动成功")
    while True:
        time.sleep(2)
utils/socket_util.py
@@ -80,3 +80,17 @@
        return True
    else:
        return False
# 端口是否被占用
def is_port_bind(port):
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    result = sock.connect_ex(('127.0.0.1', port))
    if result == 0:
        return True
    else:
        return False
if __name__ == "__main__":
    pass