Springboot项目平滑关闭及自动化关闭脚本

Springboot项目平滑关闭及自动化关闭脚本,供大家参考,具体内容如下

核心代码

  • GracefulShutdown.java
  • Shutdown.java
  • ApplicationStarterRunner.java
  • CommonInfo.java
  • HttpCommonUtil.java
  • application.properties

操作步骤

核心代码

GracefulShutdown.java

package cnkj.site.utils;

import org.apache.catalina.LifecycleException;
import org.apache.catalina.connector.Connector;
import org.apache.catalina.util.LifecycleBase;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.web.embedded.tomcat.TomcatConnectorCustomizer;
import org.springframework.boot.web.embedded.tomcat.TomcatServletWebServerFactory;
import org.springframework.boot.web.servlet.server.ConfigurableServletWebServerFactory;
import org.springframework.context.ApplicationListener;
import org.springframework.context.annotation.Bean;
import org.springframework.context.event.ContextClosedEvent;
import java.util.concurrent.Executor;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/*
 * @version 1.0 created by Carol on 2019/4/25 16:22
 */
public class GracefulShutdown implements TomcatConnectorCustomizer, ApplicationListener<ContextClosedEvent> {
 private static final Logger LOGGER = LoggerFactory.getLogger(GracefulShutdown.class);

 private volatile Connector connector;

 @Override
 public void customize(Connector connector) {
 this.connector = connector;
 }
 @Override
 public void onApplicationEvent(ContextClosedEvent event) {
 try {
  // 指定执行的方法
  shutdown();
  //手动清理内存
  System.gc();
  LOGGER.warn("清理内存完毕,正在退出服务......");
  if (this.connector == null){
  return;
  }
  this.connector.pause();
  LOGGER.warn("关闭全部连接......");
  Executor executor = this.connector.getProtocolHandler().getExecutor();
  if (executor instanceof ThreadPoolExecutor) {
  try {
   ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) executor;
   threadPoolExecutor.shutdown();
   LOGGER.warn("当前服务线程池被关闭");
   if (!threadPoolExecutor.awaitTermination(30, TimeUnit.SECONDS)) {
   LOGGER.warn("Tomcat thread pool did not shut down gracefully within 30 seconds. Proceeding with forceful shutdown");
   }
  } catch (InterruptedException ex) {
   Thread.currentThread().interrupt();
  }
  }
  this.connector.stop();
 } catch (LifecycleException e) {
  e.printStackTrace();
 }
 }

 @Bean
 public GracefulShutdown gracefulShutdown() {
 return new GracefulShutdown();
 }
 @Bean
 public ConfigurableServletWebServerFactory webServerFactory(final GracefulShutdown gracefulShutdown) {
 TomcatServletWebServerFactory factory = new TomcatServletWebServerFactory();
 factory.addConnectorCustomizers(gracefulShutdown);
 return factory;
 }

 /**
 * 执行服务关闭前的一些定制化操作
 * 通常需要确认以下步骤
 * 1.关闭kafka等数据连接
 * 2.flush内存中全部的未处理数据
 * 3.清理服务中全部待处理的数据
 */
 public void shutdown(){}
}

Shutdown.java

import cnkj.site.utils.GracefulShutdown;
import org.springframework.stereotype.Component;

/*
 * @version 1.0 created by Carol on 2019/4/25 16:39
 */
@Component
public class Shutdown extends GracefulShutdown {

 @Override
 public void shutdown() {
 // TODO 定制化关闭操作流程
 // 关闭 kafka 消费
 // flush全部读写流
 // 清空队列
 // 关闭全部文件流读写
 }
}

ApplicationStarterRunner.java

package cn.migu.log.component;

import cnkj.site.utils.HttpCommonUtil;
import cnkj.site.CommonInfo;
import org.springframework.boot.CommandLineRunner;
import org.springframework.stereotype.Component;

/*
 * @version 1.0 created by LXW on 2019/3/14 17:05
 */
@Component
public class ApplicationStarterRunner implements CommandLineRunner {

 @Override
 public void run(String... args) throws Exception {
 // 设置服务名
 commonInfo.setSERVICE_NAME("Service-Name");
 // 自动设置服务启动后的进程号
 commonInfo.setSERVICE_PID(HttpCommonUtil.getCurrentPid());
 }
}

CommonInfo.java

package cnkj.site.utils;

