如何使用WebFlux上传多个文件？

Question

Mono<MultiValueMap<String, Part> body = request.body(toMultipartData());
body.flatMap(map -> FilePart part = (FilePart) map.toSingleValueMap().get("file"));

但是如何为多个文件做呢？

PS.在webflux中有没有另一种上传一组文件的方法？

Answer 1

我已经找到了一些解决办法。假设我们发送一个http POST请求，其中包含一个包含我们文件的参数files。

注意：响应是任意的

>

RequestPart的RestController

@PostMapping("/upload")
public Mono<String> process(@RequestPart("files") Flux<FilePart> filePartFlux) {
    return filePartFlux.flatMap(it -> it.transferTo(Paths.get("/tmp/" + it.filename())))
        .then(Mono.just("OK"));
}

@PostMapping("/upload-model")
public Mono<String> processModel(@ModelAttribute Model model) {
    model.getFiles().forEach(it -> it.transferTo(Paths.get("/tmp/" + it.filename())));
    return Mono.just("OK");
}

class Model {
    private List<FilePart> files;
    //getters and setters
}

public Mono<ServerResponse> upload(ServerRequest request) {
    Mono<String> then = request.multipartData().map(it -> it.get("files"))
        .flatMapMany(Flux::fromIterable)
        .cast(FilePart.class)
        .flatMap(it -> it.transferTo(Paths.get("/tmp/" + it.filename())))
        .then(Mono.just("OK"));

    return ServerResponse.ok().body(then, String.class);
}