通俗易懂地玩转Spring框架中的事件订阅发布
场景
java开发中有些逻辑是这样的,完成了A操作,再继续B操作,在继续C操作。这么描述好像有点不清楚。打个比方把,你吃晚饭,通知你老婆(女友)来收碗筷,然后通知你的线上兄弟告诉他们你回来了准备开黑。至于你老婆(女友)来不来收拾无所谓,反正你告诉她了。至于你兄弟你也是通知他们,人家也不一定组你,万一他们正在跟一个一拖三的carry大佬玩的正起劲儿呢。
事件的概念
吃晚饭就是一个所谓的事件。触发了随后的两个操作,他们只存在因果关系。不存在事务关系。总不能你女友不收拾,你回退到吃饭前的情况吧。所以事件一般适用于没有事务的操作。如果你真的需要在事件中插入一些事务,该考虑引入一些消息中间件了,比如我之前科普的rabbitmq或者apache 的rocketmq。
spring中的事件玩法
新建一个springboot工程
声明一个事件。通过继承org.springframework.context.ApplicationEvent 来编写事件。时间里定义好事件推送到监听器需要执行的方法,当然也可以在监听器里写触发逻辑。
事件发布器。发布事件通过实现 事件发布接口org.springframework.context.ApplicationEventPublisher 或者其门面接口org.springframework.context.ApplicationEventPublisherAware, 推荐门面接口,里面要定义一个主动推送事件的方法如下图的 refreshEvent方法,实际代理了 ApplicationEventPublisher 执行其publishEvent 方法
事件监听,通过实现 org.springframework.context.ApplicationListener<E extends ApplicationEvent> 来实现事件的监听。特别注意泛型E,如果不指定事件将可以接收任何事件,尽量职责单一
将上面三个类注入spring 容器中,这里我们采用了 javaConfig方式,看起来更明显
这里就大功告成了,那么如何使用呢,执行事件发布器的发布方法refreshEvent就行了 ,我们来写一个单元测试
运行一下,入图
到此你应该就学会使用spring事件了,这样写出来的代码逼格更高。还能提现你对spring的一些理解。相关代码在我的码云仓库:https://gitee.com/felord/event-spring.git
- 通俗易懂地玩转Spring框架中的事件订阅发布
- 如何利用callback机制开发基于WCF的事件发布/订阅系统
- 基于EventAggregator的事件发布及订阅
- 15天玩转redis —— 第九篇 发布/订阅模式
- Prism里EventAggregator的事件订阅及发布
- 观察者(发布订阅)模式 与 委托事件
- 如何使dojo组件具有发布和订阅事件的能力
- js事件订阅、发布
- 观察者(发布订阅)模式 与 委托事件
- Android EventBus发布/订阅事件总线
- 观察者(发布订阅)模式 与 委托事件
- 基于EventAggregator的事件发布及订阅
- JavaScript事件发布/订阅模式原理与用法分析
- 事件发布/订阅轻量级框架EVENTBUS
- 基于JS原生的事件订阅和发布模式代码
- 使用MediatR重构单体应用中的事件发布/订阅
- 发布 / 订阅的事件总线(eventBus)
- StackExchange.Redis官方文档(六)【事件,发布订阅,服务器命令】
- 一、概述 EventBus是一款针对Android优化的发布/订阅事件总线。主要功能是替代Intent,Handler,BroadCast在Fragment,Activity,Service,线程之间
- ASP.NET Core实现单体程序的事件发布/订阅详解