大话设计模式读书笔记(十一) 观察者模式

观察者模式:

书中通过小菜描述同事在公司看股票行情,并请求前台帮忙在老板回来时提醒同事,引出需求。将前台通知同事老板回来的事写成程序。

未用模式实现:

 1 //前台类
 2 public class Secretary {
 3     private List<StockObserver> observers = new ArrayList<StockObserver>();
 4     private String action;
 5     //添加同事
 6     public void attach(StockObserver observer){
 7         observers.add(observer);
 8     }
 9     //待老板来时,前台通过电话通知所有同事
10     public void notifyObserver(){
11         for (StockObserver o : observers) {
12             o.update();
13         }
14     }
15     public String getAction() {
16         return action;
17     }
18     public void setAction(String action) {
19         this.action = action;
20     }
21     
22 }

 

//同事类
 1 public class StockObserver {
 2     //姓名
 3     private String name;
 4     //前台
 5     private Secretary secretary;
 6     public StockObserver(String name, Secretary secretary) {
 7         super();
 8         this.name = name;
 9         this.secretary = secretary;
10     }
11     public void update() {
12         System.out.println(secretary.getAction()+
13                 ","+name+"关闭股票行情,继续工作!");
14     }
15 }

 

主方法
 1 public class Main {
 2     public static void main(String[] args) {
 3         //前台小姐通知者
 4         Secretary tongzhizhe = new Secretary();
 5         //两位公司同事
 6         StockObserver tongshi1 = new StockObserver("魏关姹", tongzhizhe);
 7         StockObserver tongshi2 = new StockObserver("易管查", tongzhizhe);
 8         //前台几下两位同事
 9         tongzhizhe.attach(tongshi1);
10         tongzhizhe.attach(tongshi2);
11         //老板来了.前台通知同事
12         tongzhizhe.setAction("老板来了");
13         tongzhizhe.notifyObserver();
14     }
15 }

 

  代码虽然将需求的基本功能实现了,但是同事类需要前台小姐的状态,前台小姐需要增加同事。这是典型的双向偶尔。这段代码及违反了开放封闭原则,又违反了依赖倒转原则。

解耦实现:

同事抽象类
//同事抽象类
public abstract class Observer {
private String name;
public abstract void update();
}
同事实现类
//同事类
public class StockObserver extends Observer{
//姓名
private String name;
private Subject subject;
public StockObserver(String name,Subject subject) {
super();
this.name = name;
this.subject = subject;
}
@Override
public void update() {
System.out.println(subject.getAction()+","+name+"关闭股票行情,继续工作!");
}
}
//同事类
public class StockObserver2 extends Observer{
//姓名
private String name;
private Subject subject;
public StockObserver2(String name,Subject subject) {
super();
this.name = name;
this.subject = subject;
}
@Override
public void update() {
System.out.println(subject.getAction()+","+name+"关闭NBA直播,继续工作!");
}
}

通知者抽象类
//通知者抽象类
public abstract class Subject {
String action;
private List<Observer> observers = new ArrayList<Observer>();
//添加同事
public abstract void attach(Observer observer);
//待老板来时,前台通过电话通知所有同事
public abstract void notifyObserver();
public String getAction() {
return action;
}
public void setAction(String action) {
this.action = action;
}
}
通知者实现类:
//前台类
public class Secretary extends Subject{
private List<Observer> observers = new ArrayList<Observer>();
private String action;
//添加同事
public void attach(StockObserver observer){
observers.add(observer);
}
//待老板来时,前台通过电话通知所有同事
public void notifyObserver(){
for (Observer o : observers) {
o.update();
}
}
@Override
public void attach(Observer observer) {
observers.add(observer);
}
public String getAction() {
return action;
}
public void setAction(String action) {
this.action = action;
}
}

主程序:
public class Main {
public static void main(String[] args) {
//前台小姐通知者
Secretary tongzhizhe = new Secretary();
//两位公司同事
Observer tongshi1 = new StockObserver("魏关姹",tongzhizhe);
Observer tongshi2 = new StockObserver2("易管查",tongzhizhe);
//前台几下两位同事
tongzhizhe.attach(tongshi1);
tongzhizhe.attach(tongshi2);
//老板来了.前台通知同事
tongzhizhe.setAction("老板来了");
tongzhizhe.notifyObserver();
}
}

