首先，一些事情将帮助您理解解决此用例的代码片段。

1. 您永远不要在返回反应类型的方法中调用阻塞方法。您将阻塞应用程序的几个线程之一，这对应用程序来说是非常糟糕的
2. 无论如何，从Reactor 3.2开始，在反应式管道内进行阻塞会引发错误
3. subscribe如评论中所建议的那样，调用也不是一个好主意。它或多或少像在一个单独的线程中将该任务作为任务开始。完成后，您将获得一个回调（subscribe可以给这些方法指定lambdas），但实际上您正在将当前管道与该任务分离。在这种情况下，在您有机会读取完整的响应正文并将其写入文件之前，可能会关闭客户端HTTP响应并清理资源。
4. 如果您不想将整个响应缓冲在内存中，Spring会提供DataBuffer（请考虑可以缓冲的ByteBuffer实例）。
5. 如果要实现的方法本身是阻塞的（void例如返回），例如在测试用例中，则可以调用阻塞。

这是一个可用于执行此操作的代码段：

Mono<Void> fileWritten = WebClient.create().post()
        .uri(uriBuilder -> uriBuilder.path("/file/").build())
        .exchange()
        .flatMap(response -> {
            if (MediaType.APPLICATION_JSON_UTF8.equals(response.headers().contentType().get())) {
                Mono<NoPayloadResponseDto> dto = response.bodyToMono(NoPayloadResponseDto.class);
                return createErrorFile(dto);
            }
            else {
                Flux<DataBuffer> body = response.bodyToFlux(DataBuffer.class);
                return createSpreadsheet(body);
            }
        });
// Once you get that Mono, you should give plug it into an existing
// reactive pipeline, or call block on it, depending on the situation

如您所见，我们不会在任何地方阻塞，并且处理I /
O的方法将返回Mono<Void>，这与done(error)回调的反应性等效，该回调表示何时完成操作以及是否发生错误。

由于不确定该createErrorFile方法应该做什么，因此提供了一个示例，createSpreadsheet该示例仅将主体字节写入文件中。请注意，由于数据缓冲区可能被回收/池化，因此我们需要在完成后释放它们。

private Mono<Void> createSpreadsheet(Flux<DataBuffer> body) {
    try {
        Path file = //...
        WritableByteChannel channel = Files.newByteChannel(file, StandardOpenOption.WRITE);
        return DataBufferUtils.write(body, channel).map(DataBufferUtils::release).then();
    } catch (IOException exc) {
        return Mono.error(exc);
    }
}

通过此实现，您的应用程序将DataBuffer在给定的时间在内存中保存几个实例（反应式运算符出于性能原因正在预取值），并将以反应式方式写入字节。