添加失败重试控制

zhangzengfei

2024-03-22 d086208db635af26acd662c6d882bd4ced2c8772

 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 {