import lombok.Builder;
import lombok.Data;
import org.springframework.boot.actuate.info.Info;
import org.springframework.boot.actuate.info.InfoContributor;
import org.springframework.stereotype.Component;

import java.util.HashMap;
import java.util.Map;

@Data
@Component
public class CommonInfo implements InfoContributor {

 //当前服务名
 private String SERVICE_NAME="SERVICE_NAME";
 //服务当前状态
 private int SERVICE_PID;

 @Override
 public void contribute(Info.Builder builder) {
 builder.withDetail("SERVICE_NAME",SERVICE_NAME);
 builder.withDetail("SERVICE_PID", SERVICE_PID);
 }

 public void clearAll(){
 this.SERVICE_NAME="";
 this.SERVICE_PID=-1;
 }

 public Map getAll(){
 Map map = new HashMap();
 map.put("SERVICE_NAME", getSERVICE_NAME());
 map.put("SERVICE_PID", getSERVICE_PID());
 return map;
 }

}

HttpCommonUtil.java

package cnkj.site.utils;

import javax.servlet.http.HttpServletRequest;
import java.lang.management.ManagementFactory;
import java.net.InetAddress;
import java.net.UnknownHostException;

/*
 * @version 1.0 created by Carol on 2018/10/25 10:04
 */
public class HttpCommonUtil {

 /**
 * 获取当前服务的PID
 * @return PID
 */
 public static Integer getCurrentPid(){
 String name = ManagementFactory.getRuntimeMXBean().getName();
 String pid = name.split("@")[0];
 return Integer.valueOf(pid);
 }
}

application.properties

#服务关闭
management.endpoint.shutdown.enabled=true
#监控相关
management.endpoint.prometheus.enabled=true
management.endpoints.web.exposure.include=info

操作步骤

项目使用步骤:

1.拷贝上面的 Shutdown.java 代码到自己的项目中
2.在 Shutdown.java 文件中的shutdown 方法中写定制化的关闭操作流程

脚本使用步骤:

