Spring Boot 2.0 实现优雅停机

<!-- springboot监控 -->  <dependency>      <groupId>org.springframework.boot</groupId>      <artifactId>spring-boot-starter-actuator</artifactId>  </dependency>  

#启用shutdown endpoint的HTTP访问endpoints.shutdown.enabled=true#不需要验证 endpoints.shutdown.sensitive=false

@SpringBootApplicationpublic class ShutdownApplication {
    public static void main(String[] args) {        SpringApplication.run(ShutdownApplication.class, args);    }
    /**     * 用于接受 shutdown 事件     */    @Bean    public GracefulShutdown gracefulShutdown() {        return new GracefulShutdown();    }
    /**     * 配置tomcat     *     * @return     */    @Bean    public ServletWebServerFactory servletContainer() {        TomcatServletWebServerFactory tomcat = new TomcatServletWebServerFactory();        tomcat.addConnectorCustomizers(gracefulShutdown());        return tomcat;    }
    /**     * 优雅关闭 Spring Boot。容器必须是 tomcat     */    private class GracefulShutdown implements TomcatConnectorCustomizer, ApplicationListener<ContextClosedEvent> {        private final Logger log = LoggerFactory.getLogger(GracefulShutdown.class);        private volatile Connector connector;        private final int waitTime = 10;
        @Override        public void customize(Connector connector) {            this.connector = connector;        }
        @Override        public void onApplicationEvent(ContextClosedEvent contextClosedEvent) {            this.connector.pause();            Executor executor = this.connector.getProtocolHandler().getExecutor();            if (executor instanceof ThreadPoolExecutor) {                try {                    ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor) executor;                    threadPoolExecutor.shutdown();                    if (!threadPoolExecutor.awaitTermination(waitTime, TimeUnit.SECONDS)) {                        log.warn("Tomcat 进程在" + waitTime + " 秒内无法结束，尝试强制结束");                    }                } catch (InterruptedException ex) {                    Thread.currentThread().interrupt();                }            }        }    }}

@SpringBootApplicationpublic class Application {
    public static void main(String[] args) {        SpringApplication.run(Application.class, args);    }
    /**     * 优雅关闭 Spring Boot     */    @Component    public class GracefulShutdown implements ApplicationListener<ContextClosedEvent> {
        @Autowired        private GracefulShutdownWrapper gracefulShutdownWrapper;
        @Autowired        private ServletWebServerApplicationContext context;
        @Override        public void onApplicationEvent(ContextClosedEvent contextClosedEvent){            gracefulShutdownWrapper.getGracefulShutdownHandler().shutdown();            try {                UndertowServletWebServer webServer = (UndertowServletWebServer)context.getWebServer();                Field field = webServer.getClass().getDeclaredField("undertow");                field.setAccessible(true);                Undertow undertow = (Undertow) field.get(webServer);                List<Undertow.ListenerInfo> listenerInfo = undertow.getListenerInfo();                Undertow.ListenerInfo listener = listenerInfo.get(0);                ConnectorStatistics connectorStatistics = listener.getConnectorStatistics();                while (connectorStatistics.getActiveConnections() > 0){}            }catch (Exception e){                // Application Shutdown            }        }    }    @Component  public class GracefulShutdownWrapper implements HandlerWrapper{
      private GracefulShutdownHandler gracefulShutdownHandler;
      @Override      public HttpHandler wrap(HttpHandler handler) {          if(gracefulShutdownHandler == null) {              this.gracefulShutdownHandler = new GracefulShutdownHandler(handler);          }          return gracefulShutdownHandler;      }
      public GracefulShutdownHandler getGracefulShutdownHandler() {          return gracefulShutdownHandler;      }
  }  @Component  @AllArgsConstructor  public class UndertowExtraConfiguration {
      private final GracefulShutdownWrapper gracefulShutdownWrapper;
      @Bean      public UndertowServletWebServerFactory servletWebServerFactory() {          UndertowServletWebServerFactory factory = new UndertowServletWebServerFactory();          factory.addDeploymentInfoCustomizers(deploymentInfo -> deploymentInfo.addOuterHandlerChainWrapper(gracefulShutdownWrapper));          factory.addBuilderCustomizers(builder -> builder.setServerOption(UndertowOptions.ENABLE_STATISTICS, true));          return factory;      }
  }}

kill -15 [PID]