消息发送失败也停止进程

services/websocket_msg.go

@@ -103,6 +103,7 @@ func DealEdbInspectionMessage(adminId int) {
 						err, isClose := WriteWebSocketMessageAsync(ctx, adminId, resp)
 						if err != nil {
 							utils.FileLog.Error("巡检信息发送失败,err:%s, adminId:%d", err.Error(), adminId)
+							cancel()
 							continue
 						}
 						if isClose {