如何在Kotlin协程上进行指数退避重试

How to Exponential Backoff retry on kotlin coroutines(如何在Kotlin协程上进行指数退避重试)

问题描述

我正在使用Kotlin协程进行网络请求，使用扩展方法调用改造中的类，如下所示

public suspend fun <T : Any> Call<T>.await(): T {

  return suspendCancellableCoroutine { continuation -> 

    enqueue(object : Callback<T> {

        override fun onResponse(call: Call<T>?, response: Response<T?>) {
            if (response.isSuccessful) {
                val body = response.body()
                if (body == null) {
                    continuation.resumeWithException(
                            NullPointerException("Response body is null")
                    )
                } else {
                    continuation.resume(body)
                }
            } else {
                continuation.resumeWithException(HttpException(response))
            }
        }

        override fun onFailure(call: Call<T>, t: Throwable) {
            // Don't bother with resuming the continuation if it is already cancelled.
            if (continuation.isCancelled) return
            continuation.resumeWithException(t)
        }
    })

      registerOnCompletion(continuation)
  }
}

那么从调用端我就是这样使用上面的方法

private fun getArticles()  = launch(UI) {

    loading.value = true
    try {
        val networkResult = api.getArticle().await()
        articles.value =  networkResult

    }catch (e: Throwable){
        e.printStackTrace()
        message.value = e.message

    }finally {
        loading.value = false
    }

}

我想在某些情况下指数重试此API调用，即(IOException)如何实现？？

推荐答案

我建议为您的重试逻辑编写帮助器higher-order function。您可以使用以下实现作为起点：

suspend fun <T> retryIO(
    times: Int = Int.MAX_VALUE,
    initialDelay: Long = 100, // 0.1 second
    maxDelay: Long = 1000,    // 1 second
    factor: Double = 2.0,
    block: suspend () -> T): T
{
    var currentDelay = initialDelay
    repeat(times - 1) {
        try {
            return block()
        } catch (e: IOException) {
            // you can log an error here and/or make a more finer-grained
            // analysis of the cause to see if retry is needed
        }
        delay(currentDelay)
        currentDelay = (currentDelay * factor).toLong().coerceAtMost(maxDelay)
    }
    return block() // last attempt
}

使用此函数非常简单：

val networkResult = retryIO { api.getArticle().await() }

您可以根据具体情况更改重试参数，例如：

val networkResult = retryIO(times = 3) { api.doSomething().await() }

您还可以完全更改retryIO的实现，以适应您的应用程序的需要。例如，您可以硬编码所有重试参数、取消重试次数限制、更改默认值等。

这篇关于如何在Kotlin协程上进行指数退避重试的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持编程学习网！