广播器实现

这两篇文章是这个篇章的后篇感兴趣的读者可以阅读一下从spring源码分析观察者模式

事件基类定义

source表示事件源即发布事件的对象super(source);this.timestamp

获取事件发生时间public

ApplicationEvent作为所有Spring事件的基类继承自Java的EventObject通过记录时间戳和事件源为事件提供了基本的元数据信息使得事件能够携带更多的上下文信息。

事件监听器接口

ApplicationListener接口定义了事件监听器的标准通过泛型约束限定了具体监听的事件类型使得监听器能够只关注特定类型的事件我觉得spring的这种设计既保证了类型安全又提供了良好的扩展性。

事件发布者接口及实现

earlyApplicationEvents;Overridepublic

void

确保事件对象是ApplicationEvent类型ApplicationEvent

applicationEvent;if

将普通对象包装为PayloadApplicationEventapplicationEvent

new

{this.earlyApplicationEvents.add(applicationEvent);}

else

通过事件广播器发布事件getApplicationEventMulticaster().multicastEvent(applicationEvent);}//

如果存在父容器则同时发布到父容器if

{this.parent.publishEvent(event);}}//

初始化事件广播器protected

initApplicationEventMulticaster()

{ConfigurableListableBeanFactory

beanFactory

(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实现了事件发布的核心逻辑通过事件广播器将事件分发给所有相关的监听器同时处理了事件的向上传播和早期事件的缓存。

事件广播器实现

SimpleApplicationEventMulticaster

extends

AbstractApplicationEventMulticaster

{//

multicastEvent(ApplicationEvent

event)

resolveDefaultEventType(event));}Overridepublic

void

resolveDefaultEventType(event));//

(final

invokeListener(ApplicationListener?

listener,

{errorHandler.handleError(err);}}

else

SimpleApplicationEventMulticaster提供了事件广播的具体实现支持同步和异步两种事件处理方式并提供了错误处理机制通过这种设计使得事件的处理更加灵活和可靠同时也为性能优化提供了可能。

小小总结

Spring的事件机制通过这些精心设计的组件构建了一个完整的观察者模式实现它不仅支持Spring框架内部的事件处理也为应用程序提供了一个强大的事件驱动架构基础通过这种方式可以实现组件间的松耦合通信提高系统的可维护性和扩展性。

整个实现考虑了性能、可靠性和易用性等多个方面是一个非常典型的观察者模式应用案例。