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

java spring-boot spring-webflux

2022-09-04 03:19:30

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

我发送带有内容类型：的请求，正文包含一个部分是值是一组文件。multipart/form-data

要处理单个文件，我按如下方式进行：

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

但是如何为多个文件完成呢？

PS.有没有其他方法可以在webflux中上传一组文件？

答案 1

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

注意响应是任意的

RestController with RequestPart

@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"));
}

RestController with ModelAttribute

@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);
}

答案 2

您可以使用 Flux 迭代哈希映射并返回 Flux

Flux.fromIterable(hashMap.entrySet())
            .map(o -> hashmap.get(o));

它将作为带有文件部分的数组发送