异步环境下请求处理的核心 -Spring Boot + Spring WebFlux 的 WebHandler

我们创建的简易网关，外层的服务容器其实就是基于 Netty 和 Project Reactor 的容器，我们跳过这些，直接进入 Spring Boot 相关的处理逻辑。我们只需要知道，请求和其对应的响应，会被外层的容器封装成为 ServerHttpRequest request 和 ServerHttpResponse response(都在 org.springframework.http.server.reactive 这个包下)。

然后，会交由 WebHandler 进行处理。WebHandler 的实现，其实是一种责任链装饰模式，如下图所示。每一层的 WebHandler 会将 request 和 response 进行对应自己责任的装饰，然后交给内层的 WebHandler 处理。

HttpWebHandlerAdapter - 将请求封装成 ServerWebExchange

WebHandler 的接口定义是：

public interface WebHandler {
	Mono<Void> handle(ServerWebExchange exchange);
}
复制代码

但是最外层传进来的参数是 request 和 response，需要将他们封装成 ServerWebExchange，这个工作就是在 HttpWebHandlerAdapter 中做的。HttpWebHandlerAdapter 其实主要任务就是将各种参数封装成 ServerWebExchange（除了和本次请求相关的 request 和 response，还有会话管理器 SessionManager，编码解码器配置，国际化配置还有 ApplicationContext 用于扩展）。

除了这些，处理 Forwarded 还有 X-Forwarded* 相关的 Header 的配置逻辑，也在这里进行。然后将封装好的 ServerWebExchange 交给内层的 WebHandler 即 ExceptionHandlingWebHandler 继续处理。同时，从源码中可以看出，交给内层处理的 Mono 还加入了异常处理和记录响应信息的逻辑：

HttpWebHandlerAdapter.java

//交给内层处理封装好的 `ServerWebExchange`
return getDelegate().handle(exchange)
        //记录响应日志，trace 级别，一般用不上
		.doOnSuccess(aVoid -> logResponse(exchange))
		//处理内层没有处理的异常，一般不会走到这里
		.onErrorResume(ex -> handleUnresolvedError(exchange, ex))
		//在所有处理完成后，将 response 设为 complete
		.then(Mono.defer(response::setComplete));

链接：https://juejin.cn/post/7034154961776672805