使用SpringWebFlux读取和分析S3PutRequest中的数据

我有一个存根设置来处理与AWS S3桶交互的测试。(自定义)存根实现使用SpringWebFlux来响应例如s3 put请求。

最近,我被迫更改S3实现以使用 InputStream 而不是作为输入的实际文件。我的问题是,当传递一个输入流而不是一个文件时,存根实现不会产生预期的结果。

我的存根当前实现如下:

RouterFunction<ServerResponse> putS3Object() {
    return RouterFunctions.route(PUT("/S3/MyBucket/{filename}").and(accept(TEXT_PLAIN))) { ServerRequest request ->
        return request.bodyToMono(String)
                .doOnSuccess { s3Stubs.registerPutObject(request.pathVariable("filename"), it) }
                .flatMap { response -> ServerResponse.ok().build() }
    }
}

传递给的字符串 s3Stubs.registerPutObject 在 it 参数包含预期值“hello world”。

现在,当我使用inputstream作为s3 api的参数而不是文件时, 它 参数不再是“人类可读的”。它包含如下数据: 18;chunk-signature=c27c7fa381b8aa2824e8487979d2d0e9ded04dd3 ..... 0;chunk-signature=db7e8b1bacc57da0d410ee116 -在那里我会期待同样的结果“你好世界”。

我不确定这是否与我的WebFlux实现有关,或者与实际文件相比,S3如何处理输入流。

使用完全相同的S3实现 输入流 把一个现实世界的S3桶…