添加失败重试控制

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 {