如何优雅关闭 Spring Boot 应用

 ## 前言 随着线上应用逐步采用 springboot 构建，springboot应用实例越来多，当线上某个应用需要升级部署时，常常简单粗暴地使用 kill 命令，这种停止应用的方式会让应用将所有处理中的请求丢弃，响应失败。这样的响应失败尤其是在处理重要业务逻辑时需要极力避免的，那么有什么更好的方式来平滑地关闭 springboot 应用呢？那就通过本文一起来探究吧。（本文主要针对基于spring boot 内嵌 tomcat 容器作为 web 服务的应用） > 本文示例代码可以通过下面仓库地址获取： > > - springboot-shutdown：https://github.com/wrcj12138aaa/springboot-shutdown > > 环境支持： > > - jdk 8 > - springboot 2.1.4 > - maven 3.6.0 ## 定制 tomcat connector 行为 要平滑关闭 spring boot 应用的前提就是首先要关闭其内置的 web 容器，不再处理外部新进入的请求。为了能让应用接受关闭事件通知的时候，保证当前 tomcat 处理所有已经进入的请求，我们需要实现 tomcatconnectorcustomizer 接口，这个接口的源码十分简单，从注释可以看出这是实现自定义 tomcat connector 行为的回调接口：  这里如果小伙伴对 connector 不太熟悉，我就简单描述下：connector 属于 tomcat 抽象组件，功能就是用来接受外部请求，以及内部传递，并返回响应内容，是tomcat 中请求处理和响应的重要组件，具体实现有 http connector 和 ajp connector。 通过定制 connector 的行为，我们就可以允许在请求处理完毕后进行 tomcat 线程池的关闭，具体实现代码如下：  上述代码定义的 timeout 变量为 tomcat 线程池延时关闭的最大等待时间，一旦超过这个时间就会强制关闭线程池，也就无法处理所有请求了，我们通过控制 tomcat 线程池的关闭时机，来实现优雅关闭 web 应用的功能。另外需要注意的是我们的类 customshutdown 实现了 applicationlistener 接口，意味着监听着 spring 容器关闭的事件，即当前的 applicationcontext 执行 close 方法。 ## 内嵌 tomcat 添加 connector 回调 有了定制的 connector 回调，我们需要在启动过程中添加到内嵌的 tomcat 容器中，然后等待执行。那这一步又是如何实现的呢，可以参考下面代码：  这里的 tomcatservletwebserverfactory 是 spring boot 实现内嵌 tomcat 的工厂类，类似的其他 web 容器，也有对应的工厂类如 jettyservletwebserverfactory，undertowservletwebserverfactory。他们共同的特点就是继承同个抽象类 abstractservletwebserverfactory，提供了 web 容器默认的公共实现，如应用上下文设置，会话管理等。 如果我们需要定义spring boot 内嵌的 tomcat 容器时，就可以使用 tomcatservletwebserverfactory 来进行个性化定义，例如下方为官方文档提供自定示例：  好了说回正题，我们这里使用 `addconnectorcustomizers` 方法将自定义的 connector 行为添加到内嵌的tomcat 之上，为了查看加载效果，我们可以在 spring boot 程序启动后从容器中获取下webserverfactory 对象，然后观察，在它的 tomcatconnectorcustomizers 属性中可以看到已经有了 customeshutdown 对象。  ## 开启 shutdown endpoint 到目前让内嵌 tomcat 容器平稳关闭的操作已经完成，接下来要做的就是如何关闭主动关闭 spring 容器了，除了常规linux 命令 kill，我们可以利用 spring boot actuator 来实现spring 容器的远程关闭，怎么实现继续看 spring boot actuator 是 spring boot 的一大特性，它提供了丰富的功能来帮助我们监控和管理生产环境中运行的 spring boot 应用。我们可以通过 http 或者 jmx 方式来对我们应用进行管理，除此之外，它为我们的应用提供了审计，健康状态和度量信息收集的功能，能帮助我们更全面地了解运行中的应用。 > actuator， ['æktʃʊˌeɪtə] 中文翻译过来就是制动器，这是一个制造业的术语，指的是用于控制某物的机械装置。 在 spring boot actuator 中也提供控制应用关闭的功能，所以我们要为应用引入 spring boot actuator，具体方式就是要将对应的 starter 依赖添加到当前项目中，以 maven 项目为例：  spring boot actuator 采用向外部暴露 endpoint (端点)的方式来让我们与应用进行监控和管理，引入 `spring-boot-starter-actuator` 之后，我们就需要启用我们需要的 shutdown endpoint，在配置文件 application.properties 中，设置如下  第一行表示启用 shutdown endpoint ，第二行表示向外部以 http 方式暴露所有 endpoint，默认情况下除了 shutdown endpoint 之外，其他 endpoint 都是启用的。 > 除了 shutdown endpoint，actuator endpoint 还有十余种，有的是特定操作，比如 `heapdump` 转储内存日志；有的是信息展示，比如 `health` 显示应用健康状态。具体所有 endpoint 信息可以参见官方文档-53. endpoints 一节。 到这里我们的前期配置工作就算完成了。当启动应用后，就可以通过post 方式请求对应路径的 `http://host:port/actuator/shutdown` 来实现spring boot 应用远程关闭，是不是很简单呢。 ## 模拟测试 这里为了模拟测试，我们首先模拟实现长达10s 时间处理业务的请求控制器 businesscontroller，具体实现如下：  用 `thread.sleep` 来阻塞当前请求线程，模拟业务处理，在此同时用 http 方式访问 shutdown endpoint 试图关闭应用，可以通过观察控制台日志看是否应用是否会完成请求的处理后才真正进行关闭。 首先用 curl 命令模拟发送业务请求：  然后在业务处理中，直接发送请求 `actuator/shutdown`,尝试关闭应用，同样采用 curl 方式：  `actuator/shutdown` 请求发送后会立即返回响应结果，但应用并不会停止：  最后看下控制台的日志输出顺序：  可以看出在发送业务请求之后立刻发送关闭应用的请求，并不会立即将应用停止，而是在请求处理完毕之后，就是阻塞的 10s 后应用开始退出，这样可以保证已经接收到的请求能返回正常响应, 而关闭请求之后再进入的请求都不会被处理，到这里我们优雅关闭 spring boot 程序的操作就此实现了。 ## 实现自动化 由于 spring boot 提供内嵌 web 容器的便利性，我们经常将程序打包成 jar 然后发布。通常应用的启动和关闭操作流程是固定且重复的，本着 don't repeat yourself 原则，我们有必要将这个操作过程自动化，将关闭和启用的 springboot应用的操作写成 shell 脚本，以避免出现人为的差错，并且方便使用，提高操作效率。下面是我针对示例程序所写的程序启动脚本：(具体脚本可在示例项目查看)  有了脚本，我们可以直接通过命令行方式平滑地更新部署 spring boot 程序，效果如下：  ## 总结 本文主要探究了如何对基于spring boot 内嵌 tomcat 的 web 应用进行平滑关闭的实现，如果采用其他 web 容器也类似方式，希望这边文章有所帮助，若有错误或者不当之处，还请大家批评指正，一起学习交流。 ## 参考 - graceful shutdown spring boot applications：https://blog.marcosbarbero.com/graceful-shutdown-spring-boot-apps/ - shutdown a spring boot application：https://www.baeldung.com/spring-boot-shutdown - 官方文档-53. endpoints：https://docs.spring.io/spring-boot/docs/2.1.4.release/reference/htmlsingle/#production-ready-endpoints - the http connector：https://tomcat.apache.org/tomcat-8.5-doc/config/http.html - customizing configurableservletwebserverfactory directly：https://docs.spring.io/spring-boot/docs/2.1.4.release/reference/htmlsingle/#boot-features-customizing-configurableservletwebserverfactory-directly **推荐阅读：** [《深入理解 java 内存模型》读书笔记](http://mp.weixin.qq.com/s?__biz=mzu0mdewmjgwna==&mid=2247485768&idx=1&sn=baeb6e3e6ce1c22b8b87bbcd1e968152&chksm=fb3f10b3cc4899a51205e06df69bab0632636f13217062eaa6dbe678bc9fe1db883e5f54fe63&scene=21#wechat_redirect) [面试-基础篇](http://mp.weixin.qq.com/s?__biz=mzu0mdewmjgwna==&mid=2247485764&idx=1&sn=418a946e30a9dc1d3166da3d83a90d8d&chksm=fb3f10bfcc4899a92d510f7d2c612536626ead30d4e0ace82e89c50210d4fd09ce48fd924c37&scene=21#wechat_redirect) [spring boot 2.0 迁移指南](http://mp.weixin.qq.com/s?__biz=mzu0mdewmjgwna==&mid=2247485754&idx=1&sn=9158ea22e664aad9972f2582e66a215c&chksm=fb3f10c1cc4899d7ec106aa0c1e7ef4e7217fdf91dd852d5a34b0f3f88c321cf36e03a55c6ec&scene=21#wechat_redirect) [springboot使用docker快速部署项目](http://mp.weixin.qq.com/s?__biz=mzu0mdewmjgwna==&mid=2247485741&idx=1&sn=b048dfa7110ac22b09319af5806a8307&chksm=fb3f10d6cc4899c0338be7ba5c7b63688a8d8c0ce3d2a56d2db387636f9939c2a951f8280c60&scene=21#wechat_redirect) **为什么选择 spring 作为 java 框架？** **springboot rocketmq 整合使用和监控** **spring boot 面试的十个问题** **上篇好文：** [使用 spring framework 时常犯的十大错误](http://mp.weixin.qq.com/s?__biz=mzu0mdewmjgwna==&mid=2247485793&idx=1&sn=d832f0318916628b8867df21a030adf1&chksm=fb3f109acc48998ced40390c8e01a33c37cb96a06c90b96ba34f81fd51a5aa70ce3792a6847d&scene=21#wechat_redirect) ****