如何将mono转换为byte[]？

Question

我想使用反应性编程将我的excel文件存储到我的数据库中。在非反应式中，这很容易做到，但我不能在反应式中做类似的事情，我应该写什么来存储它到我的mongo数据库中？

@PostMapping(path = "/file",consumes = MediaType.MULTIPART_FORM_DATA_VALUE,
            produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
    public HttpStatus file(@RequestPart("files") Mono<FilePart> file) {
        return Service.save(excel);
    }

public HttpStatus save(Mono<FilePart> filePartMono) {
        //what to do here to save my file into database
    }

@Collection("data")
public class Excel {
    @Id
    int id;
    private byte[] file;
}

Answer 1

在使用反应式编程时，您实际上应该使用mono和flux，这样您的应用程序才真正是反应式的。这样做的结果是，您必须将服务和控制器方法的返回类型更改为返回mono 。您的完整应用程序应该是反应式的（从REST API到数据库），这样您就可以充分受益于反应式堆栈。

@PostMapping(path = "/file", consumes = MediaType.MULTIPART_FORM_DATA_VALUE,
             produces = MediaType.APPLICATION_STREAM_JSON_VALUE)
public Mono<HttpStatus> file(@RequestPart("files") Mono<FilePart> file) {
    return Service.save(excel);
}

在您的服务中，您可以执行以下操作：

public Mono<HttpStatus> save(Mono<FilePart> filePartMono) {
    return filePartMono.flatMap { filePart -> // you need flatMap assuming your mongo repository also returns a Mono
        byte[] bytes = // convertion to byte[]

        // save it to the database
    }.map { mongoRepositoryResponse ->
        // depending on the response from mongo repository you compute HttpStatus
    }
}