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的对比
功能 | WebHandler | HttpHandler |
---|---|---|
过滤器链支持 | 支持(WebFilter ) | 不支持 |
异常处理 | 支持(WebExceptionHandler ) | 不支持 |
会话管理 | 支持(WebSession ) | 不支持 |
与 Spring WebFlux 集成 | 高度集成 | 手动集成 |
响应式上下文 | 支持(Context ) | 不支持 |
高级请求/响应处理 | 支持(ServerWebExchange ) | 手动实现 |
相关文章:

Spring Boot之Web服务器的启动流程分析
如何判断创建哪种web容器:servlet?reactive? 我们在启动Spring Boot程序的时候,会使用SpringApplication.run方法来启动,在启动流程中首先要判断的就是需要启动什么类型的服务器,是servlet?或者…...
C# SQLite高级功能示例
目录 1 主要功能 2 程序结构和流程 3 详细实现说明 3.1 基础设置 3.2 事务演示 3.3 索引演示 3.4 视图演示 3.5 触发器演示 3.6 全文搜索演示 3.7 窗口函数演示 3.8 外键约束演示 4 高级功能示例 5 单个方法详细介绍 5.1 SetupExampleData()方法 5.2 UseTransact…...

【周输入】510周阅读推荐-1
本号一年了,有一定的成长,也有很多读者和点赞。自觉更新仍然远远不够,需要继续努力。 但是还是要坚持2点: 在当前这个时代,信息大爆炸,层次不齐,不追加多, 信息输入可以很多&#x…...

基于动态规划的强化学习方法
目录 # 动态规划 # 基于动态规划的强化学习方法 # 求解过程: ## 策略评估 ## 策略提升 # 价值迭代算法 # 参考 # 动态规划 动态规划的基本思想是将待求解问题分解成若干个子问题,先求解子问题,然后从这些子问题的解得到目标问题的解。…...
启动 spyder ModuleNotFoundError: No module named ‘PyQt5.QtWebKitWidgets‘
一、根本原因 Spyder 版本兼容性:Spyder 4.x 依赖 QtWebKitWidgets,但该模块在 PyQt5 5.15 中已被移除。 PyQt5 版本冲突:如果你安装了较新的 PyQt5(如 5.15),则会缺少 QtWebKitWidgets。 二、解决方案 方法…...
ChemBlender:科研绘图创新解决方案
一、研究背景与冲突 (一)研究背景 在科学研究领域,可视化表达对于成果的呈现与交流至关重要。科研绘图作为科学可视化的关键手段,涵盖了从微观分子结构到宏观实验现象等广泛的内容。随着科研的深入发展,研究对象的复杂…...

Uniapp Android/IOS 获取手机通讯录
介绍 最近忙着开发支付宝小程序和app,下面给大家介绍一下 app 获取通讯录的全部过程吧,也是这也是我app开发中的一项需求吧。 效果图如下 勾选配置文件 使用uniapp开发的童鞋都知道有一个配置文件 manifest.json 简单的说一下,就是安卓/ios/…...
设计一个分布式系统:要求全局消息顺序,如何使用Kafka实现?
一、高吞吐低延迟 Kafka 集群设计要点 1. 分区策略优化 // 计算合理分区数公式(动态调整) int numPartitions max(Tp, Tc) / min(Tp, Tc) // Tp生产者吞吐量 Tc消费者吞吐量建议初始按业务键(如订单ID)哈希分区单分区吞吐建议…...

2025年RIS SCI2区,改进白鲸优化算法+复杂非线性方程组求解,深度解析+性能实测
目录 1.摘要2.白鲸优化算法BWO原理3.改进策略4.结果展示5.参考文献6.代码获取7.读者交流 1.摘要 本文提出了一种改进白鲸优化算法(ABWOA)用来解决非线性方程组(SNLEs)求解问题。ABWOA引入了平衡因子和非线性自适应参数࿰…...

Java后端开发day48--反射动态代理
(以下内容全部来自上述课程) 反射 反射允许对成员变量,成员方法和构造方法的信息进行编程访问。 就是获取里面的成员变量、构造方法和成员方法,idea中打代码跳出来的提示就是反射。 1. 获取class对象的三种方式 Class.for…...
十四、继承与组合(Inheritance Composition)
十四、继承与组合(Inheritance & Composition) 引言 C最引人注目的特性之一是代码复用。组合:在新类中创建已有类的对象。继承:将新类作为已有类的一个类型来创建。 14.1 组合的语法 Useful.h //C14:Useful.h #ifndef US…...

ValueError: Caught ValueError in DataLoader worker process 0.
参考链接: https://stackoverflow.com/questions/1841565/valueerror-invalid-literal-for-int-with-base-10 它提示我有个地方值错误空字符 果然因为格式处理没有传进去东西,找下原因,让它正常处理 原来是相对路径的.影响了程序运行 将v…...

【数据结构】——链表OJ(下)
前面我们已经刷了几道单链表的题目,下面我们继续看几道题目。 一、相交链表 这道题题目的要求是很好理解的,就是现在我们有两个链表,然后我们就相办法进行判断,这两个链表是否是相交的,那么链表的相交其实就是有没有共…...

Adobe Acrobat pro在一份PDF中插入空白页
在Adobe Acrobat pro中先打开我们的PDF文件; 用鼠标点击需要插入空白页处的上一页; 然后如下图操作: 默认会在光标处的下一页插入一张空白页,你也可以修改插入页的页码或者向前一页插入...