观察者模式定义:

观察者模式又叫做发布-订阅(Publish-Subscribe)模式,它定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。这个主题对象在发生状态变化时,会通知所有观察者对象,使他们能够自动更新自己。

观察者模式UML类图:




观察者模式特点:

适用场景
1) 当一个抽象模型有两个方面, 其中一个方面依赖于另一方面。将这二者封装在独立的对象中以使它们可以各自独立地改变和复用。
2) 当对一个对象的改变需要同时改变其它对象, 而不知道具体有多少对象有待改变。
3) 当一个对象必须通知其它对象,而它又不能假定其它对象是谁。换言之, 你不希望这些对象是紧密耦合的。

-------------------------------------------分割线-----------------------------------------------------------
后面内容摘自博客http://www.cnblogs.com/java-my-life/archive/2012/05/16/2502279.html

推模型和拉模型

  在观察者模式中,又分为推模型和拉模型两种方式。

  ●  推模型

     主题对象向观察者推送主题的详细信息,不管观察者是否需要,推送的信息通常是主题对象的全部或部分数据。

  ●  拉模型

     主题对象在通知观察者的时候,只传递少量信息。如果观察者需要更具体的信息,由观察者主动到主题对象中获取,

相当于是观察者从主题对象中拉数据。一般这种模型的实现中,会把主题对象自身通过update()方法传递给观察者,这样在观察者需要获取数据的时候,

就可以通过这个引用来获取了。

  根据上面的描述,发现前面的例子就是典型的推模型,下面给出一个拉模型的实例。

  拉模型的抽象观察者类

  拉模型通常都是把主题对象当做参数传递。

复制代码
public interface Observer {/*** 更新接口* @param subject 传入主题对象,方面获取相应的主题对象的状态*/public void update(Subject subject);
}
复制代码

  拉模型的具体观察者类

复制代码
public class ConcreteObserver implements Observer {//观察者的状态private String observerState;@Overridepublic void update(Subject subject) {/*** 更新观察者的状态,使其与目标的状态保持一致*/observerState = ((ConcreteSubject)subject).getState();System.out.println("观察者状态为:"+observerState);}}
复制代码

  拉模型的抽象主题类

  拉模型的抽象主题类主要的改变是nodifyObservers()方法。在循环通知观察者的时候,也就是循环调用观察者的update()方法的时候

,传入的参数不同了。

复制代码
public abstract class Subject {/*** 用来保存注册的观察者对象*/private    List<Observer> list = new ArrayList<Observer>();/*** 注册观察者对象* @param observer    观察者对象*/public void attach(Observer observer){list.add(observer);System.out.println("Attached an observer");}/*** 删除观察者对象* @param observer    观察者对象*/public void detach(Observer observer){list.remove(observer);}/*** 通知所有注册的观察者对象*/public void nodifyObservers(){for(Observer observer : list){observer.update(this);}}
}
复制代码

  拉模型的具体主题类

  跟推模型相比,有一点变化,就是调用通知观察者的方法的时候,不需要传入参数了。

复制代码
public class ConcreteSubject extends Subject{private String state;public String getState() {return state;}public void change(String newState){state = newState;System.out.println("主题状态为:" + state);//状态发生改变,通知各个观察者this.nodifyObservers();}
}
复制代码

  两种模式的比较

  ■  推模型是假定主题对象知道观察者需要的数据;而拉模型是主题对象不知道观察者具体需要什么数据,没有办法的情况下,干脆把自身传递

给观察者,让观察者自己去按需要取值。

  ■  推模型可能会使得观察者对象难以复用,因为观察者的update()方法是按需要定义的参数,可能无法兼顾没有考虑到的使用情况。这就意味

着出现新情况的时候,就可能提供新的update()方法,或者是干脆重新实现观察者;而拉模型就不会造成这样的情况,因为拉模型下,update()方法的

参数是主题对象本身,这基本上是主题对象能传递的最大数据集合了,基本上可以适应各种情况的需要。


JAVA提供的对观察者模式的支持

