3500 // 队列告警数量

main.go

@@ -37,7 +37,7 @@ const (
 
 // 控制异步消息协程
 const (
-	monitorLength     = 1000 // 队列告警数量
+	monitorLength     = 3500 // 队列告警数量
 	kickChanSize      = 500
 	broadcastChanSize = 3500
 )
@@ -632,7 +632,7 @@ func check() {
 		select {
 		case <-tick.C:
 			l, l2 := len(kickChan), len(broadcastChan)
-			if l > monitorLength || l2 > monitorLength {
+			if l >= monitorLength || l2 >= monitorLength {
 				if time.Now().Sub(lastDingTime).Minutes() > dingIntervalMin {
 					go func() {
 						if sErr := dingding.SendDingRobot(dingding.ROBOTWEBHOOK, fmt.Sprintf("userCenter通知延迟,队列长度:kickChan:%d,broadcastChan:%d", l, l2), true); sErr != nil {