1.从git获取最新的项目关闭脚本 地址
2.压缩server_close 为server_close.zip
3.上传 server_close.zip 到你服务所在服务器上的 /data/shell 路径下
4.配置环境变量 vim /etc/profile
5.在profile文件的最下面新增 export PATH=/data/shell/server_close:$PATH
6.保存并退出 :wq
7.如果提示 /bin/bash^M: bad interpreter: No such file or directory,请vim serviceControll.sh,然后 :set fileformat=unix ,然后 :wq 保存并退出即可
8.cd /data/shell/server_close & ./serviceControll.sh 运行即可使用服务关闭脚本

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • 详解Springboot应用启动以及关闭时完成某些操作

    一:启动时完成数据加载等需求 实现ApplicationListener接口,官方文档截图: ApplicationListener接口的泛型类可以使用ApplicationStartedEvent和ApplicationReadyEvent 应用监听器事件执行先后顺序如下: ApplicationStartingEvent ApplicationEnvironmentPreparedEvent ApplicationPreparedEvent ApplicationStartedEvent A

  • Springboot项目平滑关闭及自动化关闭脚本

    Springboot项目平滑关闭及自动化关闭脚本,供大家参考,具体内容如下 核心代码 GracefulShutdown.java Shutdown.java ApplicationStarterRunner.java CommonInfo.java HttpCommonUtil.java application.properties 操作步骤 核心代码 GracefulShutdown.java package cnkj.site.utils; import org.apache.catalin

  • SpringBoot项目实现关闭数据库配置和springSecurity

    SpringBoot关闭数据库配置和springSecurity 通过exclude不注入数据源和安全验证模块 @SpringBootApplication(exclude={DataSourceAutoConfiguration.class, SecurityAutoConfiguration.class}) public class ErpApplication { public static void main(String[] args) { SpringApplication.run(

  • SpringBoot项目中建议关闭Open-EntityManager-in-view原因

    目录 前言 问题背景 OPEN-ENTITYMANAGER-IN-VIEW的前世今生 问题的真实原因 解决方案 建议关闭OPEN-ENTITYMANAGER-IN-VIEW 结语 前言 一天,开发突然找过来说KLock分布式锁失效了,高并发情况下没有锁住请求,导致数据库抛乐观锁的异常.一开始我是不信的,KLock是经过线上大量验证的,怎么会出现这么低级的问题呢?然后,协助开发一起排查了一下午,最后经过不懈努力和一探到底的摸索精神最终查明不是KLock锁的问题,问题出在Spring Data Jp

  • Jenkins+Docker 一键自动化部署 SpringBoot 项目的详细步骤

    目录 Jenkins+Docker 一键自动化部署 SpringBoot 项目 一.安装docker 1.确保 yum 包更新到最新 2.卸载旧版本(如果安装过旧版本的话) 3.安装需要的软件包 4.设置yum源 5.安装docker 6.启动和开机启动 7.验证安装是否成功 二.安装Jenkins 1.安装Jenkins 2.初始化Jenkins 2.1 解锁Jenkins 2.2 安装插件 2.3 创建管理员用户 三.系统配置 1. 安装需要插件 2. 配置Maven 四.创建任务 1. 新

  • 探讨:关闭浏览器后,php脚本会不会继续运行

    关闭浏览器后,php脚本会不会继续运行 这个问题需要理解PHP的"连接处理"机制 在 PHP 内部,系统维护着连接状态,其状态有三种可能的情况:* 0 - NORMAL(正常)* 1 - ABORTED(异常退出)* 2 - TIMEOUT(超时) 当 PHP 脚本正常地运行 NORMAL 状态时,连接为有效.当远程客户端中断连接时,ABORTED 状态的标记将会被打开.远程客户端连接的中断通常是由用户点击 STOP 按钮导致的.当连接时间超过 PHP 的时限(请参阅 set_time

  • Mac下开启与关闭端口转发的脚本配置方法

    一.依次运行以下命令: cd /etc ls | grep pf.conf sudo cp pf.conf pf.conf.normal.bak sudo cp pf.conf pf.conf.transmit.bak ls | grep pf.conf 二.修改 pf.conf pf.conf.transmit.bak sudo gedit pf.conf.transmit.bak OR: sudo vim pf.conf.transmit.bak 修改的内容参照上一篇配置端口转发的博文,我这

  • 如何用 Python 子进程关闭 Excel 自动化中的弹窗

    利用Python进行Excel自动化操作的过程中,尤其是涉及VBA时,可能遇到消息框/弹窗(MsgBox).此时需要人为响应,否则代码卡死直至超时 [^1] [^2].根本的解决方法是VBA代码中不要出现类似弹窗,但有时我们无权修改被操作的Excel文件,例如这是我们进行自动化测试的对象.所以本文记录从代码角度解决此类问题的方法. 假想场景 使用xlwings(或者其他自动化库)打开Excel文件test.xlsm,读取Sheet1!A1单元格内容.很简单的一个操作: import xlwing

  • Gitlab CI-CD自动化部署SpringBoot项目的方法步骤

    目录 一.概述 二.前期准备 三.总体架构图 四.环境搭建 1.环境准备(可选) 2.Gitlab安装 3.安装 Runner 4.安装应用服务器环境 五.创建 SpringBoot 项目 1.使用Gitlab Spring 模板快速创建一个 SpringBoot 项目: 2.添加环境变量(登录应用服务器密码) 六.总结 一.概述 本文主要记录如何通过Gitlab CI/CD自动部署SpringBoot项目jar包. 二.前期准备 准备三台 CentOS7服务器,分别部署以下服务: 序号 系统

  • SpringBoot项目中使用Groovy脚本的示例代码

    目录 1. 引入依赖 2. 使用脚本引擎运行groovy脚本 3.思考 SpringBoot+Groovy运行动态脚本 GroovyClassLoader方式 GroovyScriptEngine方式 变量绑定 最近项目中遇到了这样的需求:需要检查一个表的某些字段,是否为空,或者是否符合预期规则:比如大于0,或者在某个范围内.考虑将表名和字段名配置在数据库中,然后规则使用Groovy来写,比较灵活. 1. 引入依赖 <dependency> <groupId>org.codehau

  • Jenkins自动化部署SpringBoot项目的实现

    目录 1.Jenkins介绍 1.1.概念 1.2.优势 1.3.Jenkins目的 2.环境准备 3.Jenkins下载 3.1.下载 3.2.运行 3.3.问题解决 4.Jenkins配置 4.1.用户配置 4.2.系统配置 4.3.全局工具配置-最重要 5.新建项目 7.测试 8.错误解决 1.Jenkins介绍 1.1.概念 Jenkins是一个开源软件项目,是基于Java开发的一种持续集成工具 Jenkins是一个可扩展的持续集成引擎 用于监控持续重复的工作,旨在提供一个开放易用的软件

随机推荐