Spring Integration中AbstractRequestHandlerAdvice结合WebFlux是否引入同步流程？

你的担心有部分道理，但首先要明确：当前的MyLogger实现并没有引入同步阻塞，但它也**没有正确实现“出站请求响应返回后记录日志”**的需求，具体分析如下：

1. WebFlux场景下callback.execute()的行为 #

webflux:outbound-gateway的处理器返回的是Mono/Flux类型的响应式流，调用callback.execute()只是创建了这个流对象，并不会触发实际的HTTP请求（响应式流是冷订阅模型，只有当订阅者触发订阅时才会执行）。所以你当前代码里的“logging after the call”会在callback.execute()调用后立即执行，而不是在HTTP响应返回之后——这完全不符合你想要的“请求后日志”逻辑。

2. 是否引入同步性？ #

不会。doInvoke方法本身是在响应式流的订阅阶段同步执行的，但它没有阻塞线程等待HTTP响应：callback.execute()返回后就直接返回结果，没有任何阻塞操作。WebFlux的非阻塞特性依然保留，只是你的日志逻辑没按预期工作。

3. 正确的响应式日志实现方式 #

要实现“请求发送前、响应返回后（或异常时）”的环绕日志，需要利用响应式操作符装饰返回的Mono/Flux，修改后的doInvoke方法如下：

public class MyLogger extends AbstractRequestHandlerAdvice {

    // ...

    @Override
    protected Object doInvoke(ExecutionCallback callback, Object target, Message<?> message) {
        // 请求发送前日志
        log.info("Sending outbound request: {}", message.getPayload());

        Object result = callback.execute();

        // 根据返回类型装饰响应式流，添加响应后日志
        if (result instanceof Mono) {
            return ((Mono<?>) result)
                    .doOnSuccess(response -> log.info("Received successful response: {}", response))
                    .doOnError(error -> log.error("Request failed with error: {}", error.getMessage(), error))
                    .doOnTerminate(() -> log.info("Request processing completed"));
        } else if (result instanceof Flux) {
            return ((Flux<?>) result)
                    .doOnNext(response -> log.info("Received response element: {}", response))
                    .doOnError(error -> log.error("Request failed with error: {}", error.getMessage(), error))
                    .doOnComplete(() -> log.info("Request streaming completed"));
        }

        // 非响应式场景（兼容原有MVC）
        log.info("Received response: {}", result);
        return result;
    }
}

关键说明 #

• 针对Mono/Flux类型，使用doOnSuccess/doOnError/doOnComplete等操作符，这些操作符会在响应式流的对应阶段异步执行日志逻辑，不会阻塞线程。
• 保留了对非响应式场景的兼容，确保在原有MVC项目中依然能正常工作。
• 这种写法完全遵循WebFlux的响应式编程模型，不会破坏其非阻塞特性，同时准确实现了请求前后的日志需求。

内容的提问来源于stack exchange，提问作者al.truisme