Spring Boot使用ApplicationEvent来实现事件发布订阅功能(美女一个都不能少，都要通知到)

历史文章（累计400+篇文章）

《国内最全的Spring Boot系列之一》

《国内最全的Spring Boot系列之二》

《国内最全的Spring Boot系列之三》

《国内最全的Spring Boot系列之四》

《国内最全的Spring Boot系列之五》

你真的学会了Lambda表达式了吗？一篇让你学废了不香么 - 第417篇

当你的Stream遇上Lambda就爱上了，超级无敌酷酷！- 第418篇

java8+lambda+Stream api实战案例学彻底透学废 - 第419篇

悟纤：师傅，我发现我最近写的代码耦合度太高了？

师傅：怎么说？

悟纤：师傅你看哦，我这里有新的企业用户注册了，我需要将企业用户的信息保存到数据库，另外呢，我还需要通知到审核人员进行数据的审核，另外还需要发送通知到代理商进行企业用户的跟进。这代码完全耦合在一起了，有没有一种什么的方式可以不耦合在一起呐。

师傅：这个吧，如果使用了MQ的话，那么就很容易解耦了，如果没有使用到又想解耦的话，Spring倒是提供了一种事件发布订阅的方式。

悟纤：这牛牪犇逼。那师傅赶紧跟我讲讲呗。

师傅：来，学习走起~…

导读：

在很多源码中，会使用到Spring的事件ApplicationEvent，比如Nacos的源码中就用到了很多，心跳监测，然后通知其它的集群节点；节点变化了通知其它的集群节点，如下的代码：

然后发布事件之后，被PushService监听处理了：

OK，到这里的代码截图，这个思路你如果都了解的话，那么本节你就可以不用看了。

如果你还没有理清楚，好的，那么你有必要来看看了。

第一篇章我在朋友圈发布了条信息

我们发布了一条信息到朋友圈，这里使用Controller进行模拟：

