test

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")