diff --git a/app/core/websocket/manager.py b/app/core/websocket/manager.py index 10a6bbd..d04f5b5 100644 --- a/app/core/websocket/manager.py +++ b/app/core/websocket/manager.py @@ -167,10 +167,10 @@ class WebSocketManager: logger.info(f"心跳循环启动成功: {client_name} -> {heartbeat_channel.name}") + # 修改循环条件:只要客户端存在就发送心跳,不管连接状态 while client_name in self._clients: try: client = self._clients[client_name] - is_connected = client.is_connected # 创建心跳消息 from app.core.websocket.channel import ChannelMessage @@ -185,7 +185,7 @@ class WebSocketManager: # 发送到心跳Channel success = await heartbeat_channel.send_message(heartbeat_message) if success: - logger.debug(f"心跳消息已发送到Channel: {client_name}_heartbeat") + logger.info(f"心跳消息已发送到Channel: {client_name}_heartbeat (连接状态: {client.is_connected})") else: logger.warning(f"心跳消息发送失败: {client_name}_heartbeat")