Java中的观察者设计模式-示例教程
观察者模式是行为设计模式之一 。 当您对对象的状态感兴趣并希望在发生任何更改时得到通知时,观察者设计模式很有用。 在观察者模式中,监视另一个对象状态的对象称为Observer ,而正在监视的对象称为Subject 。 根据GoF,观察者模式意图是:
在对象之间定义一对多依赖关系,以便当一个对象更改状态时,将自动通知和更新其所有依赖关系。
主题包含观察者列表,以通知其状态的任何变化,因此它应提供观察者可以自己注册和注销的方法。 主题还包含一种将所有更改通知所有观察者的方法,它既可以在通知观察者的同时发送更新,也可以提供另一种获取更新的方法。
观察者应该有一个方法来设置要监视的对象,另一种方法将由Subject用来通知他们任何更新。
Java提供了一个内置平台,用于通过java.util.Observable类和java.util.Observer接口实现Observer模式。 但是由于它的实现非常简单,因此并未得到广泛使用,并且大多数时候我们不想只为了实现Observer模式而扩展一个类,因为Java在类中不提供多重继承。
Java消息服务(JMS)使用Observer模式和Mediator模式来允许应用程序将数据订阅和发布到其他应用程序。
模型-视图-控制器(MVC)框架还使用观察者模式,其中模型是主题,视图是观察者,可以注册以获取有关模型的任何更改的通知。
观察者模式示例
对于我们的示例,我们将实现一个简单的主题,观察者可以注册该主题。 每当将任何新消息发布到该主题时,所有注册观察者都会收到通知,他们可以使用该消息。
根据主题的要求,这里是基本主题接口,用于定义任何具体主题要实施的合同方法。
package com.journaldev.design.observer;public interface Subject {//methods to register and unregister observerspublic void register(Observer obj);public void unregister(Observer obj);//method to notify observers of changepublic void notifyObservers();//method to get updates from subjectpublic Object getUpdate(Observer obj);}
接下来,我们将为观察者创建合同,将有一种方法将Subject附加到观察者,另一种方法供Subject用来通知任何更改。
package com.journaldev.design.observer;public interface Observer {//method to update the observer, used by subjectpublic void update();//attach with subject to observepublic void setSubject(Subject sub);
}
现在我们的合同已经准备好了,让我们继续具体执行该主题。
package com.journaldev.design.observer;import java.util.ArrayList;
import java.util.List;public class MyTopic implements Subject {private List<Observer> observers;private String message;private boolean changed;private final Object MUTEX= new Object();public MyTopic(){this.observers=new ArrayList<>();}@Overridepublic void register(Observer obj) {if(obj == null) throw new NullPointerException("Null Observer");if(!observers.contains(obj)) observers.add(obj);}@Overridepublic void unregister(Observer obj) {observers.remove(obj);}@Overridepublic void notifyObservers() {List<Observer> observersLocal = null;//synchronization is used to make sure any observer registered after message is received is not notifiedsynchronized (MUTEX) {if (!changed)return;observersLocal = new ArrayList<>(this.observers);this.changed=false;}for (Observer obj : observersLocal) {obj.update();}}@Overridepublic Object getUpdate(Observer obj) {return this.message;}//method to post message to the topicpublic void postMessage(String msg){System.out.println("Message Posted to Topic:"+msg);this.message=msg;this.changed=true;notifyObservers();}}
注册和注销观察者的方法实现非常简单,额外的方法是postMessage() ,客户端应用程序将使用该方法将String消息发布到主题。 请注意,布尔变量用于跟踪主题状态的变化,并用于通知观察者。 此变量是必需的,这样,如果没有更新,并且有人调用notifyObservers()方法,它就不会向观察者发送错误的通知。
还要注意在notifyObservers()方法中使用了同步 ,以确保仅将消息发送给在将消息发布到主题之前注册的观察者。
这是将监视该主题的Observers的实现。
package com.journaldev.design.observer;public class MyTopicSubscriber implements Observer {private String name;private Subject topic;public MyTopicSubscriber(String nm){this.name=nm;}@Overridepublic void update() {String msg = (String) topic.getUpdate(this);if(msg == null){System.out.println(name+":: No new message");}elseSystem.out.println(name+":: Consuming message::"+msg);}@Overridepublic void setSubject(Subject sub) {this.topic=sub;}}
请注意update()方法的实现,在此方法中它正在调用Subject getUpdate()方法来获取要使用的消息。 我们可以通过将message作为参数传递给update()方法来避免此调用。
这是使用我们的主题实现的简单测试程序。
package com.journaldev.design.observer;public class ObserverPatternTest {public static void main(String[] args) {//create subjectMyTopic topic = new MyTopic();//create observersObserver obj1 = new MyTopicSubscriber("Obj1");Observer obj2 = new MyTopicSubscriber("Obj2");Observer obj3 = new MyTopicSubscriber("Obj3");//register observers to the subjecttopic.register(obj1);topic.register(obj2);topic.register(obj3);//attach observer to subjectobj1.setSubject(topic);obj2.setSubject(topic);obj3.setSubject(topic);//check if any update is availableobj1.update();//now send message to subjecttopic.postMessage("New Message");}}
当我们运行上面的程序时,我们得到以下输出。
Obj1:: No new message
Message Posted to Topic:New Message
Obj1:: Consuming message::New Message
Obj2:: Consuming message::New Message
Obj3:: Consuming message::New Message
观察者模式类图
观察者模式也称为发布-订阅模式。 它的一些实现是;
- Swing中的java.util.EventListener
- javax.servlet.http.HttpSessionBindingListener
- javax.servlet.http.HttpSessionAttributeListener
这就是Java中Observer模式的全部内容,希望您喜欢它。 通过评论和与他人分享来分享您的爱。
翻译自: https://www.javacodegeeks.com/2013/08/observer-design-pattern-in-java-example-tutorial.html
Java中的观察者设计模式-示例教程相关推荐
- Java中的状态设计模式–示例教程
状态模式是行为设计模式之一 . 当对象根据其内部状态更改其行为时,将使用状态设计模式. 如果必须根据对象的状态更改其行为,则可以在对象中使用状态变量,并使用if-else条件块根据状态执行不同的操作. ...
- Java中的Memento设计模式-示例教程
记忆模式是行为设计模式之一 . 当我们要保存对象的状态以便以后可以恢复时,可以使用Memento设计模式. 记忆模式用于以这种方式实现该目的,即在对象外部无法访问该对象的已保存状态数据,从而保护了已保 ...
- Java中的访问者设计模式–示例教程
访客模式是行为设计模式之一 . 当我们必须对一组相似类型的对象执行操作时,将使用访问者模式. 借助访问者模式,我们可以将操作逻辑从对象移动到另一个类. 例如,假设有一个购物车,我们可以在其中添加不同类 ...
- Java中的策略设计模式-示例教程
策略模式是行为设计模式之一 . 当我们对一个特定任务有多种算法,并且客户端决定在运行时使用的实际实现时,将使用策略模式. 策略模式也称为策略模式 . 我们定义了多种算法,并让客户端应用程序将算法用作参 ...
- Java中的迭代器设计模式–示例教程
迭代器模式是一种行为模式,用于提供遍历一组对象的标准方式. Iterator模式在Java Collection Framework中得到了广泛使用,其中Iterator接口提供了遍历集合的方法. 根 ...
- java 观察者模式示例_Java中的观察者设计模式-示例教程
java 观察者模式示例 观察者模式是行为设计模式之一 . 当您对对象的状态感兴趣并希望在发生任何更改时得到通知时,观察者设计模式很有用. 在观察者模式中,监视另一个对象状态的对象称为Observer ...
- Java依赖注入 - DI设计模式示例教程
Java依赖注入 - DI设计模式示例教程 Java依赖注入 设计模式允许我们删除硬编码的依赖项,并使我们的应用程序松散耦合,可扩展和可维护.我们可以在java中实现依赖注入,以将依赖项解析从编译时移 ...
- java 设计模式 示例_Java中的状态设计模式–示例教程
java 设计模式 示例 状态模式是行为设计模式之一 . 当对象根据其内部状态更改其行为时,将使用状态设计模式. 如果必须根据对象的状态更改其行为,则可以在对象中使用状态变量,并使用if-else条件 ...
- java 设计模式 示例_Java中的访问者设计模式–示例教程
java 设计模式 示例 访客模式是行为设计模式之一 . 当我们必须对一组相似类型的对象执行操作时,将使用访问者模式. 借助访问者模式,我们可以将操作逻辑从对象移动到另一个类. 例如,假设有一个购物车 ...
最新文章
- MySQL基础篇:SELECT几种子句
- PLSQL_海量数据处理系列3_索引
- 不同视图间的跳转方式
- mac 使用 php artisan,在Mac php artisan上設置Laravel遷移錯誤:沒有這樣的文件或目錄[duplicate]...
- Python(27)-模块
- Centos启动卡住,starting auditd: [failed]
- cdr 表格自动填充文字_PS那些好用到哭的新手小技巧(1)——如何快速去除文字图片的水印或背景文字?...
- centos java jdk 升级_centos jdk 升级到1.7.0_45方法
- 【快速乘与快速幂例题讲解】相乘取余爆long long?试试快速乘吧!
- 2020最新安卓版本是多少_努比亚Z20安卓P版本刷机包(官方最新固件rom下载V2.24正式版)...
- 描述数据库表关系之间的ER图(1对1,1对多,多对1,多对多等关系)
- 【实用工具】【图像处理,超大图片识别,方案篇:化繁为简】
- 虚拟机跑服务器网速慢,VMware虚拟机上网速度慢怎么办-解决VMware打开网页缓慢的方法 - 河东软件园...
- iOS 屏幕旋转监听
- 前端小白奋斗史03(css)
- 正则表达式中(RegExp)的字符和转译
- 向下取整数学符号_向上取整与向下取整
- 个人博客制作——首页部分
- GKB字符集转UTF-8
- 快手+何向南团队最新论文Counterfactual Interactive Recommender System ,反事实推理融入离线强化学习,解决filter bubble/信息茧房问题
热门文章
- Java 判断密码是否是大小写字母、数字、特殊字符中的至少三种
- 时间格式转换2020-04-09T23:00:00.000+08:00
- Google浏览器截长图 不需要借助任何插件!!!
- 计算机三级网络技术题库第15套,第15套 上机操作题
- java_basic_review(5) java继承
- apache.camel_Apache Camel 3.1 –即将推出更多骆驼核心优化
- 自动化测试框架 2019_2019年用于自动化的5个最佳Java测试框架
- 使用Speedment 3.0.17及更高版本简化了事务
- jaxb报错_JAXB做错了; 尝试Xembly
- netbeans插件_如何编写NetBeans插件