spring boot webflux中的后期处理

Question

我在 restcontroller 中有一个方法。我需要在方法执行完全完成后将输入请求转换为字符串并发送到另一个目的地，理想情况下我不应该影响方法处理执行，方法应该在没有额外延迟的情况下执行。 在非 webflux 应用程序中，我可以在 HandlerIntercepter 中使用 afterCompletion。但由于使用了 WebFlux，我无法使用它。 控制器方法执行结束并返回给调用者响应后如何进行额外处理？

Answer 1

如果您要调用的逻辑特定于这一控制器，您可以使用doFinally。它在您的 Stream (Mono/Flux) 终止后执行。 https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html#doFinally-java.util.function.Consumer-

例子：

public class Playground {

    ConverterService converterService;
    PostProcessor postProcessor;

    public Playground(ConverterService converterService, PostProcessor postProcessor) {
        this.converterService = converterService;
        this.postProcessor = postProcessor;
    }

    public Mono<String> endpoint(Integer input) {
        return Mono.just(input)
                .flatMap(integer -> converterService.convert(integer))
                .doFinally(signalType -> postProcess(input));
    }

    private void postProcess(Integer input) {
        this.postProcessor.process(input);
    }

}

首先调用converterService。流终止后，无论如何都会调用postProcessor。