我的编程空间,编程开发者的网络收藏夹
学习永远不晚

java的观察者模式是什么

短信预约 -IT技能 免费直播动态提醒
省份

北京

  • 北京
  • 上海
  • 天津
  • 重庆
  • 河北
  • 山东
  • 辽宁
  • 黑龙江
  • 吉林
  • 甘肃
  • 青海
  • 河南
  • 江苏
  • 湖北
  • 湖南
  • 江西
  • 浙江
  • 广东
  • 云南
  • 福建
  • 海南
  • 山西
  • 四川
  • 陕西
  • 贵州
  • 安徽
  • 广西
  • 内蒙
  • 西藏
  • 新疆
  • 宁夏
  • 兵团
手机号立即预约

请填写图片验证码后获取短信验证码

看不清楚,换张图片

免费获取短信验证码

java的观察者模式是什么

这篇文章主要讲解了“java的观察者模式是什么”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“java的观察者模式是什么”吧!

消息队列(MQ),一种能实现生产者到消费者单向通信的通信模型,这也是现在常用的主流中间件。

常见有 RabbitMQ、ActiveMQ、Kafka等 他们的特点也有很多 比如 解偶、异步、广播、削峰 等等多种优势特点。

在设计模式中也有一种模式能有效的达到解偶、异步的特点,那就是观察者模式又称为发布订阅模式。

今天阿丙就分享一下实际开发中比较常见的这种模式

大纲

java的观察者模式是什么

定义

什么是观察者模式?他的目的是什么?

  • 当一个对象的状态发生改变时,已经登记的其他对象能够观察到这一改变从而作出自己相对应的改变。通过这种方式来达到减少依赖关系,解耦合的作用。

举一个例子,就好比微信朋友圈,以当前个人作为订阅者,好友作为主题。一个人发一条动态朋友圈出去,他的好友都能看到这个朋友圈,并且可以在自主选择点赞或者评论。

感觉有点抽象,还是看看他有哪些主要角色:

java的观察者模式是什么

  • Subject(主题): 主要由类实现的可观察的接口,通知观察者使用attach方法,以及取消观察的detach方法。

  • ConcreteSubject(具体主题): 是一个实现主题接口的类,处理观察者的变化

  • Observe(观察者): 观察者是一个由对象水岸的接口,根据主题中的更改而进行更新。

这么看角色也不多,但是感觉还是有点抽象,我们还是用具体实例代码来走一遍吧,我们还是以上面的朋友圈为例看看代码实现

public interface Subject {     // 添加订阅关系     void attach(Observer observer);     // 移除订阅关系     void detach(Observer observer);     // 通知订阅者     void notifyObservers(String message); }

先创建一个主题定义,定义添加删除关系以及通知订阅者

public class ConcreteSubject implements Subject {      // 订阅者容器     private List<Observer> observers = new ArrayList<Observer>();      @Override     public void attach(Observer observer) {         // 添加订阅关系         observers.add(observer);     }      @Override     public void detach(Observer observer) {         // 移除订阅关系         observers.remove(observer);     }      @Override     public void notifyObservers(String message) {         // 通知订阅者们         for (Observer observer : observers) {             observer.update(message);         }     } }

其次再创建的具体主题,并且构建一个容器来维护订阅关系,支持添加删除关系,以及通知订阅者

public interface Observer {     // 处理业务逻辑     void update(String message); }

创建一个观察者接口,方便我们管理

public class FriendOneObserver implements Observer {       @Override     public void update(String message) {         // 模拟处理业务逻辑         System.out.println("FriendOne 知道了你发动态了" + message);     } }

最后就是创建具体的观察者类,实现观察者接口的update方法,处理本身的业务逻辑

public class test {          public static void main(String[] args) {          ConcreteSubject subject = new ConcreteSubject();         // 这里假设是添加好友         subject.attach(new FriendOneObserver());         FriendTwoObserver twoObserver = new FriendTwoObserver();         subject.attach(twoObserver);          // 发送朋友圈动态         subject.notifyObservers("第一个朋友圈消息");         // 输出结果:FriendOne 知道了你发动态了第一个朋友圈消息         //          FriendTwo 知道了你发动态了第一个朋友圈消息          // 这里发现 twoObserver 是个推荐卖茶叶的,删除好友         subject.detach(twoObserver);         subject.notifyObservers("第二个朋友圈消息");         // 输出结果:FriendOne 知道了你发动态了第二个朋友圈消息     } }

最后就是看测试结果了,通过ConcreteSubject 维护了一个订阅关系,在通过notifyObservers  方法通知订阅者之后,观察者都获取到消息从而处理自己的业务逻辑。

java的观察者模式是什么

这里细心的朋友已经达到了解耦合的效果,同时也减少了依赖关系,每个观察者根本不要知道发布者处理了什么业务逻辑,也不用依赖发布者任何业务模型,只关心自己本身需要处理的逻辑就可以了。

如果有新的业务添加进来,我们也只需要创建一个新的订阅者,并且维护到observers 容器中即可,也符合我们的开闭原则。

这里只是一种同步的实现方式,我们还可以扩展更多其他的异步实现方式,或者采用多线程等实现方式。

框架应用

观察者模式在框架的中的应用也是应该很多

