Android平台下Ktor拦截响应并替换自定义响应值的实现问题

阿华AIGC实验室

2026-4-7

嗨，我刚好之前在Ktor 3.x版本上踩过类似的响应拦截替换的坑，给你拆解下问题根源和靠谱的解决办法：

问题根源分析

你遇到的IllegalStateException其实是因为transformResponseBody的返回类型和Ktor期望的类型不匹配导致的。你之前的代码直接返回了原始的content（也就是字节流通道），但Ktor在调用body()方法时，期望的是已经转换成RespUser类型的对象，而不是原始的字节流，所以才会抛出类型不匹配的异常。

两种解决方案（根据你的需求选）

方案一：修改已返回的响应内容（适合需要调整原始响应的场景）

如果你已经发起了网络请求，只是想修改返回的响应体内容，那需要在transformResponseBody里正确处理类型转换，返回和requestedType匹配的对象：

// 自定义插件：修改响应内容
val ResponseModifyPlugin = createClientPlugin("ResponseModifyPlugin") {
    transformResponseBody { response, content, requestedType ->
        // 先把原始响应体转换成字符串
        val originalJson = content.readRemaining().decodeToString()
        // 这里可以根据需求修改JSON内容，比如替换字段值
        val modifiedJson = originalJson.replace("\"name\":\"OriginalName\"", "\"name\":\"ModifiedMockName\"")
        
        // 根据请求的目标类型返回对应对象
        when (requestedType.type) {
            RespUser::class -> {
                // 用Ktor的Json序列化器解析修改后的JSON为RespUser
                Json { ignoreUnknownKeys = true }.decodeFromString(modifiedJson)
            }
            // 其他类型保持原始处理逻辑
            else -> content
        }
    }
}

然后在HttpClient中安装这个插件，记得要先安装ContentNegotiation插件来处理JSON序列化：

val client = HttpClient(Android) {
    // 必须安装ContentNegotiation来处理JSON和对象的转换
    install(ContentNegotiation) {
        Json(Json) {
            ignoreUnknownKeys = true
        }
    }
    install(Logging) {
        logger = Logger.ANDROID
    }
    install(ResponseModifyPlugin)
}

方案二：直接拦截请求返回Mock响应（和Retrofit拦截器逻辑一致）

如果你想完全模拟Retrofit拦截器的功能——在某些条件下直接返回自定义的Mock响应，跳过实际的网络请求，那用onRequest阶段的scope.proceedWith会更合适：

// 自定义插件：直接返回Mock响应，跳过网络请求
val MockResponsePlugin = createClientPlugin("MockResponsePlugin") {
    onRequest { request, scope ->
        // 这里可以根据请求的URL、方法、参数等判断是否需要返回Mock
        if (request.url.encodedPath == "/api/user") {
            // 构建你自己的Mock RespUser对象
            val mockUser = RespUser(id = 999, name = "Mocked User", email = "mock@test.com")
            // 把Mock对象转换成字节通道
            val mockBody = ByteReadChannel(Json.encodeToString(mockUser))
            // 构建自定义的响应数据
            val mockResponse = HttpResponseData(
                statusCode = HttpStatusCode.OK,
                headers = Headers.Empty,
                version = HttpProtocolVersion.HTTP_1_1,
                request = request,
                body = mockBody,
                callContext = scope.coroutineContext
            )
            // 直接返回Mock响应，跳过网络请求
            scope.proceedWith(request, mockResponse)
        } else {
            // 其他请求正常走网络流程
            scope.proceedWith(request)
        }
    }
}

同样，需要确保HttpClient已经安装了ContentNegotiation插件，然后安装这个Mock插件即可。