diff --git a/internal/controllers/agent_controller.go b/internal/controllers/agent_controller.go index 4bc179f..505257b 100644 --- a/internal/controllers/agent_controller.go +++ b/internal/controllers/agent_controller.go @@ -430,9 +430,7 @@ func (c *AgentController) wsReadPump(ac *services.AgentConnection, agent *models for { _, message, err := ac.ReadMessage() if err != nil { - if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseAbnormalClosure) { - logger.Warnf("[AgentWS] Agent #%d 读取错误: %v", agent.ID, err) - } + logger.Warnf("[AgentWS] Agent #%d 读取错误: %v", agent.ID, err) break }