dedecms网站二次开发,英雄联盟网页设计代码,ui设计作品网站,金融投资网站源码目录
事件基类定义
事件监听器接口
事件发布者接口及实现
事件广播器实现
小小总结 Spring源码分析之事件机制——观察者模式#xff08;一#xff09;-CSDN博客
Spring源码分析之事件机制——观察者模式#xff08;二#xff09;-CSDN博客
Spring源码分析之事件机制…
目录
事件基类定义
事件监听器接口
事件发布者接口及实现
事件广播器实现
小小总结 Spring源码分析之事件机制——观察者模式一-CSDN博客
Spring源码分析之事件机制——观察者模式二-CSDN博客
Spring源码分析之事件机制——观察者模式三-CSDN博客
这两篇文章是这个篇章的后篇感兴趣的读者可以阅读一下从spring源码分析观察者模式
事件基类定义 public abstract class ApplicationEvent extends EventObject {// 事件发生的时间戳private final long timestamp;public ApplicationEvent(Object source) {// source表示事件源即发布事件的对象super(source);this.timestamp System.currentTimeMillis();}// 获取事件发生时间public final long getTimestamp() {return this.timestamp;}
}
ApplicationEvent作为所有Spring事件的基类继承自Java的EventObject通过记录时间戳和事件源为事件提供了基本的元数据信息使得事件能够携带更多的上下文信息。
事件监听器接口 FunctionalInterface
public interface ApplicationListenerE extends ApplicationEvent extends EventListener {/*** 处理应用事件的方法* param event 要响应的事件*/void onApplicationEvent(E event);
}
ApplicationListener接口定义了事件监听器的标准通过泛型约束限定了具体监听的事件类型使得监听器能够只关注特定类型的事件我觉得spring的这种设计既保证了类型安全又提供了良好的扩展性。
事件发布者接口及实现
FunctionalInterface
public interface ApplicationEventPublisher {/*** 发布事件的方法* param event 要发布的事件*/default void publishEvent(ApplicationEvent event) {publishEvent((Object) event);}/*** 发布任意对象作为事件* param event 要发布的事件对象*/void publishEvent(Object event);
} public abstract class AbstractApplicationContext implements ApplicationEventPublisher {// 事件广播器private ApplicationEventMulticaster applicationEventMulticaster;// 早期事件缓存用于存储容器未完全初始化前的事件private SetApplicationEvent earlyApplicationEvents;Overridepublic void publishEvent(Object event) {// 确保事件对象是ApplicationEvent类型ApplicationEvent applicationEvent;if (event instanceof ApplicationEvent) {applicationEvent (ApplicationEvent) event;} else {// 将普通对象包装为PayloadApplicationEventapplicationEvent new PayloadApplicationEvent(this, event);}// 如果容器还在初始化则将事件添加到早期事件集合if (this.earlyApplicationEvents ! null) {this.earlyApplicationEvents.add(applicationEvent);} else {// 通过事件广播器发布事件getApplicationEventMulticaster().multicastEvent(applicationEvent);}// 如果存在父容器则同时发布到父容器if (this.parent ! null) {this.parent.publishEvent(event);}}// 初始化事件广播器protected void initApplicationEventMulticaster() {ConfigurableListableBeanFactory beanFactory getBeanFactory();// 如果容器中已定义了广播器则使用已定义的if (beanFactory.containsLocalBean(APPLICATION_EVENT_MULTICASTER_BEAN_NAME)) {this.applicationEventMulticaster beanFactory.getBean(APPLICATION_EVENT_MULTICASTER_BEAN_NAME, ApplicationEventMulticaster.class);} else {// 否则创建一个简单的事件广播器this.applicationEventMulticaster new SimpleApplicationEventMulticaster(beanFactory);beanFactory.registerSingleton(APPLICATION_EVENT_MULTICASTER_BEAN_NAME, this.applicationEventMulticaster);}}
}
AbstractApplicationContext实现了事件发布的核心逻辑通过事件广播器将事件分发给所有相关的监听器同时处理了事件的向上传播和早期事件的缓存。 事件广播器实现 public class SimpleApplicationEventMulticaster extends AbstractApplicationEventMulticaster {// 任务执行器用于异步事件处理Nullableprivate Executor taskExecutor;// 错误处理器Nullableprivate ErrorHandler errorHandler;Overridepublic void multicastEvent(ApplicationEvent event) {// 解析事件类型并广播multicastEvent(event, resolveDefaultEventType(event));}Overridepublic void multicastEvent(final ApplicationEvent event, Nullable ResolvableType eventType) {// 解析事件类型ResolvableType type (eventType ! null ? eventType : resolveDefaultEventType(event));// 获取所有匹配的监听器并执行for (final ApplicationListener? listener : getApplicationListeners(event, type)) {Executor executor getTaskExecutor();if (executor ! null) {// 异步执行executor.execute(() - invokeListener(listener, event));} else {// 同步执行invokeListener(listener, event);}}}protected void invokeListener(ApplicationListener? listener, ApplicationEvent event) {ErrorHandler errorHandler getErrorHandler();if (errorHandler ! null) {try {doInvokeListener(listener, event);} catch (Throwable err) {errorHandler.handleError(err);}} else {doInvokeListener(listener, event);}}
}
SimpleApplicationEventMulticaster提供了事件广播的具体实现支持同步和异步两种事件处理方式并提供了错误处理机制通过这种设计使得事件的处理更加灵活和可靠同时也为性能优化提供了可能。 小小总结
Spring的事件机制通过这些精心设计的组件构建了一个完整的观察者模式实现它不仅支持Spring框架内部的事件处理也为应用程序提供了一个强大的事件驱动架构基础通过这种方式可以实现组件间的松耦合通信提高系统的可维护性和扩展性。整个实现考虑了性能、可靠性和易用性等多个方面是一个非常典型的观察者模式应用案例。
