SpringWebFlux执行过程

Spring WebFlux的出现带来了异步响应式编程的福音，随着它不断的完善，使用者会逐渐的变多，作为经常拿来与Spring MVC对比的框架。

它的执行过程，设计上与Spring MVC有什么区别呢？

大致看了下其源码，做了简要梳理。

启动

1 仍然保持原有的方式启动应用，那么Spring如何知道要启动WebFlux应用呢？

• WebApplicationType枚举类中，deduceFromClasspath判断如果存在DispatcherHandler，然后一些其它条件，那么系统认为要启动的是Reactive的应用
• 否则，采用Servlet应用

SpringApplication#run(java.lang.String...)
    context = createApplicationContext();
    switch (this.webApplicationType) {
                case SERVLET:
                    contextClass = Class.forName(DEFAULT_SERVLET_WEB_CONTEXT_CLASS);
                    break;
                case REACTIVE:
                    contextClass = Class.forName(DEFAULT_REACTIVE_WEB_CONTEXT_CLASS);
                    break;
                default:
                    contextClass = Class.forName(DEFAULT_CONTEXT_CLASS);
                }

2 在上下文刷新之后，启动Reactive服务。

image.png

运行

1 首先肯定是从Netty的channelRead开始，不过我们从接近我们的链路开始分析。

reactor.netty.http.server.HttpServerHandle#onStateChange

->ReactorHttpHandlerAdapter.apply 封装Request，Response。ReactorServerHttpRequest

-> HttpWebHandlerAdapter.handle 创建ServerWebExchange

-> ExceptionHandlingWebHandler.handle

-> FilteringWebHandler.handle

-> DefaultWebFilterChain.handle 使用WebFilter在请求处理前进行filter

-> DispatcherHandler.handle 与Spring MVC对应，HandlerMapping，HandlerAdpater

-> handlerAdapter.handle

-> 调用我们的业务代码

-> 后续定义结果封装处理

最后

大流程上看起来不难理解，不过还是可以多看几遍学习下其设计方式。