前言
上一节我们说到从HttpWebHandlerAdapter的handle方法说起到DispatcherHandler的调用流程
那么HttpWebHandlerAdapter的handle方法是从哪里来调用的呢？
我们可以找下看哪些类使用了HttpHandler
通过这些类的名字，我们可以发现，HttpHandler 往下就是具体的 Web 容器了，也就是说有具体的 Web 容器来接受请求，然后通过调用 HttpWebHandlerAdapter#handler 来进行后续的处理。这样我们也就明白了 为什么 HttpHandler 的具体实现是一个适配器，因为它要适配不同的底层容器，Spring webFLux 不仅仅可以使用 NettyReactiveWebServer 作为底层Web 容器，也可以使用 tomcat、jetty等 servlet 的容器。
web容器
通过上面分析点进去可以看到
1 2 3 4 5 6 7 8 9 10 | NettyReactiveWebServerFactory.java@Overridepublic 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方法
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 | @Overridepublic Mono 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方法，
1 2 3 | WebServerManager.java #WebServerManager this.handler = new DelayedInitializationHttpHandler(handlerSupplier, lazyInit);this.webServer = factory.getWebServer(this.handler); |
此时的httpHandler是DelayedInitializationHttpHandle对象，调用其handle方法
可以看到最后实际调用的是HttpWebHandlerAdapter的handle方法
到此这篇关于SpringCloud Gateway HttpWebHandlerAdapter链路调用请求流程介绍的文章就介绍到这了,更多相关SpringCloud HttpWebHandlerAdapter内容请搜索IT俱乐部以前的文章或继续浏览下面的相关文章希望大家以后多多支持IT俱乐部！
