自定义事件以及监听
1.定义事件
首先，我们需要定义一个时间（MyTestEvent)，需要继承Spring的ApplicationEvent
public class MyTestEvent extends ApplicationEvent{
private static final long serialVersionUID = 1L;
private String msg ;
public MyTestEvent(Object source,String msg) {
super(source);
this.msg = msg;
}
public String getMsg() {
return msg;
}
public void setMsg(String msg) {
this.msg = msg;
}
}
- 定义监听器（可以使用接口或者@EventListener() 注解）
需要定义一下监听器，自己定义的监听器需要实现ApplicationListener，同时泛型参数要加上自己要监听的事件Class名，在重写的方法onApplicationEvent中，添加自己的业务处理：
@Component public class MyNoAnnotationListener implements ApplicationListener{ @Override public void onApplicationEvent(MyTestEvent event) { System.out.println("非注解监听器：" + event.getMsg()); } }
使用注解@EventListener()
在任意方法上标注@EventListener 注解，指定 classes，即需要处理的事件类型，一般就是 ApplicationEven 及其子类，可以设置多项
@Configuration
public class Config {
@EventListener(classes = {ApplicationEvent.class})
public void listen(ApplicationEvent event) {
System.out.println("事件触发：" + event.getClass().getName());
}
}
- 事件发布
有了事件，有了事件监听者，那么什么时候触发这个事件呢？每次想让监听器收到事件通知的时候，就可以调用一下事件发布的操作。首先在类里自动注入了ApplicationEventPublisher，这个也就是我们的ApplicationCOntext，它实现了这个接口。
@Component
public class MyTestEventPubLisher {
@Autowired
private ApplicationEventPublisher applicationEventPublisher;
public void pushListener(String msg) {
applicationEventPublisher.publishEvent(new MyTestEvent(this, msg));
}
}
4.测试
用一个HTTP请求来模拟：
@RestController
public class TestEventListenerController {
@Autowired
private MyTestEventPubLisher publisher;
@RequestMapping(value = "/test/testPublishEvent1" )
public void testPublishEvent(){
publisher.pushListener("我来了！");
}
}
参考文献：
SpringBoot中@EventListener注解的使用
