1 protected void initApplicationEventMulticaster() {
 2     ConfigurableListableBeanFactory beanFactory = getBeanFactory();
 3     // 检查配置中是否有applicationEventMulticaster的Bean定义
 4     if (beanFactory.containsLocalBean(APPLICATION_EVENT_MULTICASTER_BEAN_NAME)) {
 5         // 如果有则获取（实例化Bean）
 6         this.applicationEventMulticaster =
 7             beanFactory.getBean(APPLICATION_EVENT_MULTICASTER_BEAN_NAME, ApplicationEventMulticaster.class);
 8         if (logger.isDebugEnabled()) {
 9             logger.debug("Using ApplicationEventMulticaster [" + this.applicationEventMulticaster + "]");
10         }
11     }
12     else {
13         // 如果没有手动创建SimpleApplicationEventMulticaster的实例
14         this.applicationEventMulticaster = new SimpleApplicationEventMulticaster(beanFactory);
15         // 把创建的SimpleApplicationEventMulticaster注册到BeanFactory
16         beanFactory.registerSingleton(APPLICATION_EVENT_MULTICASTER_BEAN_NAME, this.applicationEventMulticaster);
17         if (logger.isDebugEnabled()) {
18             logger.debug("Unable to locate ApplicationEventMulticaster with name ‘" +
19                          APPLICATION_EVENT_MULTICASTER_BEAN_NAME +
20                          "‘: using default [" + this.applicationEventMulticaster + "]");
21         }
22     }
23 }

 1 // 生命周期接口，任何Spring管理的对象都可以实现该接口
 2 public interface Lifecycle {
 3     void start();
 4     void stop();
 5     boolean isRunning();
 6 }
 7 
 8 // 管理ApplicationContext生命周期
 9 public interface LifecycleProcessor extends Lifecycle {
10     void onRefresh();
11     void onClose();
12 }
13 
14 public interface SmartLifecycle extends Lifecycle, Phased {
15     // Lifecycle Bean是否自动启动
16     boolean isAutoStartup();
17 
18     // 停止的时候执行回调，默认超时时间30秒
19     void stop(Runnable callback);
20 }
21 
22 // Phased最小的对象首先启动，停止时，顺序和启动时相反
23 public interface Phased {
24     // SmartLifecycle的实现类默认Phase为0
25     int getPhase();
26 }

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 4        xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
 5 
 6     <bean class="com.jdr.spring.event.TestLifeCycle" name="testLifeCycle"/>
 7 
 8     <bean class="com.jdr.spring.event.TestSmartLifeCycle" name="testSmartLifeCycle"/>
 9 
10     <bean class="com.jdr.spring.event.CustomContextEvent" name="customContextEvent"/>
11 
12 </beans>

 1 public class TestLifeCycle implements Lifecycle {
 2 
 3     private boolean running = false;
 4 
 5     public TestLifeCycle() {
 6         System.out.println("TestLifeCycle....");
 7     }
 8 
 9     @Override
10     public void start() {
11         System.out.println("TestLifeCycle start...");
12     }
13 
14     @Override
15     public void stop() {
16         System.out.println("TestLifeCycle stop...");
17     }
18 
19     @Override
20     public boolean isRunning() {
21         return running;
22     }
23 }

 1 public class TestSmartLifeCycle implements SmartLifecycle {
 2 
 3     private boolean running = false;
 4 
 5     public TestSmartLifeCycle() {
 6         System.out.println("TestSmartLifeCycle....");
 7     }
 8 
 9     @Override
10     public boolean isAutoStartup() {
11         // 若自动启动标识为false，则容器启动时不会调用start()
12         return true;
13     }
14 
15     @Override
16     public void stop(Runnable callback) {
17         System.out.println("TestSmartLifeCycle stop callback....");
18         this.running = false;
19     }
20 
21     @Override
22     public void start() {
23         System.out.println("TestSmartLifeCycle start....");
24         this.running = true;
25     }
26 
27     @Override
28     public void stop() {
29         System.out.println("TestSmartLifeCycle stop....");
30         this.running = false;
31     }
32 
33     @Override
34     public boolean isRunning() {
35         return running;
36     }
37 
38     @Override
39     public int getPhase() {
40         return 100;
41     }
42 }

 1 public class CustomContextEvent implements ApplicationListener<ApplicationEvent> {
 2 
 3     @Override
 4     public void onApplicationEvent(ApplicationEvent event) {
 5         if (event instanceof ContextRefreshedEvent) {
 6             System.out.println("ContextRefreshedEvent...");
 7         }
 8         if (event instanceof ContextStartedEvent) {
 9             System.out.println("ContextStartedEvent...");
10         }
11         if (event instanceof ContextStoppedEvent) {
12             System.out.println("ContextStoppedEvent...");
13         }
14         if (event instanceof ContextClosedEvent) {
15             System.out.println("ContextClosedEvent...");
16         }
17     }
18 }