Ktor重试时修改请求体不生效问题排查

在Ktor客户端中配置了自定义重试策略：当收到服务器5XX错误时执行指数退避重试，直至获取非5XX响应，同时希望每次重试时更新请求体。但添加modifyRequest { it.setBody("With Different body ...") }配置后，重试仅执行一次就卡住；移除该配置后，重试逻辑正常运行。请问问题出在哪里？如何实现每次重试修改请求体？

import io.ktor.client.*
import io.ktor.client.engine.java.*
import io.ktor.client.plugins.*
import io.ktor.client.request.*
import io.ktor.http.*
import io.ktor.server.application.*
import io.ktor.server.engine.*
import io.ktor.server.netty.*
import io.ktor.server.request.*
import io.ktor.server.routing.*
import kotlinx.coroutines.*
import kotlin.time.Duration.Companion.seconds

suspend fun main() {
    val serverJob = CoroutineScope(Dispatchers.Default).launch { startServer() }

    val client = HttpClient(Java) {
        install(HttpTimeout) {
            connectTimeoutMillis = 5.seconds.inWholeMilliseconds
        }
        install(HttpRequestRetry)
    }

    client.post {
        url("http://127.0.0.1:8080/")
        setBody("Hello")
        retry {
            retryOnServerErrors(maxRetries = Int.MAX_VALUE)
            exponentialDelay(maxDelayMs = 128.seconds.inWholeMilliseconds)
            modifyRequest { it.setBody("With Different body ...") } // 添加后重试异常
        }
    }

    client.close()
    serverJob.cancelAndJoin()
}

suspend fun startServer() {
    embeddedServer(Netty, port = 8080) {
        routing {
            post("/") {
                val text = call.receiveText()
                println("Retrying exponentially... $text")
                call.response.status(HttpStatusCode(500, "internal server error"))
            }
        }
    }.start(wait = true)
}

1. Java客户端引擎的请求体复用缺陷：Ktor的Java客户端引擎在处理带请求体的重试请求时，直接修改请求体可能无法正确重置请求体的流状态，导致第二次请求后，客户端无法继续构建新请求，出现卡住的情况。
2. 固定请求体的状态问题：直接设置固定字符串作为重试请求体时，未利用重试次数生成新的请求体实例，可能被引擎判定为请求无变化，终止重试逻辑。

1. 切换到Netty客户端引擎：Netty引擎对重试请求的请求体处理更稳定，能更好支持请求体动态修改。
2. 动态生成重试请求体：在modifyRequest中利用重试次数参数（attempt）生成不同请求体，确保每次重试的请求体是全新实例。
3. 显式设置请求ContentType：避免自动推断ContentType可能带来的一致性问题。

import io.ktor.client.*
import io.ktor.client.engine.netty.* // 切换为Netty引擎
import io.ktor.client.plugins.*
import io.ktor.client.request.*
import io.ktor.http.*
import io.ktor.server.application.*
import io.ktor.server.engine.*
import io.ktor.server.netty.*
import io.ktor.server.request.*
import io.ktor.server.routing.*
import kotlinx.coroutines.*
import kotlin.time.Duration.Companion.seconds

suspend fun main() {
    val serverJob = CoroutineScope(Dispatchers.Default).launch { startServer() }

    val client = HttpClient(Netty) { // 使用Netty引擎
        install(HttpTimeout) {
            connectTimeoutMillis = 5.seconds.inWholeMilliseconds
        }
        install(HttpRequestRetry)
    }

    client.post {
        url("http://127.0.0.1:8080/")
        contentType(ContentType.Text.Plain) // 显式设置ContentType
        setBody("Hello (initial request)")
        retry {
            retryOnServerErrors(maxRetries = Int.MAX_VALUE)
            exponentialDelay(maxDelayMs = 128.seconds.inWholeMilliseconds)
            // 利用重试次数动态生成请求体
            modifyRequest { attempt ->
                setBody("Retry attempt $attempt: Updated body content")
            }
        }
    }

    client.close()
    serverJob.cancelAndJoin()
}

suspend fun startServer() {
    embeddedServer(Netty, port = 8080) {
        routing {
            post("/") {
                val text = call.receiveText()
                println("Received request: $text")
                call.response.status(HttpStatusCode(500, "Internal Server Error"))
            }
        }
    }.start(wait = true)
}

• 切换到Netty引擎后，请求体的重试逻辑可正常工作，每次重试都会发送新的请求体。
• modifyRequest的lambda参数attempt表示当前是第几次重试（从1开始计数），可用于生成差异化的请求体内容。
• 显式设置contentType确保每次请求的ContentType一致，避免自动推断引发的潜在问题。

内容的提问来源于stack exchange，提问作者Vencat