如何从Spring Integration WebFlux集成流创建Reactor Flux？

数据老陈

2026-5-27

从Spring MVC集成流迁移到Spring Integration WebFlux的实践指南

嘿，我刚好折腾过这个迁移，结合Spring Integration WebFlux模块的特性，给你梳理下核心的替换步骤和踩过的坑：

替换MVC版的Http.inboundChannelAdapter
直接用WebFlux.inboundChannelAdapter替代，这是spring-integration-webflux模块专门为WebFlux场景打造的入站适配器，天然支持Reactor Flux的异步流处理。举个简单的配置示例：

@Bean
public IntegrationFlow webFluxInboundFlow() {
    return IntegrationFlows.from(WebFlux.inboundChannelAdapter("/webflux-integration")
                    .requestMapping(m -> m.methods(HttpMethod.GET)))
            .handle((payload, headers) -> {
                // 这里可以直接返回Flux类型的处理结果
                return Flux.just("WebFlux Integration", "Success!");
            })
            .get();
}

替代@GetMapping处理器
之前用@GetMapping配合消息通道的方式，现在可以直接通过WebFlux.inboundChannelAdapter的配置绑定请求路径、请求方法，不需要单独写@Controller类。如果要处理请求参数、请求头，也可以通过适配器的payloadExpression或headerExpressions来提取，比如：
```
WebFlux.inboundChannelAdapter("/webflux-inbound")
        .payloadExpression("#request.queryParams.getFirst('id')")
```
注意消息Payload的类型适配
WebFlux适配器传递的Payload默认是ServerWebExchange或者请求体的Reactor类型，和MVC版的HttpServletRequest完全不同。比如要获取请求参数，得这么写：
```
ServerWebExchange exchange = (ServerWebExchange) payload;
String param = exchange.getRequest().getQueryParams().getFirst("param");
```
响应流的自动适配
当你的处理逻辑返回Flux类型时，WebFlux适配器会自动把它转换成对应的响应流，不用像MVC版那样手动做响应适配，这一点体验顺畅很多。