  • 第一种 熟悉JDK的人应该知道 在java.util 包下 除了常用的 集合  和map之外还有一个Observable类,他的实现方式其实就是观察者模式。里面也有添加、删除、通知等方法。

这里需要注意是的 他是用Vector 作为订阅关系的容器,同时在他的定义方法中都添加synchronized关键字修饰类,以达到线程安全的目的

这里我贴出了关键源码,感兴趣的同学可以自己打开并且观看每个方法的注释。

java的观察者模式是什么

java的观察者模式是什么

  • 第二种  在Spring中有一个ApplicationListener,也是采用观察者模式来处理的,ApplicationEventMulticaster作为主题,里面有添加,删除,通知等。

spring有一些内置的事件,当完成某种操作时会发出某些事件动作,他的处理方式也就上面的这种模式,当然这里面还有很多,我没有细讲,有兴趣的同学可以仔细了解下Spring的启动过程。

import java.util.EventListener; @FunctionalInterface public interface ApplicationListener<E extends ApplicationEvent> extends EventListener {     void onApplicationEvent(E event);  }

  • 第三种 Google Guava的事件处理机制Guava EventBus 他的实现也是采用设计模式中的观察者设计模式。

EventBus 当前实现有两种方式:

  • EventBus // 同步阻塞模式

  • AsyncEventBus // // 异步非阻塞模式

EventBus内部也提供来一系列的方法来供我们方便使用:

  • register 方法作为添加观察者

  • unregister方法删除观察者

  • post 方法发送通知消息等

使用起来非常方便。添加@Subscribe注解就可以创建一个订阅者了,具体的使用方式可以看看官网。

现实业务改造举例

框架应用的例子这么多,在业务场景中其实也有很多地方可以使用到,这里我还是给大家举一个例子。

在新用户注册成功之后我们需要给用户做两件事情,第一是发送注册成功短信,第二是给用发送新人优惠券。

看到这个问题  大家可能首先会想到用MQ消息处理呀,是的,用消息确实可以的,但是这里我们用观察者模式来实现这个问题,同时可以给大家演示一下,同步或者异步的问题。

