好像知道的人不多？Spring容器关闭执行销毁方法有几种，看完MQ源码我才知道SmartLifecycle最快

@Service
public class UserServiceImpl implements UserService, DisposableBean, SmartLifecycle {
    private volatile boolean running = false;
    private List<String> lockKeys = new ArrayList<>();
    @Resource
    HelloService helloService;
    @Override
    public void get() {
        String key = "redis:key";
        //伪代码
        RedissonUtil.lock(key);
        try {
            lockKeys.add(key);
        } catch (Exception ex){
            ex.printStackTrace();
            //...
        } finally {
            RedissonUtil.unlock(key);
            lockKeys.remove(key);
        }
    }
    @Override
    public void destroy() {
        // 删除正在执行中的key
        RedissonUtil.deletes(lockKeys);
        running = false;
    }
    @Override
    public void start() {
        System.out.println("start >>>>");
        running = true;
    }
    @Override
    public void stop() {
        System.out.println("stop >>>>");
        // 删除正在执行中的key
        RedissonUtil.deletes(lockKeys);
    }
    @Override
    public boolean isRunning() {
        return running;
    }
    @Override
    public int getPhase() {
        return Integer.MAX_VALUE;
    }
}

@Service
public class UserServiceImpl implements UserService, DisposableBean {
    @Override
    public void destroy() {
        System.out.println("destroy>>>>>");
    }
}

@Service
public class UserServiceImpl implements UserService, SmartLifecycle {
    @Override
    public void start() {
        System.out.println("start >>>>");
        running = true;
    }
    @Override
    public void stop() {
        System.out.println("stop >>>>");
    }
    @Override
    public boolean isRunning() {
        return running;
    }
    @Override
    public int getPhase() {
        return Integer.MAX_VALUE;
    }
}

@Service
public class UserServiceImpl implements UserService, InitializingBean {
    @Override
    public void afterPropertiesSet() {
        Runtime.getRuntime().addShutdownHook(new Thread(() -> {
            helloService.get();
            System.out.println("addShutdownHook>>>>>");
        }));
    }
}

@PreDestroy
public void preDestroy(){
    System.out.println("PreDestroy>>>>");
}

2022-09-05 23:06:04.046  INFO 11807 --- [           main] c.l.d.SpringBootDemoDockerApplication    : Started SpringBootDemoDockerApplication in 1.4 seconds (JVM running for 1.752)
ApplicationRunner>>>>>
CommandLineRunner>>>项目启动完毕后,倒数10秒关闭
thread1...
thread1...
thread1...
thread1...
stop >>>>
2022-09-05 23:06:14.054  INFO 11807 --- [           main] o.s.s.concurrent.ThreadPoolTaskExecutor  : Shutting down ExecutorService 'applicationTaskExecutor'
PreDestroy>>>>
destroy>>>>>
thread1...
thread1...
get
addShutdownHook>>>>>

/**
 * 当上下文被刷新（所有对象已被实例化和初始化之后）时，将调用该方法
 * isAutoStartup默认为true则调用start，否则需要自己手动调用
 */
@Override
public void start() {
    System.out.println("start >>>>");
    running = true;
}
/**
 * 接口Lifecycle子类的方法，只有非SmartLifecycle的子类才会执行该方法。
 * 1. 该方法只对直接实现接口Lifecycle的类才起作用，对实现SmartLifecycle接口的类无效。
 * 2. 方法stop()和方法stop(Runnable callback)的区别只在于，后者是SmartLifecycle子类的专属。
 */
@Override
public void stop() {
    System.out.println("stop >>>>");
}
/**
 * 只有该方法返回false时，start方法才会被执行
 * 只有该方法返回true时，stop(Runnable callback)或stop()方法才会被执
 * @return
 */
@Override
public boolean isRunning() {
    return running;
}
/**
 * 返回 Integer.MAX_VALUE 仅表明
 * 我们将是第一个关闭的 bean 和最后一个启动的 bean
 * 关闭容器的第一时间调用stop()方法
 */
@Override
public int getPhase() {
    return Integer.MAX_VALUE;
}
/**
 * 如果该`Lifecycle`类所在的上下文在调用`refresh`时,希望能够自己自动进行回调，则返回`true`,
 * false的值表明组件打算通过显式的start()调用来启动，类似于普通的Lifecycle实现。
 */
@Override
public boolean isAutoStartup() {
    return false;
}
/**
 * SmartLifecycle子类的才有的方法，当isRunning方法返回true时，该方法才会被调用。
 * 很多框架中的源码中，都会把真正逻辑写在stop()方法内。
 */
@Override
public void stop(Runnable callback) {
    stop();
    // 如果你让isRunning返回true，需要执行stop这个方法
    // 在程序退出时，Spring的DefaultLifecycleProcessor会认为这个MySmartLifecycle没有stop完成，
    // 程序会一直卡着结束不了，等待一定时间（默认超时时间30秒）后才会自动结束。
    callback.run();
}

public class DefaultRocketMQListenerContainer implements InitializingBean,
    RocketMQListenerContainer, SmartLifecycle, ApplicationContextAware {
    private final static Logger log = LoggerFactory.getLogger(DefaultRocketMQListenerContainer.class);
    private boolean running;
    ...
    @Override
    public void destroy() {
        this.setRunning(false);
        if (Objects.nonNull(consumer)) {
            consumer.shutdown();
        }
        log.info("container destroyed, {}", this.toString());
    }
    @Override
    public boolean isAutoStartup() {
        return true;
    }
    @Override
    public void stop(Runnable callback) {
        stop();
        callback.run();
    }
    @Override
    public void start() {
        if (this.isRunning()) {
            throw new IllegalStateException("container already running. " + this.toString());
        }
        try {
            consumer.start();
        } catch (MQClientException e) {
            throw new IllegalStateException("Failed to start RocketMQ push consumer", e);
        }
        this.setRunning(true);
        log.info("running container: {}", this.toString());
    }
    @Override
    public void stop() {
        if (this.isRunning()) {
            if (Objects.nonNull(consumer)) {
                consumer.shutdown();
            }
            setRunning(false);
        }
    }
    @Override
    public boolean isRunning() {
        return running;
    }
    private void setRunning(boolean running) {
        this.running = running;
    }
    @Override
    public int getPhase() {
        // Returning Integer.MAX_VALUE only suggests that
        // we will be the first bean to shutdown and last bean to start
        return Integer.MAX_VALUE;
    }
    @Override
    public void afterPropertiesSet() throws Exception {
        initRocketMQPushConsumer();
        this.messageType = getMessageType();
        this.methodParameter = getMethodParameter();
        log.debug("RocketMQ messageType: {}", messageType);
    }
}