优化消息队列-当没有新消息时加大延迟时间

2026-03-03 04:07:39 +08:00 · 2023-01-28 16:25:30 +08:00
parent b8150cfc51
commit 8c8d681093
1 changed files with 1 additions and 1 deletions
--- a/sysservice/messagequeueservice/CustomerSubscriber.go
+++ b/sysservice/messagequeueservice/CustomerSubscriber.go
@@ -190,7 +190,7 @@ func (cs *CustomerSubscriber) publishToCustomer(topicData []TopicData) bool {

 	if len(topicData) == 0 {
 		//没有任何数据待一秒吧
-		time.Sleep(time.Millisecond * 100)
+		time.Sleep(time.Second * 1)
 		return true
 	}