Kotlin/Java发送Gzip流响应

Question

我试图发送一个包含压缩（gzip）流输出的响应。我当前的代码是：

@Path("/")
@Get
@Produces(MediaType.APPLICATION_JSON)
fun testRessource() : Response {
   val streamingOutput = TestOutputStream()
   val gzipStreamingOutput = CompressedHttpOutputStream(streamingOutput)
   val response = Response.ok(gzipStreamingOutput)
   response.setHeader("Content-Encoding", "gzip")

   return response
}

class TestOutputStream() : StreamingOutput {
   override fun write(outputStream: OutputStream) {
       val writer = BufferedWriter(OutputStreamWriter(outputStream))
       writer.write("{ "id" : 5 }")
       writer.flush()
   }
}


class CompressedHttpOutputStream(private val streamingOutput: StreamingOutput) : StreamingOutput {
    override fun write(outputStream: OutputStream) {
        val os = GZIPOutputStream(outputStream)
        streamingOutput.write(os)
        os.finish()
    }
}

当我请求这项服务时，我的浏览器中会出现乱七八糟的数据。尽管我的响应正确设置了以下标题，但似乎我遗漏了什么：内容编码：gzip和传输编码：chunked。

在我的单元测试中，如果我提取主体并通过GzipInputStream（）读取它，我就能够检索json主体。

当我更换时：

val os=gzip输出流（outputStream）

具有

val os=DeflaterOutputStream（outputStream）和内容编码：deflate

输出正确解压缩为json。

我正在使用Quarkus2.6.0。最终。

感谢您的帮助和见解！

Answer 1

没关系，不需要CompressedHttpOutputStream。Quakus实现了对其余endpoint的gzip支持。

我只需要向endpoint和quarkus添加注释。放松。gzip。在应用程序中，enabled=true。属性。