applicaitonListener配合ApplicationEvent原理

今天突然想看看applicationListener和applicationEvent是怎么实现的观察者模式所以看了下源码

先定义两个观察者

@Component
public class ListenerOne implements ApplicationListener<MyEvent> {@Overridepublic void onApplicationEvent(MyEvent event) {System.out.println(event.getSource() + "事件1执行了");}
}@Component
public class ListenerTwo implements ApplicationListener<MyEvent> {@Overridepublic void onApplicationEvent(MyEvent event) {System.out.println(event.getSource() + "事件2执行了");}
}

在定义一个被观察者

public class MyEvent extends ApplicationEvent {/*** Create a new {@code ApplicationEvent}.** @param source the object on which the event initially occurred or with*               which the event is associated (never {@code null})*/public MyEvent(Object source) {super(source);}
}

接着我们在编写代码的地方如果出现了需要推送事件执行listener的地方就对事件进行推送,我这里这是为了推送事件写的代码

@Configuration
public class BasicConfig {@Autowiredprivate ApplicationContext applicationContext;@PostConstructpublic void publish(){applicationContext.publishEvent(new MyEvent(1));}
}
结果:
事件1执行了 event传入的source:1
事件2执行了 event传入的source:1

源码分析

在publishEvent的时候主要是看红框框起来的部分,我们继续往下走

再往下追的的话主要分为两步
1、通过我们推送的event类型和在创建event传入的字段类型解析出一个缓存的key,这里面存放的就是当前事件里面所支持的所有观察者
2、这里其实就是循环所有的观察着将符合事件类型和参数类型的拿出来,最终进行返回调用