Spring Boot之Web服务器的启动流程分析

如何判断创建哪种web容器:servlet?reactive?

我们在启动Spring Boot程序的时候,会使用SpringApplication.run方法来启动,在启动流程中首先要判断的就是需要启动什么类型的服务器,是servlet?或者是reactive?那么spring boot是如何进行判断的呢?

根据上面的流程首先会判断出来要创建的web服务器的类型,然后通过spring.factories文件中的配置的ApplicationContextFactory实现,根据容器类型来创建出对应的容器:

  • reactive:AnnotationConfigReactiveWebServerApplicationContext;
  • servlet:AnnotationConfigServletWebServerApplicationContext;

上面已经创建出了对应的Spring容器,接下来就是要启动服务器来接收请求了,下面来看具体的流程:

我们假设创建的是reactive的容器,即AnnotationConfigReactiveWebServerApplicationContext。该类继承自ReactiveWebServerApplicationContext,该类中重写了生命周期中的onRefresh方法来创建一个WebServer

	@Overrideprotected void onRefresh() {super.onRefresh();try {createWebServer();}catch (Throwable ex) {throw new ApplicationContextException("Unable to start reactive web server", ex);}}

createWebServer()中完成的步骤就是一个:初始化WebServerManager

this.serverManager = new WebServerManager(this, webServerFactory, this::getHttpHandler, lazyInit);

初始化WebServerManager

从容器中获取ReactiveWebServerFactory

在容器中获取,首先需要容器中有ReactiveWebServerFactory的实现,经过查找发现是通过自动配置的方式将ReactiveWebServerFactory的实现加载到spring容器中的。我们查看autoconfiguration的配置发现有ReactiveWebServerFactoryAutoConfiguration自动配置类。

首先web服务需要是reactive类型的,然后通过@Import的方式我们看到加载了多种web服务器。通过打断点的方式,发现此处加载的NettyReactiveWebServerFactory,也就是最终生效的是EmbeddedNetty。这里创建的都是工厂类,还不是实际的web服务器,这里返回的是NettyReactiveWebServerFactory

从容器中获取HttpHandler

HttpHandler是spring处理http协议请求的顶级抽象接口,同样是从容器中获取的该接口的实现。我们还是查看自动配置类,发现HttpHandler的自动配置类是HttpHandlerAutoConfiguration。在自动配置类中通过WebHttpHandlerBuilder最终会创建出HttpHandler。下面看详细的创建流程:

初始化过程中,从容器中获取的WebHandler实现开始,在基础之上依次封装了:负责过滤器执行、负责处理异常、使用适配器将webHandler与httpHandler结合 这三种能力之后完成bean对象的创建。

从上面的流程可以看出,最原始的对象则是在容器中获得的名字为webHandler的实例。那么有没有呢,其实是有的:

上面的配置是在自动配置类WebFluxAutoConfiguration中完成的。

除此之外我们还应注意到的是在步骤2中的applicationContext方法注释:

上面的说明也明确了我们可以进行拓展的地方,比如可以实现WebFilter接口,将自己的过滤逻辑添加进程序的执行流程中。

此时我们得到了构造WebServerManager的主要参数,即有一个WebServerFactory还有一个HttpHandler。接下来就可以来创建WebServerManager对象了。

创建WebServerManager

因为是通过new的方式创建的对象,调用的是WebServerManager的构造器,查看构造器发现多了一个额外的逻辑:通过ReactiveWebServerFactory来创建webServer。接下来来看一下具体流程。

创建webServer

前面提到我们获得到的是NettyReactiveWebServerFactory工厂,通过getWebServer最终会创建出来一个netty服务器。详细的创建流程如下:

首先会通过Netty的HttpServer.create()方法创建出来一个HttpServer。然后就是将我们的httpHandler与netty的handler进行结合。

在netty中插入请求处理器的方式是调用handler方法:HttpServer.handle(this.handler),这里我们的传参就是上面第4步骤返回的适配器handler。这样当netty接收到请求的时候,会通过netty中的handler将请求代理到我们程序的处理逻辑中。

最终创建出来的是NettyWebServer对象,里面包含了Netty服务器、httpHandler和routeProviders。

启动NettyWebServer

上面创建好了Netty服务器,但是还没有启动它,需要把它添加到spring的生命周期中随着程序的启动同时启动web服务器。
spring boot中使用WebServerStartStopLifecycle来管理WebServer的生命周期。WebServerStartStopLifecycle实现了生命周期接口SmartLifecycle,监听到程序的启动start和停止stop。

getBeanFactory().registerSingleton("webServerStartStop",new WebServerStartStopLifecycle(this.serverManager));

总结

针对于reactive类型的Web容器,Spring Boot在启动的时候通过生命周期方法同时会启动Web服务器来接收请求。在使用Netty作为底层Web服务器的时候,通过handler适配器,将我们的业务逻辑处理流程与Netty的请求处理结合在一起,将请求的处理转入到Spring Boot的体系中。

不同的Web服务器的实现则只需要提供对应的适配器将handler进行结合,使请求能够通过适配器转入到Spring Boot的处理逻辑中即可。

