如何使用ktor客户端设置HttpServlet响应的正文

Question

我有spring boot控制器

@PostMapping(path = ["/download"])
fun getFile(@RequestBody myObjectRq: myObjectRq, httpServletResponse: HttpServletResponse): CompletableFuture<HttpServletResponse> {
    return GlobalScope.async {
       val response = webService.getFile(myObjectRq)
       response?.let {
           httpServletResponse.setHeader("Content-Type", response.headers.get("Content-Type"))
           httpServletResponse.setHeader("Content-Disposition", response.headers.get("Content-Disposition"))
           httpServletResponse.writer.write(String(response.content.toByteArray()))
           httpServletResponse.writer.flush()
           httpServletResponse.status = response.status.value
       }
       httpServletResponse
   }.asCompletableFuture()
}

在其中，我使用服务，该服务反过来使用ktor客户端向外部服务器发送post请求，该服务器应响应发送csv文件。csv文件内容取决于我在myObjectRq中发送的值。

服务：

suspend fun getFile(myObjectRq: myObjectRq): HttpResponse {
    val response = ktorClient.post<HttpResponse> {
        accept(ContentType.Application.OctetStream)
        url(externalWebServerUrl)
        body = myObjectRq
        contentType(ContentType.Application.Json)
    }
    log.info(String(response.content.toByteArray()))
    response
}

正确设置响应的标头，以及日志。方法中的info（String（response.content.toByteArray（））打印出接收文件的内容，但我不能将其设置为HttpServletResponse的主体。我不断得到组织。springframework。网状物HttpMediaTypeNotAcceptableException：找不到可接受的表示。

此外，我还得到了httpServletResponse的不适当的阻塞方法调用。编写器哪种中断了ktor客户端的异步质量。我做错了什么？我应该如何解决？

Answer 1

我实际上设法使用CompletableFuture解决了这个问题

Answer 2

所以，我认为SpringBoot与您的返回类型相混淆。它试图找到一种方法来序列化您的返回

@PostMapping(path = ["/download"])
fun getFile(@RequestBody myObjectRq: myObjectRq, httpServletResponse: HttpServletResponse): CompletableFuture<Void> {
    return GlobalScope.async {
       val response = webService.getFile(myObjectRq)
       response?.let {
           httpServletResponse.setHeader("Content-Type", response.headers.get("Content-Type"))
           httpServletResponse.setHeader("Content-Disposition", response.headers.get("Content-Disposition"))
           httpServletResponse.writer.write(String(response.content.toByteArray()))
           httpServletResponse.writer.flush()
           httpServletResponse.status = response.status.value
       }
       null
   }.asCompletableFuture()
}