java-----异常
对于Error:表示系统级错误或者资源耗尽的状况,像OutOfMemoryError、StackOverflowError等。这类错误是程序无法处理的,通常也不应该尝试去处理。 对于Exception:表示程序可以处理的异常。它又能细分为: 受检查异常&a…...

[工具]B站缓存工具箱 (By 郭逍遥)
📌 项目简介 B站缓存工具箱是一个多功能的B站缓存工具,包含视频下载、缓存重载、文件合并及系统设置四大核心功能。基于yutto开发,采用图形化界面操作,极大简化B站资源获取与管理流程。 工具可以直接将原本缓存的视频读取&#…...
《内网渗透测试:绕过最新防火墙策略》
内网渗透测试是检验企业网络安全防御体系有效性的核心手段,而现代防火墙策略的持续演进(如零信任架构、AI流量分析、深度包检测)对攻击者提出了更高挑战。本文系统解析2024年新型防火墙的防护机制,聚焦协议隐蔽隧道、上下文感知绕…...
python_竞态条件
好的,我们通过一个具体的例子来说明在多线程环境中,可变对象和不可变对象的行为差异,以及不可变对象如何避免竞态条件(race condition)。 1. 竞态条件(Race Condition) 竞态条件是指在多线程环…...
聊聊JetCache的CachePenetrationProtect
序 本文主要研究一下JetCache的CachePenetrationProtect CachePenetrationProtect com/alicp/jetcache/anno/CachePenetrationProtect.java Documented Retention(RetentionPolicy.RUNTIME) Target({ElementType.METHOD, ElementType.FIELD}) public interface CachePenetr…...
【实战】基于 ABP vNext 构建高可用 S7 协议采集平台(西门子 PLC 通信全流程)
🚀🔧【实战】基于 ABP vNext 构建高可用 S7 协议采集平台(西门子 PLC 通信全流程)📊 📑 目录 🚀🔧【实战】基于 ABP vNext 构建高可用 S7 协议采集平台(西门子 PLC 通信全…...
数据结构:树(Tree)
目录 为什么需要树? 🌱 基本的树结构定义 什么是树? 树的术语 🌿 常见基本树的变体 🌳 二叉搜索树(BST) 🌲 自平衡二叉搜索树 1. AVL树(Adelson-Velsky and La…...

自动化测试与功能测试详解
🍅 点击文末小卡片,免费获取软件测试全套资料,资料在手,涨薪更快 什么是自动化测试? 自动化测试是指利用软件测试工具自动实现全部或部分测试,它是软件测试的一个重要组成 部分,能完成许多手工测试无…...
java中的Optional
在 Java 8 中,Optional 是一个用于处理可能为 null 的值的容器类,旨在减少空指针异常(NullPointerException)并提升代码的可读性。以下是 Optional 的核心用法和最佳实践: 1. 创建 Optional 对象 1.1 常规创建方式 Op…...
Qt事件循环机制
受事件循环机制影响,按钮的样式表改变了可能不会立即刷新。 需要使用 update() 或 repaint() 或者调用 QApplication::processEvents() 强制处理所有待处理的事件,从而确保界面更新。 在 Qt 中,事件循环(Event Loop)是…...
深入理解 OAuth 2.0:技术核心与实战场景
在互联网应用日益复杂的今天,如何安全、高效地实现第三方应用授权访问资源,成为开发者面临的重要问题。OAuth 2.0 凭借其灵活、安全的授权机制,成为解决这一问题的主流方案。本文将深入剖析 OAuth 2.0 的技术重点,并结合具体使用场…...
Rust 环境变量管理秘籍:从菜鸟到老鸟都爱的 dotenv 教程
前言 写代码的你,是否遭遇过这些灵魂拷问: “我现在在哪个环境?开发?测试?还是直接在生产线上裸奔?”“少写一个 .env,测试脚本在数据库里上演清空大法,客户当场破防。”“每次手动设置 RUST_ENV,命令敲到一半就开始怀疑人生,还怕输错一个字符引发灭世级事故。”别慌…...

CSS经典布局之圣杯布局和双飞翼布局
目标: 中间自适应,两边定宽,并且三栏布局在一行展示。 圣杯布局 实现方法: 通过float搭建布局margin使三列布局到一行上relative相对定位调整位置; 给外部容器添加padding,通过相对定位调整左右两列的…...

OpenCV 的 CUDA 模块中用于将多个单通道的 GpuMat 图像合并成一个多通道的图像 函数cv::cuda::merge
操作系统:ubuntu22.04 OpenCV版本:OpenCV4.9 IDE:Visual Studio Code 编程语言:C11 算法描述 在 OpenCV 的 CUDA 模块中,cv::cuda::merge 函数用于将多个单通道的 GpuMat 图像合并成一个多通道的图像。该函数是 cv::merge 的 GP…...

计网实验笔记(一)CS144 Lab
Lab0 ByteStream : 实现一个在内存中的 有序可靠字节流Lab1 StreamReassembler:实现一个流重组器,一个将字节流的字串或者小段按照正确顺序来拼接回连续字节流的模块Lab2 TCPReceiver:实现入站字节流的TCP部分。Lab3 TCPSender:实…...
Blog Contents
目录 Python Financing Medical Logistics Tool(IT & AI) 持续更新~ Python # Name URL 1 Python | Dashboard制作 Python | Dashboard制作-CSDN博客 2 Python | AKShare获取A股数据 Python | AKShare获取A股数据-CSDN博客 3 Python | A股指标对比 Python | A股…...