我们简单看一下Tomcat服务器的创建代码:

	public WebServer getWebServer(HttpHandler httpHandler) {......// 创建Tomcat服务器实例Tomcat tomcat = new Tomcat();......Connector connector = new Connector(this.protocol);......// 使用Adapter将httpHandler嵌入到tomcat服务器中TomcatHttpHandlerAdapter servlet = new TomcatHttpHandlerAdapter(httpHandler);prepareContext(tomcat.getHost(), servlet);return getTomcatWebServer(tomcat);}

补充知识

WebHandler和HttpHandler的对比

功能WebHandlerHttpHandler
过滤器链支持支持(WebFilter不支持
异常处理支持(WebExceptionHandler不支持
会话管理支持(WebSession不支持
与 Spring WebFlux 集成高度集成手动集成
响应式上下文支持(Context不支持
高级请求/响应处理支持(ServerWebExchange手动实现

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mfbz.cn/a/260.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

影刀RPA开发-采集爬取京东读书书籍

1.采集京东读书 我们先梳理下操作流程 首先,在首页输入要爬取的书籍名称,输入后,搜索 出现搜索结果后,会有很多版本的书籍 我们点击热门筛选,让书记排序,这样可以将最符合我们需求的书籍显示在第一位 点击…

VScode 的插件本地更改后怎么生效

首先 vscode 的插件安装地址为 C:\Users\%USERNAME%\.vscode\extensions 找到你的插件包进行更改 想要打印日志,用下面方法 vscode.window.showErrorMessage(console.log "${name}" exists.); 打印结果 找到插件,点击卸载 然后点击重新启动 …

前端项目2-01:个人简介页面

目录 一.代码显示 二.效果图 三.代码分析 1. 文档声明和 HTML 基本结构 2. CSS 样式部分 全局样式 body 样式 页面主要容器 box 样式 左侧区域 l 样式 右侧区域 r 样式 左侧区域中头像容器 to 样式 头像图片样式及悬停效果 左侧区域中个人信息容器 tit 样式 个人…

针对面试-mysql篇

1.如何定位慢查询? 1.1.介绍一下当时产生问题的场景(我们当时的接口测试的时候非常的慢,压测的结果大概5秒钟)),可以监测出哪个接口,最终因为是sql的问题 1.2.我们系统中当时采用了运维工具(Skywalkin就是2秒,一旦sql执行超过2秒…

无偿帮写毕业论文

以下教程教你如何利用相关网站和AI免费帮你写一个毕业论文。毕竟毕业论文只要过就行,脱产学习这么多年,终于熬出头了,完成毕设后有空就去多看看亲人好友,祝好! 一、找一个论文模板(最好是overleaf) 废话不多说&#…

Spring MVC 根据请求头 (如 Accept) 怎么返回 JSON 或 XML 数据?

Spring MVC 通过 内容协商 (Content Negotiation) 来根据客户端请求的 Accept 头决定返回 JSON、XML 还是其他格式的数据。 以下是核心机制和步骤: 客户端请求中的 Accept 头: 客户端(如浏览器、curl、Postman等)在发起HTTP请求时&#xff0…

Java 线程的堆栈跟踪信息

Java 线程的堆栈跟踪信息,展示了线程的当前状态和执行位置。以下是详细解释: 线程基本信息 "Thread-0" #16 prio5 os_prio0 cpu0.00ms elapsed16.29s tid0x00000243105a4130 nid0x5384 waiting on condition [0x0000007687ffe000]线程名称…

机器学习管道 pipeline

知识回顾: 转化器和估计器的概念管道工程ColumnTransformer和Pipeline类 作业: 整理下全部逻辑的先后顺序,看看能不能制作出适合所有机器学习的通用pipeline 基础概念 pipeline在机器学习领域可以翻译为“管道”,也可以翻译为“流水线”&…

硬件工程师笔记——电子器件汇总大全

目录 1、电阻 工作原理 欧姆定律 电阻的物理本质 一、限制电流 二、分压作用 三、消耗电能(将电能转化为热能) 2、压敏电阻 伏安特性 1. 过压保护 2. 电压调节 3. 浪涌吸收 4. 消噪与消火花 5. 高频应用 3、电容 工作原理 (…

【React中useRef钩子详解】

一、useRef的核心特性 useRef是React提供的Hook,用于在函数组件中创建可变的持久化引用,具有以下核心特性: 持久化存储 返回的ref对象在组件整个生命周期内保持不变,即使组件重新渲染,current属性的值也不会丢失。无触发渲染 修改ref.current的值不会导致组件重新渲染,适…

在 C++中,指针数组与数组指针的区别

1. 指针数组:本质上是一个数组,数组中的每个元素都是一个指针。也就是说,这个数组存储的是多个指针变量,这些指针可以指向不同的对象(比如不同的变量、数组等) 。 2. 数组指针:本质上是一个指针,这个指针指向一个数组。即它指向的是数组的首地址,通过这个指针可以操作…

python打卡训练营打卡记录day22

复习日 仔细回顾一下之前21天的内容,没跟上进度的同学补一下进度。 作业: 自行学习参考如何使用kaggle平台,写下使用注意点,并对下述比赛提交代码 kaggle泰坦尼克号人员生还预测 导入数据 # 导入所需库 import pandas as pd impor…