  1. public class SendNewPersonCouponObserver implements Observer { 

  2.  

  3.     ExecutorService pool = Executors.newFixedThreadPool(2); 

  4.  

  5.     @Override 

  6.     public void update(String message) { 

  7.  

  8.         Future<String> future = pool.submit(new Callable<String>() { 

  9.             @Override 

  10.             public String call() throws Exception { 

  11.                 TimeUnit.SECONDS.sleep(3); 

  12.                 // 处理响应的业务逻辑 

  13.                 return "调用发券服务,返回结果"; 

  14.             } 

  15.         }); 

  16.         try { 

  17.             // 假设等待200毫秒 没有获取到返回值结果则认为失败 

  18.             System.out.println(future.get(4000, TimeUnit.MILLISECONDS)); 

  19.         } catch (Exception e) { 

  20.             // 执行异步获取失败 

  21.             // 记录日志,定时任务重试等 

  22.         } 

  23.  

  24.         // 第一种不关心返回值结果 

  25.         Thread thread = new Thread(new Runnable() { 

  26.             @SneakyThrows 

  27.             @Override 

  28.             public void run() { 

  29.                 // 模拟服务调用 线程睡3秒钟 

  30.                 TimeUnit.SECONDS.sleep(3); 

  31.                 System.out.println("发送新人优惠券"); 

  32.             } 

  33.         }); 

  34.         thread.start(); 

  35.         System.out.println("执行异步返回"); 

  36.     } 


public class SendSuccessMessageObserver implements Observer {      @Override     public void update(String message) {         // 处理业务逻辑         System.out.println("注册成功");     }      public static void main(String[] args) {         // 假设用户注册成功直接通知观察者,改干自己的事情了         ConcreteSubject subject = buildSubject();         subject.notifyObservers("");     }      private static ConcreteSubject buildSubject() {         ConcreteSubject subject = new ConcreteSubject();         subject.attach(new SendSuccessMessageObserver());         subject.attach(new SendNewPersonCouponObserver());         return subject;     } }

 java的观察者模式是什么

这里我们新写了两个观察者,主要看第一个SendNewPersonCouponObserver,这里了异步开启新的线程去处理我们的业务逻辑,当我们关心返回值的时候可以用Future来获取返回结果,当不关心的返回值的化,直接开启普通线程就可以了。

这个举例整体其实还是比较简单的主要是为了说清楚异步线程处理,当然如果用Guava  EventBus也可以实现。而且也不复杂,感兴趣的朋友可以自己去试试。

当前现在有更加好的中间件MQ消息队列来处理这个业务问题,使得我们更加从容的面对这类场景问题,但是一些资源不足,不想引入新的系统。还是可以用这种方式来处理问题的。

设计模式学习的不是代码,而是学习每种模式的思想,他们分别处理的是什么业务场景。

总结

大家看完本篇文章不知道有发现没有,其实整个内容都是围绕了解耦的思想来写的,观察者模式作为行为型设计模式,主要也是为了不同的业务行为的代码解耦。

合理的使用设计模式可以使代码结构更加清晰,同时还能满足不同的小模块符合单一职责,以及开闭原则,从而达到前面写工厂模式说的,提高代码的可扩展性,维护成本低的特点。

感谢各位的阅读,以上就是“java的观察者模式是什么”的内容了,经过本文的学习后,相信大家对java的观察者模式是什么这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是编程网,小编将为大家推送更多相关知识点的文章,欢迎关注!

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

java的观察者模式是什么

下载Word文档到电脑,方便收藏和打印~

下载Word文档

猜你喜欢

java观察者模式是什么

本篇内容介绍了“java观察者模式是什么”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!观察者模式① 观察者模式的概念观察者模式(Observ
2023-06-19

Java编程中的观察者模式是什么

这篇文章主要介绍“Java编程中的观察者模式是什么”,在日常操作中,相信很多人在Java编程中的观察者模式是什么问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”Java编程中的观察者模式是什么”的疑惑有所帮助!
2023-05-30

Java观察者模式有什么用

这篇文章主要为大家展示了“Java观察者模式有什么用”,内容简而易懂,条理清晰,希望能够帮助大家解决疑惑,下面让小编带领大家一起研究并学习一下“Java观察者模式有什么用”这篇文章吧。一、观察者模式的定义和特点观察者模式的定义:指多个对象间
2023-06-22

PHP中的观察者模式是什么

这篇文章主要讲解了“PHP中的观察者模式是什么”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“PHP中的观察者模式是什么”吧!介绍现在有两派,有的人建议使用设计模式,有的人不建议使用设计模式!
2023-06-20

Java观察者模式的实现方法是什么

Java观察者模式的实现方法如下:定义观察者接口(Observer):观察者接口定义了观察者对象的更新方法,通常包括一个update()方法来接收被观察者的通知。定义被观察者接口(Subject):被观察者接口定义了被观察者的行为,包括添加
2023-10-23

PHP中的观察者模式是什么意思

本篇内容主要讲解“PHP中的观察者模式是什么意思”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“PHP中的观察者模式是什么意思”吧!观察者,貌似在很多科幻作品中都会有这个角色的出现。比如我很喜欢的
2023-06-20

java观察者模式怎么实现

要实现观察者模式,你可以按照以下步骤进行:定义观察者接口(Observer):该接口应该包含一个方法,用于接收被观察者的通知。public interface Observer {void update();}定义被观察者接口(Subje
2023-10-27

Java设计模式中的观察者模式

观察者模式定义对象之间的一种一对多的依赖关系,使得每当一个对象的状态发生变化时,其相关的依赖对象都可以得到通知并被自动更新。主要用于多个不同的对象对一个对象的某个方法会做出不同的反应
2023-02-16

详解Java中的观察者模式

详解Java中的观察者模式?相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。定义:定义对象间一种一对多的依赖关系,使得当每一个对象改变状态,则所有依赖于它的对象都会得到通知并自动更
2023-05-31

怎么理解Java设计模式的观察者模式

本篇内容介绍了“怎么理解Java设计模式的观察者模式”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!一、什么是观察者模式在许多设计中,经常涉及
2023-06-25

Android中实现观察者模式的原理是什么

这篇文章将为大家详细讲解有关Android中实现观察者模式的原理是什么,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。观察者模式:A类中定义一个被观察者画家package com.exampl
2023-05-31

Java观察者模式实例分析

这篇文章主要讲解了“Java观察者模式实例分析”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“Java观察者模式实例分析”吧!使用场景观察者模式所做的工作其实就是在解耦,让耦合的双方都依赖于抽
2023-06-27

JAVA怎样实现观察者模式

这篇文章将为大家详细讲解有关JAVA怎样实现观察者模式,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。概念观察者模式又叫做发布-订阅模式,是对象间的一对多的关系,当一个对象的状态发生改变时,所有依赖于它的对
2023-06-29

Java设计模式中的观察者模式怎样的

今天就跟大家聊聊有关Java设计模式中的观察者模式怎样的,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。一、观察者模式的定义和特点观察者模式的定义:指多个对象间存在一对多的依赖关系,当
2023-06-22

编程热搜

目录