From d086208db635af26acd662c6d882bd4ced2c8772 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期五, 22 三月 2024 18:56:23 +0800
Subject: [PATCH] 添加失败重试控制
---
main.go | 11 +++++++++--
1 files changed, 9 insertions(+), 2 deletions(-)
diff --git a/main.go b/main.go
index b943870..087099e 100644
--- a/main.go
+++ b/main.go
@@ -42,6 +42,7 @@
func doServer() {
total := 0
+ retryCount := 0
for {
t, err := service.GetTotal()
if err != nil {
@@ -49,8 +50,8 @@
return
}
total = t
- logger.Debug("鏈彂閫佺殑鏁版嵁鎬婚噺锛�", total)
- if total == 0 {
+ logger.Debugf("鏈彂閫佺殑鏁版嵁鎬婚噺:%d, 閲嶈瘯娆℃暟:%d", total, retryCount)
+ if total == 0 || retryCount > 10 {
break
} else {
for {
@@ -61,6 +62,8 @@
result, err1 := service.GetData()
if err1 != nil {
logger.Warn(err1.Error())
+ time.Sleep(1 * time.Second)
+ retryCount += 1
break
}
@@ -71,6 +74,10 @@
markStatus := service.MarkData(id)
fmt.Println(markStatus)
logger.Debug("璁板綍鎺ㄩ�佺姸鎬� markStatus: ", markStatus)
+ } else {
+ logger.Debug("鎺ㄩ�佺殑鏁版嵁澶辫触 id: ", id)
+ time.Sleep(1 * time.Second)
+ retryCount += 1
}
break
} else {
--
Gitblit v1.8.0