spring上下文的异步Event事件

在实际开发中，我们经常会需要做一件事：在完成某一个动作之后，需要另外以同步或者异步的方式去通知另外的对象去完成额外的操作，比如：当用户下单成功之后，需要发异步消息到给到邮件系统发邮件（短信）通知用户。(这里就涉及到异步消息的概念)

消息队列是我们用来解决系统与系统之间异步与解耦的极佳实践工具，而在应用内部这个级别上，有时候也会需要这样的异步消息通知机制。

spring提供的事件通知机制是基于在容器内部注册与监听的模式，本质上是Observer模式（观察者模式）。对于不明白观察者模式或者忘记的，可以百度了解一下。其实在jdk中也有对观察者模式做了实现，有兴趣的读者也可以了解一下。事件发布注册早容器中（事件注册中心），由事件注册中心去通知相应的监听器去处理该事件。

实现流程一般为：

1、定义扩展自ApplicationEvent类的事件。

2、定义实现自ApplicationListener接口的监听器。

3、通过上下文环境进行事件发布。

代码如下：

1/**
2 * 下单事件
3 * 
4 * @author lennon
5 *
6 */
7public class OrderCreateEvent extends ApplicationEvent{
8
9	private static final long serialVersionUID = 1L;
10	
11	private String orderSn;
12
13	public OrderCreateEvent(String orderSn) {
14		super(SpringContextHolder.getApplicationContext());
15		this.orderSn = orderSn;
16	}
17
18	public String getOrderSn() {
19		return orderSn;
20	}
21
22	public void setOrderSn(String orderSn) {
23		this.orderSn = orderSn;
24	}
25}
26
27/**
28 * 下单事件监听器
29 * 
30 * @author lennon
31 *
32 */
33@Component
34@Async
35public class OrderCreateEventListener implements ApplicationListener<OrderCreateEvent> {
36
37	@Override
38	public void onApplicationEvent(OrderCreateEvent orderCreateEvent) {
39		// 对下单操作进行处理
40		System.out.println("打印订单");
41		System.out.println(orderCreateEvent.getOrderSn());
42	}
43
44}
45
46/**
47 * 下单成功之后发布异步事件
48 * 
49 * @author lennon
50 *
51 */
52public class OrderCreateEventPublisher {
53
54	
55	public void afterCreateOrder() {
56		
57		// 下单
58		OrderCreateEvent orderCreateEvent = new OrderCreateEvent(UUID.randomUUID().toString());
59		
60		// ....
61		// 下单成功
62		System.out.println("下单成功之后，异步做一些简单处理");
63		
64		
65		SpringContextHolder.getApplicationContext().publishEvent(orderCreateEvent);
66		
67		System.out.println("异步之后！");
68	}
69}
70
71/**
72 * 持有spring的上下文对象
73 * 
74 * @author lennon
75 *
76 */
77@Component
78public class SpringContextHolder implements ApplicationContextAware{
79
80	private static ApplicationContext applicationContext = null;  
81	  
82    @Override  
83    public void setApplicationContext(ApplicationContext applicationContext)  
84            throws BeansException {  
85    	this.applicationContext = applicationContext;  
86    }  
87      
88    public static Object getBean(String name){  
89        return applicationContext.getBean(name);  
90    }
91    
92    public static ApplicationContext getApplicationContext() {
93    	return applicationContext;
94    }
95}

总结：

1、异步Event事件与自定义线程实现，到底哪种好？什么时候要用异步事件，什么时候使用线程？

2、什么时候使用异步Event，什么时候使用同步Event?

3、深入了解底层的观察者模式，如何自己写出一套基于发布与订阅的异步Event事件框架？【值得尝试做一下，重复造轮子可以检验自己的能力】