package com.kfit.demo;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.context.ApplicationContext;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController;/** * MeController * * @author 悟纤「公众号SpringBoot」 * @date 2022-02-08 * @slogan 大道至简 悟在天成 */@RestController@RequestMapping("/me")public class MeController {    @Autowired    private ApplicationContext applicationContext;    @RequestMapping("/publishMsg")    public String publishMsg(String message){        //发布了一条信息：message        System.out.println(message);        return "OK";    }}

启动SpringBoot应用，现在就是简单的在控制台进行打印了。

第二篇章我想让关注我的人收到我的信息

朋友圈自己玩肯定是没啥意思了，我是希望我发布了之后，那些关注我的人可以收到我的最新动态，然后给我点个赞，于是当我在朋友圈发布信息之后，我发布了一个我信息更新的事件：

package com.kfit.demo;import org.springframework.context.ApplicationEvent;/** *  定义消息更新事件 * @author 悟纤「公众号SpringBoot」 * @date 2022-02-08 * @slogan 大道至简 悟在天成 */public class MessageUpdateApplicationEvent extends ApplicationEvent {    public MessageUpdateApplicationEvent(Object source) {        super(source);    }}

第三篇章谷爱凌关注我了

谷爱凌关注了我的朋友圈，那么对于关注我的人只要监听我消息发布的事件，一旦我发布了事件之后，那么就能够收到我的最新的消息了：

package com.kfit.demo;import org.springframework.context.ApplicationListener;import org.springframework.stereotype.Component;/** * * 监听事件 * * @author 悟纤「公众号SpringBoot」 * @date 2022-02-08 * @slogan 大道至简 悟在天成 */@Componentpublic class MessageUpdateListener implements ApplicationListener<MessageUpdateApplicationEvent> {    @Override    public void onApplicationEvent(MessageUpdateApplicationEvent event) {        System.out.println("收到事件信息："+event.getSource());        System.out.println("点个赞先...");    }}

第四篇章我发布了一条新的信息

我们对于发布信息的地方做个修改，我们需要发布一个事件：

@RequestMapping("/publishMsg")public String publishMsg(String message){    //发布了一条信息：message    System.out.println(message);    applicationContext.publishEvent(new MessageUpdateApplicationEvent(message));    return "OK";}

这里的发布事件主要是使用了applicationContext的publishEvent进行发布的。

运行下程序，访问如下地址：

http://127.0.0.1:8080/me/publishMsg?message=今天你真棒

查看控制台：

到这里我们就实现了Spring的事件监听了。

ApplicationEvent总结

1> ApplicationEvent是什么？

ApplicationEvent以及Listener是Spring为我们提供的一个事件监听、订阅的实现，内部实现原理是观察者设计模式，设计初衷也是为了系统业务逻辑之间的解耦，提高可扩展性以及可维护性。

2> Spring事件发布监听机制

流程：当事件源（发布者）发布事件时，相应监听此事件的监听者接收到事件对象并且进行处理Spring的事件发布监听机制本质上就是发布-订阅，即生产者-消费者，也体现了设计模式中的观察者模式。

1> ApplicationEvent使用步骤

（1）事件（ApplicationEvent）：创建ApplicationEvent事件

（2）事件发布者（ApplicationEventPublisher）：事件发布

（3）事件监听者（ApplicationListener）：创建ApplicationListener事件监听

说明：没有事件监听也不影响程序的运行。

辅助理解：我们有一个事件要发布，那么就要有一个发布者的角色，那么事件发布了，被谁处理或者说被谁监听呐，那么就需要监听者的角色。所以：

事件发布者(ApplicationEventPublisher)发布了一个事件（ApplicationEvent）被某些事件监听者（ApplicationListener）监听处理。

（1）如何定义事件：继承(extends)类ApplicationEvent。

（2）如何发布事件：使用applicationContext的publishEvent进行发布事件。比如：

applicationContext.publishEvent(newMessageUpdateApplicationEvent(message));

（3）如何监听事件：实现(implements)接口ApplicationListener<T>的onApplicationEvent()方法。

2> ApplicationEvent的益处

一个是很好的解耦。减少模块之间的依赖，也可以做消息传播，广播等。去触发某一个事件。

我就是我，是颜色不一样的烟火。
我就是我，是与众不同的小苹果。

à云课堂学院：悟空学院

学院中有Spring Boot相关的课程！！

SpringBoot视频：从零开始学Spring Boot Plus - 网易云课堂

SpringBoot交流平台：https://t.cn/R3QDhU0

SpringSecurity5.0视频：权限管理spring security - 网易云课堂

ShardingJDBC分库分表：分库分表Sharding-JDBC实战 - 网易云课堂

分布式事务解决方案：分布式事务解决方案「手写代码」 - 网易云课堂

JVM内存模型调优实战：深入理解JVM内存模型/调优实战 - 网易云课堂

Spring入门到精通：Spring零基础从入门到精通 - 网易云课堂

大话设计模式之爱你：大话设计模式之爱你一万年 - 网易云课堂

Spring Boot使用ApplicationEvent来实现事件发布订阅功能(美女一个都不能少，都要通知到) - 第420篇相关推荐

Spring Boot使用Redis进行消息的发布订阅
https://www.tianmaying.com/tutorial/springboot-redis-message 转载于:https://www.cnblogs.com/chen-msg/p/ ...
Spring Boot 2.x基础教程：使用Redis的发布订阅功能
通过前面一篇集中式缓存的使用教程,我们已经了解了Redis的核心功能:作为K.V存储的高性能缓存. 接下来我们会分几篇来继续讲讲Redis的一些其他强大用法!如果你对此感兴趣,一定要关注收藏我哦! 发 ...
Android中使用EventBus事件发布/订阅框架实现事件传递
场景 EventBus EventBus是一种用于Android的事件发布-订阅总线.它简化了应用程序内各个组件之间进行通信的复杂度,尤其是碎片之间进行通信的问题,可以避免由于使用广播通信而带来的诸多 ...
ASP.NET Core中实现单体程序的事件发布/订阅 - LamondLu - 博客园
标题:ASP.NET Core中实现单体程序的事件发布/订阅作者:Lamond Lu 地址:https://www.cnblogs.com/lwqlun/p/10468058.html 项目源代码:h ...
Vue + Spring Boot 学习笔记01：实现用户登录功能
Vue + Spring Boot 学习笔记01:实现用户登录功能一.创建后端Spring Boot项目Book Management 二.创建前端Vue项目bm-vue 三.修改后端项目Book ...
【springboot】【redis】springboot+redis实现发布订阅功能，实现redis的消息队列的功能...
springboot+redis实现发布订阅功能,实现redis的消息队列的功能参考:https://www.cnblogs.com/cx987514451/p/9529611.html 思考一个问 ...
redis的观察者模式----------发布订阅功能
2019独角兽企业重金招聘Python工程师标准>>> 众所周知,Java,C++等面向对象有一种常见的设计模式:观察者模式,redis这种机制叫做发布订阅功能. 以下假设已redi ...
你还不了解Redis的发布/订阅功能与Redis的Stream吗
一.Redis 中的发布/订阅功能发布/ 订阅系统是 Web 系统中比较常用的一个功能.简单点说就是发布者发布消息,订阅者接受消息,这有点类似于我们的报纸/ 杂志社之类的: (借用前边的一张图) ...
Redis 发布订阅功能
redis在windows下查看工具 Another Redis Desktop Manager 发布订阅有多种实现方式,常用pubsub和stream 1.基于频道(Channel)或模式(Patt ...

Spring Boot使用ApplicationEvent来实现事件发布订阅功能(美女一个都不能少，都要通知到) - 第420篇

Spring Boot使用ApplicationEvent来实现事件发布订阅功能(美女一个都不能少，都要通知到) - 第420篇相关推荐

最新文章

热门文章