用悟空召唤土地的方式讲解事件通知机制与观察者模式
小时候最开心的事莫过于躺在沙发上看《西游记》了。大闹天宫、三打白骨精、真假美猴王......一幕幕精彩的故事萦绕脑海,现在想来,回味无穷。
不知道你有没有注意到这个细节:每当孙悟空到了一个新的环境需要了解本地的“风土人情”时,都会挥舞一下金箍棒,将土地召唤出来。那么你可知道,土地公公接收孙悟空召唤的原理是什么吗?
事件通知机制
我们可以先将其理解为“事件通知机制”,即每当孙悟空将金箍棒敲在地上时,就相当于给土地发了一封 email 的通知,告诉他俺老孙来了,赶快出来接驾。当土地收到通知之后就会立即现身了。
大家都知道 Spring 已经为我们提供好了事件监听、订阅的实现,接下来我们用代码来实现一下这个场景。
首先我们要定义一个事件,来记录下孙悟空敲地的动作。
@Getter public class MonkeyKingEvent extends ApplicationEvent { private MonkeyKing monkeyKing; public MonkeyKingEvent(MonkeyKing monkeyKing) { super("monkeyKing"); this.monkeyKing = monkeyKing; } }
其中 MonkeyKing
是我们定义好的孙悟空的实体类
@Data public class MonkeyKing { /** * 是否敲地,默认为否 **/ private boolean knockGround = false; }
然后我们需要实现 ApplicationListener
来监听孙悟空敲地的动作。
@Component public class MyGuardianListener implements ApplicationListener<MonkeyKingEvent> { @Override public void onApplicationEvent(MonkeyKingEvent event) { boolean knockGround = event.getMonkeyKing().isKnockGround(); if(knockGround){ MyGuardian.appear(); }else{ MyGuardian.seclusion(); } } }
最后我们来验证下整个流程。
@PostMapping public void testEvent(@RequestParam boolean knockGround) { MonkeyKing monkeyKing = new MonkeyKing(); monkeyKing.setKnockGround(knockGround); MonkeyKingEvent monkeyKingEvent = new MonkeyKingEvent(monkeyKing); //发布孙悟空敲地的动作事件 applicationEventPublisher.publishEvent(monkeyKingEvent); }
当我们调用testEvent()
方法传入knockGround
为 true
时,打印
土地公公出现了
传入为false
时,打印
土地公公遁地了
这样我们就简单实现了“孙悟空召唤土地”的功能。你以为这样就结束了?从小老师就教导我们要“知其然,更要知其所以然”。
大家都说读源码更像是在喝咖啡,读不懂又苦又涩,读懂了浓郁醇香。为了不影响大家的好心情,这里我们就不研究它的源码了,我们直捣黄龙。
观察者模式
说是事件通知机制也好,事件监听-订阅的实现也罢,其实它内部的最终实现原理依赖的是观察者模式。看到这,先不要胆怯,不要觉得设计模式晦涩难懂、久攻不下。今天我就用通俗易懂的小故事来带你重新认识一下观察者模式。
故事是这样的,上边我们只说了孙悟空敲地的动作,但是你是否还记得孙悟空将金箍棒往天上一指,便换来雷公电母、龙王等为其施法布雨?闭上双眼,与虎力大仙比试的场景仍历历在目。
由此可见,不光土地能收到孙悟空的通知,连雷公电母和龙王也是可以接收到的。在这里,我们把孙悟空比作主题,也就是大家说的被观察者和 Subject
的概念,把雷公电母和龙王以及土地比作观察者。
以下是我们的代码逻辑:
首先,我们定义一个主题的基础类,里边会记录所有订阅该主题的观察者列表,还包含了增加、删除以及通知观察者的方法。
public class Subject { //观察者列表 private Vector<Observer> vector = new Vector(); /** * 增加观察者 **/ public void addObserver(Observer observer){ vector.add(observer); } /** * 删除观察者 **/ public void deleteObserver(Observer observer){ vector.remove(observer); } /** * 通知所有观察者 **/ public void notifyObserver(String goldenCudgel) { for(Observer observer : vector) { observer.update(goldenCudgel); } } }
然后,我们定义一个观察者的接口,包含观察者收到通知之后的“动作”。
public interface Observer { void update(String goldenCudgel); }
这时候我们再分别定义出“土地”、“雷公电母”、“龙王”的观察者实体类,实现具体的打雷下雨等动作。
“雷公电母”、“龙王”等实现与“土地”类似,故此处仅展示观察者“土地”。
@Component public class MyGuardianObserver implements Observer { @Override public void update(String goldenCudgel) { if(upGoldenCudgel(goldenCudgel)) { System.out.println("土地公公出现了"); } } public boolean upGoldenCudgel(String goldenCudgel){ if(Objects.equals(goldenCudgel,"down")){ return true; } return false; } }
接着,我们就可以定义被观察者的具体实现类“孙悟空”了
public class MonkeyKingSubject extends Subject{ /** * 金箍棒是举起来还是放下呢?哈哈,你猜猜。。。 **/ public void doGoldenCudgel(String goldenCudgel){ notifyObserver(goldenCudgel); } }
最后我们来做个测试看看他们能不能响应孙悟空的通知。
@PostMapping public void observerTest(){ MonkeyKingSubject subject = new MonkeyKingSubject(); subject.addObserver(new ThunderGodObserver()); subject.addObserver(new MyGuardianObserver()); subject.addObserver(new DragonKingObserver()); subject.doGoldenCudgel("up"); System.out.println("我是分割线-----------------------------"); subject.doGoldenCudgel("down"); }
结果展示
雷公电母发出电闪雷鸣 龙王前来下雨 我是分割线----------------------------- 土地公公出现了
总结
故事的最后怎么能少的了总结呢?观察者模式与事件通知机制都是在一对多的关系中,当一个对象被修改时,则会自动通知依赖它的对象,两者之间相互独立,互相解耦,这样既省去了反复检索状态的资源消耗,也能够得到最高的反馈速度。
当然它的缺点也不容忽视:
- 如果一个被观察者对象有很多的直接和间接的观察者的话,将所有的观察者都通知到会花费很多时间;
- 如果在观察者和观察目标之间有循环依赖的话,观察目标会触发它们之间进行循环调用,可能导致系统崩溃;
- 观察者模式没有相应的机制让观察者知道所观察的目标对象是怎么发生变化的,而仅仅只是知道观察目标发生了变化;
文章的最后,照例奉上源码,后台回复 event
即可获取。以上就是今天的全部内容了,如果你有不同的意见或者更好的idea
,欢迎联系阿Q,添加阿Q可以加入技术交流群参与讨论呦!
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
【Redis核心原理专题】(1)「技术提升系列」分析探究如何实现LFU的热点key发现机制以及内部的Scan扫描技术的原理
前言介绍 业务中存在访问热点是在所难免的,redis也会遇到这个问题,然而如何发现热点key一直困扰着许多用户,redis4.0为我们带来了许多新特性,其中便包括基于LFU的热点key发现机制。 Least Frequently Used Least Frequently Used——简称LFU,意为最不经常使用,是redis4.0新增的一类内存逐出策略,从LFU的字面意思我们很容易联想到key的访问频率,但是4.0最初版本仅用来做内存逐出,对于访问频率并没有很好的记录,那么经过一番改造,redis于4.0.3版本开始正式支持基于LFU的热点key发现机制。 LFU算法介绍 Redis中每个对象都有24 bits空间来记录LRU/LFU信息: typedef struct redisObject { unsigned type:4; unsigned encoding:4; unsigned lru:LRU_BITS; /* LRU time (relative to global lru_clock) or * LFU data (least significant 8 bits f...
- 下一篇
数据有了,如何构建数据资产?
本文由百度智能云大数据资深产品经理——崔宝宏在百度开发者沙龙线上分享的演讲内容整理而成。本次分享模拟企业面临的真实场景,介绍如何利用百度大数据产品帮助企业构建数据资产。 本次分享从以下四个环节展开: 场景介绍 架构设计 数据开发 应用开发 01场景介绍 为了让大家更好的了解这些产品的应用,首先模拟一个企业应用场景demo: 有一家中型的零售商,客户和销售数据分散在不同系统中。希望通过一个项目打通并实现标准化、集中化的管理。管理好了之后同时希望能把数据实现价值发挥,为高层提供多维度的销售报表,维度包括:客户、产品、地域和时间。度量包括:销售额和净利润。 企业在技术层面上有如下需求: 原始数据存储于MySQL数据库或者其他的文件中。 为了保护原始生态系统的稳定性,不用查询源数据直接访问生产主库。 最大处理TB级数据,需要2小时完成数据全链路处理。 报表查询秒级响应。 业务需求分析 业务解读: 数据打通及标准化,通常按照数仓/数据集市方式实现数据治理。 高层使用多维报表需要考虑页面效果以及需求高效响应,客户高层的需求除了常用的东西之外还需要快速的响应需求。 技术解读: TB级别在...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
-
Docker使用Oracle官方镜像安装(12C,18C,19C)
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- CentOS8编译安装MySQL8.0.19
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- MySQL8.0.19开启GTID主从同步CentOS8
- CentOS7,8上快速安装Gitea,搭建Git服务器
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
推荐阅读
最新文章
- SpringBoot2整合Thymeleaf,官方推荐html解决方案
- Red5直播服务器,属于Java语言的直播服务器
- CentOS6,CentOS7官方镜像安装Oracle11G
- 设置Eclipse缩进为4个空格,增强代码规范
- Windows10,CentOS7,CentOS8安装MongoDB4.0.16
- SpringBoot2整合MyBatis,连接MySql数据库做增删改查操作
- CentOS8安装MyCat,轻松搞定数据库的读写分离、垂直分库、水平分库
- SpringBoot2初体验,简单认识spring boot2并且搭建基础工程
- Windows10,CentOS7,CentOS8安装Nodejs环境
- SpringBoot2整合Redis,开启缓存,提高访问速度