一、Spring 中觀察者模式的四個角色
1. 事件（ApplicationEvent）
ApplicationEvent 是所有事件對象的父類。ApplicationEvent 繼承自 jdk 的 EventObject, 所有的事件都需要繼承 ApplicationEvent, 並且通過 source 得到事件源。
下列描述了Spring提供的內置事件：
- ContextRefreshedEvent：事件發布在 ApplicationContext 初始化或刷新時（例如：通過在 ConfigurableApplicationContext 接口使用refresh()方法）。這里,“初始化”意味着所有 bean 加載，post-processor bean 被檢測到並且激活,單例預先實例化，ApplicationContext 對象可以使用了。只要上下文沒有關閉,可以觸發多次刷新, ApplicationContext 提供了一種可選擇的支持這種“熱”刷新。例如：XmlWebApplicationContext 支持熱刷新,但 GenericApplicationContext 並非如此。具體是在 AbstractApplicationContext 的 finishRefresh() 方法中。
- ContextStartedEvent：事件發布在 ApplicationContext 開始使用 ConfigurableApplicationContext 接口 start() 方法。這里,“開始”意味着所有生命周期 bean 接收到一個明確的起始信號。通常,這個信號用於明確停止后重新啟動,但它也可以用於啟動組件沒有被配置為自動運行（例如：組件還沒有開始初始化）。
- ContextStoppedEvent：事件發布在 ApplicationContext 停止時通過使用 ConfigurableApplicationContext 接口上的 stop() 方法。在這里,“停止”意味着所有生命周期bean接收一個顯式的停止信號。停止上下文可以通過重新調用start()方法。
- ContextClosedEvent：事件發布在 ApplicationContext 關閉時通過關閉 ConfigurableApplicationContext 接口()方法。這里,“封閉”意味着所有單例 bean 被摧毀。一個封閉的環境達到生命的終結。它不能刷新或重啟。
- RequestHandledEvent：一個特定的web事件告訴所有能處理HTTP請求的bean 。這個事件是在請求完成后發布的。這個事件只適用於使用 Spring 的 DispatcherServlet 的web應用程序。
2. 事件監聽（ApplicationListener）
ApplicationListener 事件監聽器，也就是觀察者。繼承自 jdk 的 EventListener，該類中只有一個方法 onApplicationEvent。當監聽的事件發生后該方法會被執行。
3. 事件發布（ApplicationContext）
ApplicationContext 是 Spring 中的核心容器，在事件監聽中 ApplicationContext 可以作為事件的發布者，也就是事件源。因為 ApplicationContext 繼承自 ApplicationEventPublisher。在 ApplicationEventPublisher 中定義了事件發布的方法 — publishEvent(Object event)
4. 事件管理（ApplicationEventMulticaster）
ApplicationEventMulticaster 用於事件監聽器的注冊和事件的廣播。監聽器的注冊就是通過它來實現的，它的作用是把 Applicationcontext 發布的 Event 廣播給它的監聽器列表。
二、Spring中實現觀察者模式
- 自定義需要發布的事件類，需要繼承 ApplicationEvent 類或 PayloadApplicationEvent
(該類也僅僅是對 ApplicationEvent 的一層封裝) - 使用 @EventListener 來監聽事件或者實現 ApplicationListener 接口。
- 使用 ApplicationEventPublisher 來發布自定義事件（@Autowired注入即可）
@TransactionalEventListener 監聽器：如果事件的發布不是在事務（@Transactional）范圍內，則監聽不到該事件，除非將 fallbackExecution 標志設置為 true：
@TransactionalEventListener(fallbackExecution = true)
如果在事務中，可以選擇在事務的哪個階段來監聽事件，默認在事務提交后監聽：
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMPLETION)
以上介紹的事件監聽都是同步，如果需要開啟異步支持的話：
@Configuration
@EnableAsync
public class AsyncEventConfiguration implements AsyncConfigurer {
@Override
public Executor getAsyncExecutor() {
return Executors.newCachedThreadPool();
}
}
三、 實戰
事件（MyEvent.java）
@Component
public class MyEvent extends ApplicationEvent {
public MyEvent(ApplicationContext source) {
super(source);
System.out.println("MyEvent 構造器執行");
}
public void echo() {
System.out.println("模擬業務邏輯執行");
}
}
事件監聽（MyListenerA.java、MyListenerB.java）
@Component
public class MyListenerA implements ApplicationListener<MyEvent> {
@Override
public void onApplicationEvent(MyEvent myEvent) {
System.out.println("MyListenerA");
myEvent.echo();
}
}
@Component
public class MyListenerB {
@EventListener
public void onApplicationEvent(MyEvent myEvent) {
System.out.println("MyListenerB");
myEvent.echo();
}
}
事件發布（MyPublisher.java）
@Component
public class MyPublisher implements ApplicationContextAware {
private ApplicationContext applicationContext;
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
this.applicationContext = applicationContext;
}
/**
* 發布事件
* 監聽該事件的監聽者都可以獲取消息
*
* @param myEvent
*/
public void publisherEvent(MyEvent myEvent) {
System.out.println("---開始發布 myEvent 事件---");
applicationContext.publishEvent(myEvent);
}
}
單元測試（ApplicationTests.java）
@RunWith(SpringRunner.class)
@SpringBootTest
public class ApplicationTests {
@Autowired
private MyPublisher myPublisher;
@Autowired
private MyEvent myEvent;
@Test
public void contextLoads() {
myPublisher.publisherEvent(myEvent);
}
}