网络流量上传文件未保存

Question

我有这段代码：

@PostMapping(value = {"/store"})
public Mono<ResponseEntity<StoreResponse>> store(@RequestPart("file") Mono<FilePart> file,
                                                 @RequestPart("publicationId") String publicationId,
                                                 @RequestPart("visible") String visible) throws Exception {
    return file
            .doOnNext(this::checkFile)
            .flatMap((f) -> this.saveFileToDatabase(UUID.fromString(publicationId),
                    f.filename(),
                    Boolean.parseBoolean(visible)))
            .then(Mono.just(ResponseEntity.ok().body(new StoreResponse("", "", "Working",
                    null))))
            .onErrorReturn(ResponseEntity.internalServerError().body(new StoreResponse("Not Working",
                    "", "Working", null)));
}

问题1：
奇怪的是，只要我在Mono上使用平面地图，它就可以工作。
当我切换到map而不是平面地图时，它就不起作用（该文件不会写入数据库this.saveFileToDatabase（通过spring-data-r2dbc））。
为什么会这样？

问题2：
当我想在保存到数据库后执行另一个操作（将文件保存到minio容器）时，如何将其链接到给定的代码中？另一个然后（）？

Answer 1

当我切换到map而不是flatMap时，它就不起作用了

map操作符被设计为执行1对1的同步操作，比如简单的对象映射。另一方面，flatMap用于异步I/O操作，就像您的情况一样。参见Reactor中的地图与平面地图

当我想在保存到数据库后进行另一个操作时

您可以使用第二个flatmap，如下所示：

 .flatMap(file -> this.saveFileToDatabase(...).map(reponse -> file))
 .flatMap(file -> this.saveFileToContainer(...))