SpringCloud Gateway HttpWebHandlerAdapter链路调用请求流程介绍

前言

上一节我们说到从HttpWebHandlerAdapter的handle方法说起到DispatcherHandler的调用流程

那么HttpWebHandlerAdapter的handle方法是从哪里来调用的呢？

我们可以找下看哪些类使用了HttpHandler

通过这些类的名字，我们可以发现，HttpHandler 往下就是具体的 Web 容器了，也就是说有具体的 Web 容器来接受请求，然后通过调用 HttpWebHandlerAdapter#handler 来进行后续的处理。这样我们也就明白了 为什么 HttpHandler 的具体实现是一个适配器，因为它要适配不同的底层容器，Spring webFLux 不仅仅可以使用 NettyReactiveWebServer 作为底层Web 容器，也可以使用 tomcat、jetty等 servlet 的容器。

web容器

通过上面分析点进去可以看到

NettyReactiveWebServerFactory.java
@Override
public WebServer getWebServer(HttpHandler httpHandler) {
HttpServer httpServer = createHttpServer();
ReactorHttpHandlerAdapter handlerAdapter = new ReactorHttpHandlerAdapter(httpHandler);
NettyWebServer webServer = createNettyWebServer(httpServer, handlerAdapter, this.lifecycleTimeout,
getShutdown());
webServer.setRouteProviders(this.routeProviders);
return webServer;
}

通过方法名就可以发现这就是得到一个web服务

往上面一直追踪可以找到入口是AbstractApplicationContext#onRefresh方法中，也就是在AbstractApplicationContext#refresh中调用的。熟悉Spring的同学可以看到这就是Spring容器启动的核心方法。

接着上面的代码，可以看到第二行，实例化了ReactorHttpHandlerAdapter对象

点进去可以看到核心的apply方法

@Override
public Mono<Void> apply(HttpServerRequest reactorRequest, HttpServerResponse reactorResponse) {
NettyDataBufferFactory bufferFactory = new NettyDataBufferFactory(reactorResponse.alloc());
try {
ReactorServerHttpRequest request = new ReactorServerHttpRequest(reactorRequest, bufferFactory);
ServerHttpResponse response = new ReactorServerHttpResponse(reactorResponse, bufferFactory);
if (request.getMethod() == HttpMethod.HEAD) {
response = new HttpHeadResponseDecorator(response);
}
            //调用handle方法
return this.httpHandler.handle(request, response)
.doOnError(ex -> logger.trace(request.getLogPrefix() + "Failed to complete: " + ex.getMessage()))
.doOnSuccess(aVoid -> logger.trace(request.getLogPrefix() + "Handling completed"));
}
catch (URISyntaxException ex) {
if (logger.isDebugEnabled()) {
logger.debug("Failed to get request URI: " + ex.getMessage());
}
reactorResponse.status(HttpResponseStatus.BAD_REQUEST);
return Mono.empty();
}
}

可以看到在这里调用开始httpHandler#handle方法，

WebServerManager.java #WebServerManager
this.handler = new DelayedInitializationHttpHandler(handlerSupplier, lazyInit);
this.webServer = factory.getWebServer(this.handler);

此时的httpHandler是DelayedInitializationHttpHandle对象，调用其handle方法

可以看到最后实际调用的是HttpWebHandlerAdapter的handle方法

来源：https://blog.csdn.net/Apandam/article/details/127409087