减少一次消费条数

2025-05-12 09:50:31 +08:00 · 2025-05-12 09:50:31 +08:00 · 0c01053615
parent 83295e7443
commit 0c01053615
1 changed files with 2 additions and 2 deletions
--- a/internal/server/wechat_notify_consumer.go
+++ b/internal/server/wechat_notify_consumer.go
@ -119,8 +119,8 @@ func (w *WechatNotifyConsumer) consumeMessages(mqConsumer mq_http_sdk.MQConsumer
 		// 长轮询消费消息，网络超时时间默认为35s。
 		// 长轮询表示如果Topic没有消息，则客户端请求会在服务端挂起3s，3s内如果有消息可以消费则立即返回响应。
 		mqConsumer.ConsumeMessage(respChan, errChan,
-			5,  // 一次最多消费3条（最多可设置为16条）。
-			20, // 长轮询时间3s（最多可设置为30s）。
+			3,  // 一次最多消费3条（最多可设置为16条）。
+			10, // 长轮询时间3s（最多可设置为30s）。
 		)
 		<-endChan
 	}