返回顶部
首页 > 资讯 > 后端开发 > Python >SpringCloudGatewayHttpWebHandlerAdapter链路调用请求流程介绍
  • 154
分享到

SpringCloudGatewayHttpWebHandlerAdapter链路调用请求流程介绍

SpringCloudHttpWebHandlerAdapterSpringCloudGatewayHttpWebHandlerAdapter 2022-11-13 18:11:10 154人浏览 独家记忆

Python 官方文档:入门教程 => 点击学习

摘要

目录前言WEB容器前言 上一节我们说到从HttpWebHandlerAdapter的handle方法说起到DispatcherHandler的调用流程 那么HttpWebHandle

前言

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

到此这篇关于SpringCloud Gateway HttpWebHandlerAdapter链路调用请求流程介绍的文章就介绍到这了,更多相关SprinGCloud HttpWebHandlerAdapter内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网!

--结束END--

本文标题: SpringCloudGatewayHttpWebHandlerAdapter链路调用请求流程介绍

本文链接: https://lsjlt.com/news/169874.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

猜你喜欢
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作