SpringBoot 优雅停机的正确姿势

​一、介绍

什么叫优雅停机?

为新罗等地区用户提供了全套网页设计制作服务,及新罗网站建设行业解决方案。主营业务为成都网站制作、成都网站设计、外贸营销网站建设、新罗网站设计,以传统方式定制建设网站,并提供域名空间备案等一条龙服务,秉承以专业、用心的态度为用户提供真诚的服务。我们深信只要达到每一位用户的要求,就会得到认可,从而选择与我们长期合作。这样,我们也可以走得更远!

简单的说,就是向应用进程发出停止指令之后,能保证正在执行的业务操作不受影响,直到操作运行完毕之后再停止服务。应用程序接收到停止指令之后,会进行如下操作:

  • 1.停止接收新的访问请求
  • 2.正在处理的请求,等待请求处理完毕;对于内部正在执行的其他任务,比如定时任务、mq 消费等等,也要等当前正在执行的任务执行完毕,并且不再启动新的任务
  • 3.当应用准备关闭的时候,按需向外发出信号,告知其他应用服务准备接手,以保证服务高可用

如果暴力的关闭应用程序,比如通过kill -9 命令强制直接关闭应用程序进程,可能会导致正在执行的任务数据丢失或者错乱,也可能会导致任务所持有的全局资源等不到释放,比如当前任务持有 redis 的锁,并且没有设置过期时间,当任务突然被终止并且没有主动释放锁,会导致其他进程因无法获取锁而不能处理业务。

那么如何在不影响正在执行的业务的情况下,将应用程序安全的进行关闭呢?

二、方案实践

SpringBoot 官方文档上,已经告诉开发者只需要实现特定接口即可监听到项目启动成功与关闭时的事件,相关接口如下:

  • CommandLineRunner​接口:当应用启动成功后但在开始接受流量之前,会回调此接口的实现类,也可以实现ApplicationRunner接口,工作的方式与CommandLineRunner与之类似
  • DisposableBean​接口:当应用正要被销毁前,会回调此接口的实现类,也可以使用@PreDestroy注解,被标记的方法也会被调用

基于此流程,我们可以创建一个服务监听类,用于监听到项目启动成功与关闭时的回调服务,示例代码如下:

@Component
public class AppListener implements CommandLineRunner, DisposableBean {

@Override
public void run(String... args) throws Exception {
System.out.println("应用启动成功,预加载相关数据");
}

@Override
public void destroy() throws Exception {
System.out.println("应用正在关闭,清理相关数据");
}

}

每一个SpringApplication​在启用的时候,都会向 JVM 注册一个关闭钩子shutdown hook​,以确保ApplicationContext在退出的时候,通过这个勾子通知 JVM,实现服务正常的关闭,以下介绍的所有关闭服务的方法,都是基于这一原理进行实现的。

2.1、方法一:通过Actuator的Endpoint机制关闭服务

使用此方法,需要先添加spring-boot-starter-actuator监控服务依赖包,


org.springframework.boot
spring-boot-starter-actuator

默认配置下,shutdown​端点是关闭的,需要在application.properties里配置里面开启:

management.endpoint.shutdown.enabled=true

虽然Actuator​的端点,支持通过JMX或HTTP​进行远程访问。而shutdown​默认配置下是不支持HTTP​进行Web​访问的,所以使用HTTP请求进行关闭时的配置,也需要开启:

management.endpoints.web.exposure.include=shutdown

最后将SpringBoot​服务启动之后,使用POST请求类型,调用以下接口,即可实现关闭服务!

http://127.0.0.1:8080/actuator/shutdown

2.2、方法二:使用ApplicationContext的close方法关闭服务

如果你不想添加spring-boot-starter-actuator​监控服务依赖包来关停服务,也可以使用ApplicationContext的close​方法来关停服务,他会自动销毁bean对象并关停服务。

只需要在应用启用的时候,获取ApplicationContext​对象,然后在相关的位置调用close方法,就可以关闭服务。

示例代码如下:

@SpringBootApplication
public class Application {

public static void main(String[] args){
ConfigurableApplicationContext context = SpringApplication.run(Application.class, args);

try {
TimeUnit.SECONDS.sleep(10);
} catch (InterruptedException e) {
e.printStackTrace();
}
//启动10秒以后,自动关闭
context.close();
}
}

