通过WebFlux（Spring-Boot）传输文件和存储文件ID（Elasticsearch）

Question

我正在尝试通过WebFlux将文件传输到第三方服务，并将文件ID存储在Elasticsearch中。文件被传输和保存，但是ID未连接到实体。

控制器：

@PostMapping(value = "upload", consumes = MediaType.MULTIPART_FORM_DATA_VALUE, produces = MediaType.APPLICATION_JSON_VALUE)
    public Flux<String> store(@RequestParam(required = false) String orderId, @RequestPart("file") Flux<FilePart> files){
        return imageService.store(orderId, files);
    }

服务：

    public Flux<String> store(String orderId, Flux<FilePart> files) {
        return marketService.findById(orderId)
                .filter(Objects::nonNull)
                .flatMapMany(order -> {
                    return files.ofType(FilePart.class).flatMap(file -> save(orderId, file));
                });
    }

    private Mono<String> save(String orderId, FilePart file) {
        return file.content()
                .flatMap(dataBuffer -> {
                    byte[] bytes = new byte[dataBuffer.readableByteCount()];
                    dataBuffer.read(bytes);
                    String image = storeApi.upload(bytes, file.filename());
                    DataBufferUtils.release(dataBuffer);
                    return Mono.just(image);
                })
                .doOnNext(image -> marketService.addImages(orderId, image))
                .last();
    }

MarketService.addimages：

    public Mono<Order> addImages(String id, String image){
        log.info("addImages: id={}, image={}", id, image);
        return orderRepository
                .findById(id)
                .doOnNext(order -> {
                    if(order.getProduct().getImages() == null){
                        order.getProduct().setImages(new ArrayList<>());
                    }
                    order.getProduct().getImages().add(image);
                })
                .flatMap(this::create);
    }

doonnext 和 flatmap block中的代码（ addimages ）不起作用。这样，控制器调用方法（ admimages ）可以正常工作。告诉我我想念什么。

Answer 1

我想我找到了一个解决方案。根据此解决方案，我将操作从doonnext更改为flatmap：

public Mono<OrderPostgres> store(String orderId, Flux<FilePart> files) {
        return marketService.findById(orderId)
                .filter(Objects::nonNull)
                .flatMapMany(order -> {
                    return files.ofType(FilePart.class)
                            .flatMap(file -> save(orderId, file))
                            .collectList();
                })
                .flatMap(image -> marketService.addImages(orderId, image))
                .then(Mono.empty());
    }

    private Flux<String> save(String orderId, FilePart file) {
        return file.content()
                .log()
                .flatMap(dataBuffer -> {
                    byte[] bytes = new byte[dataBuffer.readableByteCount()];
                    dataBuffer.read(bytes);
                    String image = storeApi.upload(bytes, file.filename());
                    DataBufferUtils.release(dataBuffer);
                    return Flux.just(image);
                }).switchIfEmpty(Flux.empty());
    }

public Mono<OrderPostgres> addImages(String id, List<String> images){
        log.info("### addImage: id={}, images={}", id, images);

        Mono<OrderPostgres> byId = orderRepository.findById(id);
        return byId
                .flatMap(order -> {
                    if (order.getImages() == null) {
                        order.setImages(new ArrayList<>());
                    }
                    order.getImages().addAll(images);
                    return orderRepository.save(order);
                }).then(Mono.empty());
    }