本站收集了一篇相关的编程文章，网友刘明杰根据主题投稿了本篇教程内容，涉及到Spring、Event、Spring、Event、异步事件、Spring异步事件、实现Spring Event(异步事件)相关内容，已被550网友关注，如果对知识点想更进一步了解可以在下方电子资料中获取。
实现Spring Event(异步事件)
一、叙述
当Spring的事件（Application Event）为Bean和Bean之间的消息同步提供了支持。
当一个Bean处理完成一个任务之后，希望另外一个Bean知道并能做相应的处理，这时我们就需要让另外一个Bean监听当前Bean所发生的事件
Spring的事件需要遵循如下流程
- 自定义事件，继承ApplicationEvent
- 定义事件监听器，实现ApplicationListener
- 使用容器发布事件
Spring框架中事件
Spring提供了以下5种标准的事件：
- 上下文更新事件（ContextRefreshedEvent）：在调用ConfigurableApplicationContext 接口中的refresh()方法时被触发。
- 上下文开始事件（ContextStartedEvent）：当容器调用ConfigurableApplicationContext的Start()方法开始/重新开始容器时触发该事件。
- 上下文停止事件（ContextStoppedEvent）：当容器调用ConfigurableApplicationContext的Stop()方法停止容器时触发该事件。
- 上下文关闭事件（ContextClosedEvent）：当ApplicationContext被关闭时触发该事件。容器被关闭时，其管理的所有单例Bean都被销毁。
请求处理事件（RequestHandledEvent）：在Web应用中，当一个http请求（request）结束触发该事件。
如果一个bean实现了ApplicationListener接口，当一个ApplicationEvent被发布以后，bean会自动被通知
二、上Demo示例
1. pom文件
<!-- https://mvnrepository.com/artifact/org.springframework/org.springframework.context -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>org.springframework.context</artifactId>
<version>3.1.2.RELEASE</version>
</dependency>
2. 自定义一个事件继承ApplicationEvent
import com.hrm.dto.ExamAnswer;
import org.springframework.context.ApplicationEvent;
/**
* 考生答题事件
*/
public class AnswerEvent extends ApplicationEvent {
private static final long serialVersionUID = 1L;
public AnswerEvent(ExamAnswer answer) {
super(answer);
}
}
3. 自定义一个监听器实现ApplicationListener<自定义事件>
import com.hrm.dto.ExamAnswer;
import com.hrm.service.event.AnswerEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.stereotype.Component;
/**
* 答题监听事件
*/
@Component
@EnableAsync
public class AnswerEventListener implements ApplicationListener<ExamAnswer> {
@Override
public void onApplicationEvent(AnswerEvent answerEvent) {
ExamAnswer answer = (ExamAnswer) answerEvent.getSource();
if(answer != null) {
super.save(answer);
}
}
}
4. 再来一个事件发布类
import com.hrm.dto.ExamAnswer;
import com.hrm.service.event.AnswerEvent;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Repository;
@Repository
public class ExamAnswerDaoImpl implements ExamAnswerDao {
@Autowired
private ApplicationContext applicationContext;
private void putAnswerToSpringEvent(ExamAnswer examAnswer) {
发送Spring Event 事件
applicationContext.publishEvent(new AnswerEvent(examAnswer));
}
}
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持码农之家。
