如何在Ktor中获得call.reponse的超文本传输协议？

Question

我用Ktor构建了一个Web服务器，并想缓存API方法结果。但是我不知道如何从下面call.response.代码中获取响应正文

fun Application.module(){

    // before method was called
    intercept(ApplicationCallPipeline.Features) {
        val cache = redis.get("cache")
        if(cache) {
            call.respond(cache)
        }

        return @intercept finish()
    }
    
    // after method was called
    intercept(ApplicationCallPipeline.Fallback) {
        // TODO, how to get call.response.body
        redis.set("cache", call.response.body)
    }
}

如果我无法获得响应体，还有其他解决方案可以在Ktor中缓存API方法的结果吗？

Answer 1

在拦截器内，用于应用程序调用管道（ApplicationCallPipeline）。功能阶段您可以在ApplicationSendPipeline之前添加一个阶段。引擎并拦截它以检索响应正文（内容）：

val phase = PipelinePhase("phase")
call.response.pipeline.insertPhaseBefore(ApplicationSendPipeline.Engine, phase)
call.response.pipeline.intercept(phase) { response ->
    val content: ByteReadChannel = when (response) {
        is OutgoingContent.ByteArrayContent -> ByteReadChannel(response.bytes())
        is OutgoingContent.NoContent -> ByteReadChannel.Empty
        is OutgoingContent.ReadChannelContent -> response.readFrom()
        is OutgoingContent.WriteChannelContent -> GlobalScope.writer(coroutineContext, autoFlush = true) {
            response.writeTo(channel)
        }.channel
        else -> error("")
    }

    // Do something with content
}