当然我们也可以自己写一个Controller​,获取对应的ApplicationContext​对象,通过api​操作调用close方法关停服务,示例代码如下:

@RestController
public class ShutdownController implements ApplicationContextAware {

private ApplicationContext context;

@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
this.context = applicationContext;
}

/**
* 关闭服务
*/
@GetMapping("/shutdown")
public void shutdownContext(){
((ConfigurableApplicationContext) context).close();
}
}

2.3、方法三:监听服务pid,通过kill方式关闭服务

通过api方式来关停服务,在很多人看来并不安全,因为一旦接口泄漏了,意味着用户可以随便请求这个接口来关闭服务,其影响不言而喻,因此很多人建议在服务端,通过其他的方式来关闭服务,比如通过进程命令方式来关停。

在springboot​启动的时候将应用进程 ID 写入一个app.pid文件,生成的路径可以指定,然后通过脚本命令方式来关闭服务。

启动示例代码如下:

@SpringBootApplication
public class Application {

public static void main(String[] args){
SpringApplication application = new SpringApplication(Application.class);
application.addListeners(new ApplicationPidFileWriter("/home/app/project1/app.pid"));
application.run();
}
}

通过如下命令方式,可以安全的关闭服务。

cat /home/app/project1/app.pid | xargs kill

这种方式,也是目前在linux操作系统中,使用较为普遍的一种解决方案,区别在于实现的方式可能不同,有的不用写文件,通过其他方式来获取应用进程 ID。

如果使用​kill -9 的方式关闭服务,服务的监听器不会收到任何消息,类似于直接强杀应用进程,此方法不可取!

2.4、方法四:使用SpringApplication的exit方法关闭服务

通过调用一个SpringApplication.exit()​方法也可以安全的退出程序,同时会返回一个退出码,这个退出码可以传递给所有的context​,最后通过调用System.exit()​可以将这个错误码也传给JVM。

示例代码如下:

@SpringBootApplication
public class Application {

public static void main(String[] args){
ConfigurableApplicationContext context = SpringApplication.run(Application.class, args);

try {
TimeUnit.SECONDS.sleep(5);
} catch (InterruptedException e) {
e.printStackTrace();
}
//5秒后,关闭服务
exitApplication(context);
}

public static void exitApplication(ConfigurableApplicationContext context){
//获取退出码
int exitCode = SpringApplication.exit(context, (ExitCodeGenerator) () -> 0);
//退出码传递给jvm,安全退出程序
System.exit(exitCode);
}

}

三、其他监听介绍

3.1、ApplicationListener

如果有些服务,比如定时任务,我们想在SpringBoot​关闭数据源连接池之前,将其关闭,可以通过实现ApplicationListener​接口,监听bean​对象的变化情况,在bean对象销毁之前,执行相关的关闭任务。

示例代码如下:

@Component
public class JobTaskListener implements ApplicationListener {

@Override
public void onApplicationEvent(ApplicationEvent applicationEvent){
// 在spring bean容器销毁之前执行的事件,防止数据库连接池在任务终止前销毁
if (applicationEvent instanceof ContextClosedEvent) {
System.out.println("关闭相关的定时任务");
}
}
}

3.2、PreDestroy

上文中,我们提到了实现DisposableBean​接口,可以监听应用关闭前的回调处理,其实在自定义的方法上加@PreDestroy注解,也可以实现相同的效果。

示例代码如下:

@Component
public class AppDestroyConfig {

@PreDestroy
public void PreDestroy(){
System.out.println("应用程序正在关闭。。。");
}
}

四、小结

本位主要围绕如何安全的关闭SpringBoot服务,进行了一些方案操作的介绍,如果有疏漏的地方,欢迎网友批评指出!

分享标题:SpringBoot 优雅停机的正确姿势
文章路径:http://www.shufengxianlan.com/qtweb/news39/292039.html

网站建设、网络推广公司-创新互联,是专注品牌与效果的网站制作,网络营销seo公司;服务项目有等

广告

声明:本网站发布的内容(图片、视频和文字)以用户投稿、用户转载内容为主,如果涉及侵权请尽快告知,我们将会在第一时间删除。文章观点不代表本网站立场,如需处理请联系客服。电话:028-86922220;邮箱:631063699@qq.com。内容未经允许不得转载,或转载时需注明来源: 创新互联