SpringCloud HttpWebHandlerAdapter

时间:2022-10-23 Polarisy丶人气:0

前言

上一节我们说到从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方法

加载全部内容