ApplicationContext容器提供了容器内部事件发布功能,是继承自JavaSE标准自定义事件类而实现的。
JavaSE标准自定义事件结构不在此详细描述,一张图很直观的描述清楚:
EventObject,为JavaSE提供的事件类型基类,任何自定义的事件都继承自该类,例如上图中右侧灰色的各个事件。Spring中提供了该接口的子类ApplicationEvent。
EventListener为JavaSE提供的事件监听者接口,任何自定义的事件监听者都实现了该接口,如上图左侧的各个事件监听者。Spring中提供了该接口的子类ApplicationListener接口。
JavaSE中未提供事件发布者这一角色类,由各个应用程序自行实现事件发布者这一角色。Spring中提供了ApplicationEventPublisher接口作为事件发布者,并且ApplicationContext实现了这个接口,担当起了事件发布者这一角色。但ApplicationContext在具体实现上有所差异,Spring提供了ApplicationEventMulticaster接口,负责管理ApplicationListener和发布ApplicationEvent。ApplicationContext会把相应的事件相关工作委派给ApplicationEventMulticaster接口实现类来做。类图如下所示:
事件发布时序图如下:
Spring中提供一些Aware相关的接口,BeanFactoryAware、 ApplicationContextAware、ResourceLoaderAware、ServletContextAware等等,其中最常用到的是ApplicationContextAware。实现ApplicationContextAware的Bean,在Bean被初始后,将会被注入ApplicationContext的实例。ApplicationContextAware提供了publishEvent()方法,实现Observer(观察者)设计模式的事件传播机,提供了针对Bean的事件传播功能。通过Application.publishEvent方法,我们可以将事件通知系统内所有的ApplicationListener。
Spring事件处理一般过程:
◆定义Event类,继承org.springframework.context.ApplicationEvent。
◆编写发布事件类Publisher,实现org.springframework.context.ApplicationContextAware接口。
◆覆盖方法setApplicationContext(ApplicationContext applicationContext)和发布方法publish(Object obj)。
◆定义时间监听类EventListener,实现ApplicationListener接口,实现方法onApplicationEvent(ApplicationEvent event)。
import org.springframework.context.ApplicationEventPublisher; import org.springframework.context.ApplicationEventPublisherAware; /** * * @author zq * */ publicclassHelloWorldimplementsApplicationEventPublisherAware{ privateString word; privateApplicationEventPublisher tradeEventPublisher; publicvoid setWord(String w){ this.word = w; } publicvoid say(){ System.out.println("say : "+this.word); //construct a TradeEvent instance and publish it TradeEvent tradeEvent =newTradeEvent(newString("tradeEvent")); this.tradeEventPublisher.publishEvent(tradeEvent); } @Override publicvoid setApplicationEventPublisher( ApplicationEventPublisher applicationEventPublisher){ // TODO Auto-generated method stub this.tradeEventPublisher = applicationEventPublisher; } }
2.接受事件import org.springframework.context.ApplicationEvent; import org.springframework.context.ApplicationListener; import org.springframework.context.event.ContextStartedEvent; publicclassTradeContextListenerimplementsApplicationListener{ @Override publicvoid onApplicationEvent(ApplicationEvent e){ System.out.println(e.getClass().toString()); // TODO Auto-generated method stub if(e instanceofContextStartedEvent){ System.out.println("it was contextStartedEvent"); } if(e instanceofTradeEvent){ System.out.println(e.getSource()); } } }
3配置文件<?xml version="1.0" encoding="utf-8"?> <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd"> <beans> <beanname="helloWorld"class="study.HelloWorld"> <propertyname="word"value="hello world"/> </bean> <beanid="tradeContextListener"class="study.TradeContextListener"/> </beans>
4.测试代码import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import study.HelloWorld; publicclassTestHelloWorld{ /** * @param args */ publicstaticvoid main(String[] args){ // TODO Auto-generated method stub ApplicationContext applicationContext =newClassPathXmlApplicationContext("study-context.xml"); HelloWorld bean =(HelloWorld)applicationContext.getBean("helloWorld"); bean.say(); } }
1) ContextRefreshedEvent:当ApplicationContext初始化或者刷新时触发该事件。
2) ContextClosedEvent:当ApplicationContext被关闭时触发该事件。容器被关闭时,其管理的所有单例Bean都被销毁。
3) RequestHandleEvent:在Web应用中,当一个http请求(request)结束触发该事件。
ContestStartedEvent:Spring2.5新增的事件,当容器调用ConfigurableApplicationContext的Start()方法开始/重新开始容器时触发该事件。
5) ContestStopedEvent:Spring2.5新增的事件,当容器调用ConfigurableApplicationContext的Stop()方法停止容器时触发该事件。
下面通过一个例子展示如何处理Spring内定的事件(例程3.8)。创建一个Java工程,添加Spring开发能力后,新建ioc.test包。在包中新建ApplicationEventListener类,实现ApplicationListener接口,在onApplicationEvent()方法中添加事件处理代码,如下:
2
3 //Import省略
4 publicclass ApplicationEventListenerimplements ApplicationListener {
5
6 publicvoid onApplicationEvent(ApplicationEvent event) {
7
8 //如果是容器刷新事件
9 if(eventinstanceof ContextClosedEvent ){
10 System.out.println(event.getClass().getSimpleName()+" 事件已发生!");
11 }elseif(eventinstanceof ContextRefreshedEvent ){//如果是容器关闭事件
12 System.out.println(event.getClass().getSimpleName()+" 事件已发生!");
13 }elseif(eventinstanceof ContextStartedEvent ){
14 System.out.println(event.getClass().getSimpleName()+" 事件已发生!");
15 }elseif(eventinstanceof ContextStoppedEvent){
16 System.out.println(event.getClass().getSimpleName()+" 事件已发生!");
17 }else{
18 System.out.println("有其它事件发生:"+event.getClass().getName());
19 }
20
21 }
22
23 }
24
在Spring配置文件中定义一个Bean,类为ApplicationEventListener,代码如下:
2 <beans…………
3
4 <bean id="ApplicationEventListener" class="ioc.test.ApplicationEventListener"/>
5
6 </beans>
7
添加含有主方法的TesMain类,在主方法中,调用容器的相应方法,触发Spring内定事件,代码如下:
2
3 //import省略
4 publicclass TesMain {
5
6 publicstaticvoid main(String[] args) {
7 AbstractApplicationContext ac=new ClassPathXmlApplicationContext("applicationContext.xml");
8
9
10 // ac.refresh();//触发ContextRefreshedEvent事件
11 ac.start();//触发ContextStartedEvent事件
12 ac.stop(); //触发ContextStoppedEvent事件
13 ac.close();//关闭容器,触发ContextClosedEvent事件
14
15 }
16 }
17
运行主类,控制台输出如下:
从例子中可以知道,要注册事件监听器,我们只需要把它配置成一个Bean即可,ApplicationContext容器会自动将其注册。
相关推荐
spring发布和接收定制事件(这个上传必须要填资源分啦),ApplicationContext基于Observer模式(java.util包中有对应实现),提供了针对Bean的事件传 播功能。通过Application. publishEvent方法,我们可以将事件...
Spring事件主要涉及两个核心概念:事件发布(Event Publishing)和事件监听(Event Listening)。在这个"JAVA-spring学习资源之spring事件"中,我们将深入探讨这两个方面,并通过具体的示例来理解它们的工作原理。 ...
本篇文章将深入探讨Spring的配置和事件注入机制,帮助开发者更好地理解和利用这些特性。 首先,让我们关注Spring的配置。Spring的配置主要有两种方式:XML配置和Java配置。在早期的Spring版本中,XML配置是最常用的...
在Spring框架中,`ApplicationContext`不仅是一个容器,用于管理Bean的生命周期和依赖注入,它还提供了事件发布和监听的功能。这个特性使得Spring应用能够实现组件间的异步通信,类似于消息队列(MQ)的工作模式。...
通过发布和监听事件,我们可以创建出更加灵活、可维护的系统架构。 综上所述,Spring事件是基于观察者模式的一种设计模式实现,提供了发布-订阅式的事件处理能力,有助于构建松耦合的应用程序。通过创建自定义事件...
在Spring框架中,事件监听机制是一种非常重要的组件间通信方式,它允许应用程序的不同部分通过发布和订阅事件来进行异步通信。这种模式使得组件之间松耦合,提高了代码的可维护性和可扩展性。下面我们将详细探讨...
在Spring响应式编程中,我们使用Reactor库,这是一个符合 Reactive Streams 规范的Java库,它实现了数据流的发布-订阅模型,确保了非阻塞和异步处理能力。 1. **Reactive Streams**: 这是一个用于处理流的API,定义...
1. `org.springframework.context-3.1.1.RELEASE.jar`:这是 Spring 框架的核心模块之一,提供了上下文抽象,包括bean的生命周期管理、事件传播、国际化等功能。它是 Spring 其他模块的基础,为 Spring AMQP 提供了...
Spring的事件发布通常通过`ApplicationEventPublisher`接口完成,它可以在任何具有`ApplicationContext`的组件中获取并使用,用来发布事件。`ApplicationEventMulticaster`是`ApplicationEventPublisher`的实现,...
Spring应用中可以利用事件发布-订阅模型来解耦组件之间的交互。通过使用ApplicationEvent类和ApplicationListener接口,可以实现事件的发布和监听。Spring的事件机制不仅支持同步事件传播,还可以配置异步事件处理。...
此外,Spring Cloud Bus作为控制总线,用于在微服务之间传播事件,如配置的更新。它可以连接到AMQP(如RabbitMQ)或HTTP服务器,使得全集群的配置更新变得简单。 Spring Cloud Data Flow是一个用于构建、部署和管理...
ApplicationContext是BeanFactory的扩展,提供了更多企业级功能,如事件传播、资源加载和国际化支持。 IoC(控制反转)和DI(依赖注入)是Spring的核心概念,它们通过反转控制(将对象的创建和管理交给容器进行)来...
5. `spring-context.jar`:Spring框架的上下文模块,提供了AOP、事件传播和任务调度等功能。 6. `spring-web.jar`:Spring框架的web模块,包含了处理HTTP请求和响应的相关类。 7. `spring-aop.jar`:Spring的AOP模块...
5. **spring-core**: 核心工具包,包含Spring的基本组件,如资源访问、类型转换、事件传播等。它是其他所有Spring模块的基础。 6. **spring-context-indexer**: 这是一个辅助工具,用于在类路径中自动发现和索引...
SpringJMS允许开发者捕获和处理JMS异常,例如消息无法发送或接收时,可以通过Spring的异常处理机制进行适当的响应。 10. **性能优化** 调整SpringJMS和ActiveMQ的配置,例如设置连接池大小、消息缓存等,可以优化...
Spring框架中的依赖注入(DI)、声明式事务、事件传播等高级特性都可以和Spring AMQP集成,从而简化开发过程。 文档的第二部分是关于“介绍”,这部分是对Spring AMQP和其底层概念以及如何快速开始一个简单应用的...
Spring Event机制基于`ApplicationEvent`接口,当某个组件发生事件时,它创建一个实现了`ApplicationEvent`的实例,并通过`ApplicationContext`的`publishEvent`方法发布这个事件。所有注册为事件监听器的bean会...
Spring Cloud Bus 是 Spring Cloud 中的一个组件,它主要用于在分布式系统中传播事件,例如配置更改。当 Config Server 上的配置发生变更时,Bus 可以将这个变更事件广播到所有微服务,从而触发各个服务的配置更新。...
`spring-context.jar`构建于`spring-core`和`spring-beans`之上,为Spring的其他模块提供了一种集成方式,如国际化、事件传播、资源加载以及邮件服务等。它是Spring应用上下文的中心,使开发者能够轻松地访问应用...
Spring允许我们为每个数据源配置单独的事务管理器,这样可以独立控制各自的事务行为,如隔离级别、传播行为等。 接着,我们来看Spring的多事务处理。在有多个数据源的情况下,Spring支持同时管理多个事务。这意味着...