Spring Boot使用ApplicationEvent来实现事件发布订阅功能(美女一个都不能少，都要通知到) - 第420篇_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零基础从入门到精通 - 网易云课堂

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