前段时间因为工作的需要用到Spring事件，翻翻文档将功能实现了，但是存在少许理解不畅的地方，今天有空来梳理梳理。
叶子同学在新入职公司，老大让他实现登陆功能，叶子随手写完，上线无bug，一切安好
//登陆伪代码
public void login(....){
userLogin(....);
}几天之后，老大说为维护用户的粘度，每天登陆送积分。叶子同学，二话不说，一顿操作后，上线无bug，一切安好
//登陆伪代码
public void login(....){
//登陆
userLogin(....);
//送积分
loginPoint(....)
}又几天后，老大说，为了客户安全，每次异地登陆发送邮件。叶子同学稍微抱怨，看在钱份上又是一顿操作后，上线无bug， 一切安好
//登陆伪代码
public void login(....){
//登陆
userLogin(....);
//送积分
loginPoint(....)
//发送邮件
sendEmail(....)
}又又几天后，老大说，部分客户不用邮件，用短信。叶子同学压着怒气，看着银行卡，又是一顿操作后，上线无bug， 一切安好
//登陆伪代码
public void login(....){
//登陆
userLogin(....);
//送积分
loginPoint(....)
//发送邮件
sendEmail(....)
//发短信
sendSms(...)
}又又又几天后，老大还没开口，叶子同学就忍无可忍啦，得加钱。老大哄了好久，说不改需求了。改bug，用户抱怨登陆慢，有时还不成功。叶子二话不说，接手排查，查出问题啦
代码改进：
//登陆伪代码
public void login(....){
//登陆
userLogin(....);
try{
//送积分
new Thread(()->loginPoint(....)).start();
//发送邮件
new Thread(()->sendEmail(....)).start();
//发短信
new Thread(()->sendSms(....)).start();
}catch(Exception e){
//异常处理
}
}问题解决，功能实现，ok~
又又又又几天之后，老大说，只需要实现登陆功能即可，其他都不要~
叶子同学一句卧槽，然后是一段含母非常高的国粹。
此时，问：如果你是叶子同学，你有啥方案能优雅应对上面的需求变更呢？
一种优雅方案：事件监听机制
事件监听机制：就是对一个事件(行为动作)进行监听，当外界触发某事件时，监听程序马上被捕获该事件，并触发相应的响应，这过程称之为事件监听机制。
事件监听机制有3个核心组成部分：
以上面的登录为例：
以登录为例子实现事件监听机制
1>定义抽象事件
/**
* 抽象事件类
* 作用：定制事件逻辑
*/
public class AbstractEvent {
//绑定的事件源
private Object source;
public AbstractEvent(Object source) {
this.source = source;
}
public Object getSource() {
return source;
}
public void setSource(Object source) {
this.source = source;
}
}2>定制登陆事件
/**
* 登陆事件
*/
public class LoginEvent extends AbstractEvent{
public LoginEvent(Object source) {
super(source);
}
}3>定义事件监听器
/**
* 事件监听器
* 作用：当监控的事件发送时，执行预设的逻辑
*/
public interface EventListener<E extends AbstractEvent> {
/**
* 预设逻辑方法
* 事件被触发，马上执行
*/
void onEvent(E event);
}4>定制登陆事件监听器
积分监听器
/**
* 加积分监听器器：
* 当用户登陆事件触发后，马上执行
*/
public class PointsListener implements EventListener<LoginEvent> {
public void onEvent(LoginEvent event) {
System.out.println(event.getSource() + "发生后，执行积分+1操作");
System.out.println(Thread.currentThread().getName());
}
}短信监听器
/**
* 加积分监听器器：
* 当用户登陆事件触发后，马上执行
*/
public class SmsListener implements EventListener<LoginEvent> {
public void onEvent(LoginEvent event) {
System.out.println(event.getSource() + "发生后，执行发送短信操作");
System.out.println(Thread.currentThread().getName());
}
}邮件监听器
/**
* 加积分监听器器：
* 当用户登陆事件触发后，马上执行
*/
public class EmailListener implements EventListener<LoginEvent> {
public void onEvent(LoginEvent event) {
try {
//模拟10s延时
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(event.getSource() + "发生后，执行发送邮件操作");
System.out.println(Thread.currentThread().getName());
}
}5>定义事件广播器
/**
* 事件广播器
* 1>注册事件监听器
* 2>删除事件监听器
* 3>事件触发时，广播事件
*/
public interface EventMulticaster {
//广播事件
void multicastEvent(AbstractEvent event);
//注册事件监听器
void registListener(EventListener listener);
//删除事件监听器
void removeListener(EventListener listener);
}6>定制简单的事件广播器
/**
* 事件广播器实现类
* 作用：维护事件监听器
*/
public class SimpleEventMulticaster implements EventMulticaster {
//key：事件字节码对象， value：当前事件绑定的事件监听器
private Map<Class<?>, List<EventListener>> map = new HashMap<Class<?>, List<EventListener>>();
public void multicastEvent(AbstractEvent event) {
List<EventListener> eventListeners = map.get(event.getClass());
if(eventListeners != null){
ExecutorService executorService = Executors.newCachedThreadPool();
for (EventListener eventListener : eventListeners) {
//异步
executorService.submit(()-> eventListener.onEvent(event));
//同步
//eventListener.onEvent(event);
}
executorService.shutdown();
}
}
public void registListener(EventListener listener) {
//获取监听器绑定的事件
ParameterizedType getType = (ParameterizedType)listener.getClass().getGenericInterfaces()[0];
Type type = getType.getActualTypeArguments()[0];
Class<?> clz = (Class<?>) type;
List<EventListener> listeners = map.get(clz);
if(listeners == null){
listeners = new ArrayList<EventListener>();
map.put(clz, listeners);
}
listeners.add(listener);
}
public void removeListener(EventListener listener) {
//获取监听器绑定的事件
ParameterizedType getType = (ParameterizedType)listener.getClass().getGenericInterfaces()[0];
Type type = getType.getActualTypeArguments()[0];
Class<?> clz = (Class<?>) type;
List<EventListener> listeners = map.get(clz);
if(listener != null){
listeners.remove(listener);
}
}
}
7>综合测试
public class App {
//1：初始化事件广播器
public static SimpleEventMulticaster multicaster = new SimpleEventMulticaster();
static {
//2：注册监听器
//登陆事件上绑定3个监听器
multicaster.registListener(new PointsListener());
multicaster.registListener(new EmailListener());
multicaster.registListener(new SmsListener());
}
//3：模拟登陆
public static void login(){
//4：用户登陆成功触发登陆事件
System.out.println("用户执行登陆逻辑");
System.out.println(Thread.currentThread().getName());
//5：广播登陆事件
multicaster.multicastEvent(new LoginEvent("用户登陆啦"));
System.out.println("登陆成功.....");
}
public static void main(String[] args) {
App.login();
System.out.println(Thread.currentThread().getName());
}
}
