| | |
| | | global l2CommandManager |
| | | l2CommandManager = command_manager.L2CommandManager() |
| | | l2CommandManager.init(MyL2ActionCallback()) |
| | | logger_system.info("l2_client启动成功") |
| | | logger_system.info("L2订阅服务启动成功") |
| | | while True: |
| | | time.sleep(2) |
| | | |
| | |
| | | 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) |
| | | |
| | |
| | | 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 |