From c20daf71fa6dde9a4c31214d739de080ad74a3b9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=AD=90=E9=93=AD?= Date: Tue, 11 Mar 2025 14:19:01 +0800 Subject: [PATCH] cmb --- go.sum | 1 + internal/server/wechat_notify_consumer.go | 10 ++++------ 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/go.sum b/go.sum index a7ff27d..812c2eb 100644 --- a/go.sum +++ b/go.sum @@ -126,6 +126,7 @@ github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeN github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg= github.com/google/pprof v0.0.0-20210407192527-94a9f03dee38/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE= github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI= +github.com/google/subcommands v1.2.0 h1:vWQspBTo2nEqTUFita5/KeEWlUL8kQObDFbub/EN9oE= github.com/google/subcommands v1.2.0/go.mod h1:ZjhPrFU+Olkh9WazFPsl27BQ4UPiG37m3yTrtFlrHVk= github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0= diff --git a/internal/server/wechat_notify_consumer.go b/internal/server/wechat_notify_consumer.go index b261b18..7baeda5 100644 --- a/internal/server/wechat_notify_consumer.go +++ b/internal/server/wechat_notify_consumer.go @@ -94,11 +94,9 @@ func (w *WechatNotifyConsumer) consumeMessages(ctx context.Context, mqConsumer m if errAckItems, ok := ackerr.(errors.ErrCode).Context()["Detail"].([]mqhttpsdk.ErrAckItem); ok { for _, errAckItem := range errAckItems { log.Errorf("\tErrorHandle:%s, ErrorCode:%s, ErrorMsg:%s\n", errAckItem.ErrorHandle, errAckItem.ErrorCode, errAckItem.ErrorMsg) - fmt.Printf("\tErrorHandle:%s, ErrorCode:%s, ErrorMsg:%s\n", errAckItem.ErrorHandle, errAckItem.ErrorCode, errAckItem.ErrorMsg) } } else { - log.Errorf("ackerr:%+v\n", ackerr) - fmt.Println("ack err =", ackerr) + log.Errorf("ack err:%+v\n", ackerr) } time.Sleep(time.Duration(3) * time.Second) } else { @@ -113,7 +111,7 @@ func (w *WechatNotifyConsumer) consumeMessages(ctx context.Context, mqConsumer m if strings.Contains(err.(errors.ErrCode).Error(), "MessageNotExist") { fmt.Println("\nNo new message, continue!") } else { - fmt.Println(err) + log.Errorf("\tTopic中没有消息可消费判定报错:%v\n", err) time.Sleep(time.Duration(3) * time.Second) } endChan <- 1 @@ -129,8 +127,8 @@ func (w *WechatNotifyConsumer) consumeMessages(ctx context.Context, mqConsumer m // 长轮询消费消息，网络超时时间默认为35s。 // 长轮询表示如果Topic没有消息，则客户端请求会在服务端挂起3s，3s内如果有消息可以消费则立即返回响应。 mqConsumer.ConsumeMessage(respChan, errChan, - 3, // 一次最多消费3条（最多可设置为16条）。 - 10, // 长轮询时间3s（最多可设置为30s）。 + 3, // 一次最多消费3条（最多可设置为16条）。 + 5, // 长轮询时间3s（最多可设置为30s）。 ) <-endChan }