  在JAVA语言的java.util库里面,提供了一个Observable类以及一个Observer接口,构成JAVA语言对观察者模式的支持。

  Observer接口

  这个接口只定义了一个方法,即update()方法,当被观察者对象的状态发生变化时,被观察者对象的notifyObservers()方法就会调用这一方法。

public interface Observer {void update(Observable o, Object arg);
}

  Observable类

  被观察者类都是java.util.Observable类的子类。java.util.Observable提供公开的方法支持观察者对象,这些方法中有两个对Observable的子类非常

重要:一个是setChanged(),另一个是notifyObservers()。第一方法setChanged()被调用之后会设置一个内部标记变量,代表被观察者对象的状态发生

了变化。第二个是notifyObservers(),这个方法被调用时,会调用所有登记过的观察者对象的update()方法,使这些观察者对象可以更新自己。

复制代码
public class Observable {private boolean changed = false;private Vector obs;/** Construct an Observable with zero Observers. */public Observable() {obs = new Vector();}/*** 将一个观察者添加到观察者聚集上面*/public synchronized void addObserver(Observer o) {if (o == null)throw new NullPointerException();if (!obs.contains(o)) {obs.addElement(o);}}/*** 将一个观察者从观察者聚集上删除*/public synchronized void deleteObserver(Observer o) {obs.removeElement(o);}public void notifyObservers() {notifyObservers(null);}/*** 如果本对象有变化(那时hasChanged 方法会返回true)* 调用本方法通知所有登记的观察者,即调用它们的update()方法* 传入this和arg作为参数*/public void notifyObservers(Object arg) {Object[] arrLocal;synchronized (this) {if (!changed)return;arrLocal = obs.toArray();clearChanged();}for (int i = arrLocal.length-1; i>=0; i--)((Observer)arrLocal[i]).update(this, arg);}/*** 将观察者聚集清空*/public synchronized void deleteObservers() {obs.removeAllElements();}/*** 将“已变化”设置为true*/protected synchronized void setChanged() {changed = true;}/*** 将“已变化”重置为false*/protected synchronized void clearChanged() {changed = false;}/*** 检测本对象是否已变化*/public synchronized boolean hasChanged() {return changed;}/*** Returns the number of observers of this <tt>Observable</tt> object.** @return  the number of observers of this object.*/public synchronized int countObservers() {return obs.size();}
}
复制代码

  这个类代表一个被观察者对象,有时称之为主题对象。一个被观察者对象可以有数个观察者对象,每个观察者对象都是实现Observer接口的对象。

在被观察者发生变化时,会调用Observable的notifyObservers()方法,此方法调用所有的具体观察者的update()方法,从而使所有的观察者都被通知更

新自己。

怎样使用JAVA对观察者模式的支持

  这里给出一个非常简单的例子,说明怎样使用JAVA所提供的对观察者模式的支持。在这个例子中,被观察对象叫做Watched;而观察者对象叫做

Watcher。Watched对象继承自java.util.Observable类;而Watcher对象实现了java.util.Observer接口。另外有一个Test类扮演客户端角色。

  源代码

  被观察者Watched类源代码

复制代码
public class Watched extends Observable{private String data = "";public String getData() {return data;}public void setData(String data) {if(!this.data.equals(data)){this.data = data;setChanged();}notifyObservers();}    
}
复制代码

 

  观察者类源代码

复制代码
public class Watcher implements Observer{public Watcher(Observable o){o.addObserver(this);}@Overridepublic void update(Observable o, Object arg) {System.out.println("状态发生改变:" + ((Watched)o).getData());}}
复制代码

  测试类源代码

复制代码
public class Test {public static void main(String[] args) {//创建被观察者对象Watched watched = new Watched();//创建观察者对象,并将被观察者对象登记Observer watcher = new Watcher(watched);//给被观察者状态赋值watched.setData("start");watched.setData("run");watched.setData("stop");}}
复制代码

