diff --git a/main.go b/main.go index 53f4294c075808e75431bc5a791753c7f0842178..08ee7a98eabfa586246f0fe0af18017875d6a400 100644 --- a/main.go +++ b/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 {