个人中心
退出
Spring Boot使用ApplicationEvent来实现事件发布订阅功能(美女一个都不能少，都要通知到) - 第420篇
导读：
在很多源码中，会使用到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()方法。
购买完整视频，请前往：http://www.mark-to-win.com/TeacherV2.html?id=287
分类导航