  Test对象首先创建了Watched和Watcher对象。在创建Watcher对象时,将Watched对象作为参数传入;然后Test对象调用Watched对象的

setData()方法,触发Watched对象的内部状态变化;Watched对象进而通知实现登记过的Watcher对象,也就是调用它的update()方法。

转载于:https://www.cnblogs.com/xsyfl/p/6842511.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/371051.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

解决高度塌陷

<!DOCTYPE html> <html lang"en" dir"ltr"><head><meta charset"utf-8"><title>高度塌陷解决</title><style media"screen">.box1{border: 10px #bfc993 solid;}.box2{width: 100px;height…

IBM AIX:Java进程大小监视

本文将为您提供有关如何计算在IBM AIX 5.3 OS上运行的Java VM进程的Java进程大小内存占用量的快速参考指南。 这是我关于该主题的原始文章的补充文章&#xff1a; 如何在AIX上监视Java本机内存 。 我强烈建议所有参与生产支持或AIX上部署Java应用程序开发的人员阅读此书。 为…

pstate0 vid数值意义_天体运动的简单数值计算

&#xff08;建议阅读全文&#xff09; 预备知识 万有引力&#xff0c; 弹簧振子受迫运动的简单数值计算    下面我们来用一种极其简单的算法对单个天体在中心天体的万有引力作用下的运动进行数值计算&#xff0e; 事实上该问题存在解析解&#xff08;见开普勒三定律&#x…

集合框架

集合框架包含的内容&#xff1a; 集合框架的接口&#xff1a; List接口实现类 ArrayList 1 package com.jredu.ch01;3 import java.util.ArrayList;5 import java.util.List;7 public class ArrayListTest {9 public static void main(String[] args) { 10 // TODO…

Java中的类型安全的空集合

我之前曾在Java Collections类的实用程序上进行过博客撰写&#xff0c;并且特别地在使用Usings Collections Methods上的博客emptyList&#xff08;&#xff09;&#xff0c;emptyMap&#xff08;&#xff09;和emptySet&#xff08;&#xff09;上进行了博客撰写。 在本文中&a…

剑指offer二十二之从上往下打印二叉树

一、题目 从上往下打印出二叉树的每个节点&#xff0c;同层节点从左至右打印。 二、思路 二叉树的层次遍历&#xff0c;可以借助队列实现。具体思路详见注释。 三、代码 import java.util.ArrayList; import java.util.LinkedList; /** public class TreeNode {int val 0;Tree…

arduino i2c 如何写16位寄存器_arduino入门

硬件&#xff1a;Arduino Uno是基于ATmega328P(数据表)的微控制器板。它具有14个数字输入/输出引脚(其中6个可用作PWM输出)&#xff0c;6个模拟输入&#xff0c;工作电压5v&#xff0c;输入电压7-12v。串行&#xff1a;0(RX)和1(TX)用于接收(RX)和发送(TX)TTL串行数据。这些引脚…

mysql序列号生成_一文看懂mycat的6种全局序列号实现方式

概述在实现分库分表的情况下&#xff0c;数据库自增主键已无法保证自增主键的全局唯一。为此&#xff0c;MyCat 提供了全局sequence&#xff0c;并且提供了包含本地配置和数据库配置等多种实现方式。下面对这几种实现方式做一下介绍。1、本地文件方式原理&#xff1a;此方式 My…

android.graphics.Paint方法setXfermode (Xfermode x...

[java] view plaincopymPaint new Paint(); mPaint.setXfermode(new PorterDuffXfermode(PorterDuff.Mode.SCREEN)); 常见的Xfermode&#xff08;SRC为原图&#xff0c;DST为目标图&#xff09;&#xff0c;把代码中的SRC_IN换成下图指定的模式就会出现对应的效果图…

从零开始的全栈工程师——html篇1

全栈工程师也可以叫web 前端 H5主要是网站 app 小程序 公众号这一块 HTML篇 html(超文本标记语言&#xff0c;标记通用标记语言下的一个应用。) “超文本”就是指页面内可以包含图片、链接&#xff0c;甚至音乐、程序等非文字元素。 超文本标记语言的结构包括“头”部分&am…

苹果mp3软件_优秀的Apple音乐转换器,将任何iTunes M4P,AAX,AA转换为MP3

Macsome iTunes Converter是一款优秀的音频转换工具&#xff0c;这款音频转换软件能够帮助大家快速进行音频格式转换&#xff0c;使得您可以自由的播放和分享自己喜爱的音频文件。同时这款软件与大多数音频转换软件一样&#xff0c;将受到保护DRM的Apple音乐转换转换成MP3, AAC…

虚幻4毛发系统_虚幻引擎复活!苹果与Epic对决,有哪些游戏险些中枪?

最近&#xff0c;苹果和Epic的官司闹得沸沸扬扬。随着Epic旗下热门手游《堡垒之夜》遭苹果火速下架&#xff0c;两大巨头之间的冲突愈演愈烈。苹果似乎并不满足于此&#xff0c;由于Epic公开违反自家规定&#xff0c;苹果计划进一步封禁Epic维护虚幻引擎的开发者账户&#xff0…

01-JAVA语言基础

1.设计思想&#xff1a; 先以字符串的形式输入两个数字&#xff0c;然后将他们转化为int类型&#xff0c;再对两数进行相加&#xff0c;最后输出结果。 2.程序流程图&#xff1a; 3.源程序代码&#xff1a; import java.util.Scanner;public class Addition2 {public static vo…

php签名墙,肺功能检查质量控制网

2017年12月2日&#xff0c;由中华医学会呼吸病学分会/儿科分会、国家呼吸系统疾病临床医学研究中心、国家呼吸疾病医疗质量控制中心、中国肺功能联盟、中国儿童肺功能协作组主办&#xff0c;浙江省中医院承办的"2017年中国肺功能检查规范化培训及应用推广学习班暨肺功能检…

餐饮水单打印软件_开发一款餐饮手机app系统软件什么价格?有哪些方面需要考虑?...

开发一款餐饮手机app系统软件什么价格&#xff1f;有哪些方面需要考虑&#xff1f;近年来&#xff0c;餐饮类的APP如雨后春笋般快速增长&#xff0c;无论是上档次的酒店&#xff0c;还是各大餐厅&#xff0c;都有各自的专属APP。餐饮APP的开发能让大型酒店/餐厅获得更多盈利、销…

Spring-framework应用程序启动loadtime源码分析笔记(二)——@Transactional

Transactional标识类或方法&#xff0c;使方法被执行时使用事务方式执行&#xff0c;这里只讨论PROXY方法增强方法。使用EnableTransactionManagement&#xff0c;默认modelAdviceMode.PROXY&#xff0c;通过Import(TransactionManagementConfigurationSelector.class)来判断在…

具有Spring的简单工作流引擎

几个月前&#xff0c;在处理一个公司项目时&#xff0c;我们需要开发REST服务&#xff0c;该服务用于根据客户端应用程序发送的数据发送电子邮件。 在开发此服务期间&#xff0c;我们决定创建简单的工作流引擎&#xff0c;该引擎将为发送电子邮件收费&#xff0c;但该引擎也可用…

TypeScript学习笔记归纳(持续更新ing)

文章目录 前言 二、TypeScript的优势体现在哪里&#xff1f; 1、执行时间上的区别 2、基础数据类型区别 3、TS优势 三、TypeScript的关键特性 四、TypeScript的类型系统 1、什么是类型注释&#xff1f; 2、类型系统核心 - 常用类型 1&#xff09; 基本类型&#xff0…

组态王 6.55 启停plc_永宏PLC在远程控制系统中的应用

一、行业介绍本远程控制系统是给石药集团的下属子公司设计的一个控制方案。主要是配套GPRS-DTU产品实现远程plc与plc之间的数据共享。从而达到远程无线数据写入控制和读取监控的目的。二、客户需求(1) 客户可以在监控室控制至少2-3公里外的井上两个水泵的启动和停止。(2) 客户可…

Vue表格中,对数据进行转换、处理

众所周知&#xff0c;后端从Mysql取出的数据&#xff0c;一般是很难单独处理某一个Key的数据的&#xff08;需要处理的话&#xff0c;可能会浪费大量的性能。而且对页面加载时间有很大的影响&#xff09;&#xff0c;所以&#xff0c;从数据库取出的数据。只能由前端进行处理。…