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()方法。

 

2>  ApplicationEvent的益处

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


  1. 购买完整视频,请前往:http://www.mark-to-win.com/TeacherV2.html?id=287