- 浏览: 21969 次
- 性别:
- 来自: 北京
最新评论
在一对多依赖的对象关系中, 如果这个'一'对象状态发生了变化,那么它所有依赖的'多'对象都应该被通知,然后做相应的变化,这就是观察者模式. 就如同'多'对象一直在观察'一'对象的状态变化一样.
在观察者模式中最重要的俩个对象分别是:Observable和Observer对象.它们的关系可总结如下:
1. Observable和Observer对象是一对多的关系,也就是说一旦Observable对象状态变化,它就要负责通知所有和它有关系的Observer对象,然后做相应的改变.
1. Observable对象不会主动去通知各个具体的Observer对象其状态发生了变化,而是提供一个注册接口供Observer对象使用,任何一个Observer对象如果想要被通知,则可以使用这个接口来注册.
3. 在Observable中有一个集合和一个状态控制开关,所有注册了通知的Observer对象会被保存在这个集合中.这个控制开关就是用来控制Observable是否发生了变化,一旦发生了变化,就通知所有的Observer对象更新状态.
在java api中分别提供了Observable对象:java.util.Observable和Observer接口:java.util.Observer. 下面用实例来实现一下观察者模式: 股票系统
所有的类如下:
StockData (Observable对象,也就是所股票数据发生了变化,它就要通知所有和它有关系的交易实体做相应的变化)
BigBuyer (Observer对象, 实现了Observer接口)
TradingFool (Observer对象, 实现了Observer接口)
StockQuote 测试类
在这个例子中一旦StockData对象的状态发生了变化,那BigBuyer和TradingFool都应该受到通知:
StockData.java:
import java.util.Observable;
public class StockData extends Observable
{
private String symbol;
private float close;
private float high;
private float low;
private long volume;
public StockData()
{}
public String getSymbol()
{
return symbol;
}
public float getClose()
{
return close;
}
public float getHigh()
{
return high;
}
public float getLow()
{
return low;
}
public long getVolume()
{
return volume;
}
public void sendStockData()
{
setChanged();
notifyObservers();
}
public void setStockData(String symbol,float close,float high,float low,long volume)
{
this.symbol = symbol;
this.close = close;
this.high = high;
this.low = low;
this.volume = volume;
sendStockData();
}
}
BigBuyer.java:
public class BigBuyer implements Observer
{
private String symbol;
private float close;
private float high;
private float low;
private long volume;
public BigBuyer(Observable observable)
{
observable.addObserver(this); //注册关系
}
public void update(Observable observable,Object args)
{
if(observable instanceof StockData)
{
StockData stockData = (StockData)observable;
this.symbol = stockData.getSymbol();
this.close = stockData.getClose();
this.high = stockData.getHigh();
this.low = stockData.getLow();
this.volume = stockData.getVolume();
display();
}
}
public void display()
{
DecimalFormatSymbols dfs = new DecimalFormatSymbols();
DecimalFormat volumeFormat = new DecimalFormat("###,###,###,###",dfs);
DecimalFormat priceFormat = new DecimalFormat("###.00",dfs);
System.out.println("Big Buyer reports... ");
System.out.println("\tThe lastest stock quote for " + symbol + " is:");
System.out.println("\t$" + priceFormat.format(close) + " per share (close).");
System.out.println("\t$" + priceFormat.format(high) + " per share (high).");
System.out.println("\t$" + priceFormat.format(low) + " per share (low).");
System.out.println("\t" + volumeFormat.format(volume) + " shares traded.");
System.out.println();
}
}
TradingFool.java:
public class TradingFool implements Observer
{
private String symbol;
private float close;
public TradingFool(Observable observable)
{
observable.addObserver(this);//注册关系
}
public void update(Observable observable,Object args)
{
if(observable instanceof StockData)
{
StockData stockData = (StockData)observable;
this.symbol = stockData.getSymbol();
this.close = stockData.getClose();
display();
}
}
public void display()
{
DecimalFormatSymbols dfs = new DecimalFormatSymbols();
DecimalFormat priceFormat = new DecimalFormat("###.00",dfs);
System.out.println("Trading Fool says... ");
System.out.println("\t" + symbol + " is currently trading at $" + priceFormat.format(close) + " per share.");
System.out.println();
}
}
StokeQuote.java
public class StockQuotes
{
public static void main(String[] args)
{
System.out.println();
System.out.println("-- Stock Quote Application --");
System.out.println();
StockData stockData = new StockData();
// register observers...
new TradingFool(stockData);
new BigBuyer(stockData);
// generate changes to stock data...
stockData.setStockData("JUPM",16.10f,16.15f,15.34f,(long)481172);
stockData.setStockData("SUNW",4.84f,4.90f,4.79f,(long)68870233);
stockData.setStockData("MSFT",23.17f,23.37f,23.05f,(long)75091400);
}
}
在测试类中我们可以看到俩个Observer对象都注册了Observable对象,而当Observable对象发生改变时,这俩个Observable对象就会做相应的更新了, 运行结果如下:
Big Buyer reports...
The lastest stock quote for JUPM is:
$16.10 per share (close).
$16.15 per share (high).
$15.34 per share (low).
481,172 shares traded.
Trading Fool says...
JUPM is currently trading at $16.10 per share.
Big Buyer reports...
The lastest stock quote for SUNW is:
$4.84 per share (close).
$4.90 per share (high).
$4.79 per share (low).
68,870,233 shares traded.
Trading Fool says...
SUNW is currently trading at $4.84 per share.
Big Buyer reports...
The lastest stock quote for MSFT is:
$23.17 per share (close).
$23.37 per share (high).
$23.05 per share (low).
75,091,400 shares traded.
Trading Fool says...
MSFT is currently trading at $23.17 per share.
我们通过Observable源码可以看到,其实Observable对象不关心具体的Observer的实例类型. 只要是实现了Observer接口的Observer对象都可以得到通知,这就为我们如果想要对模型进行扩展提供了方便,使Observable对象和Observer对象实现了松耦合. 如果我们需要添加一个新的Observer对象时,我们只要注册一下,当Observable对象发生变化时就可以得到通知,而不要做其他任何改变,非常方便.
在观察者模式中最重要的俩个对象分别是:Observable和Observer对象.它们的关系可总结如下:
1. Observable和Observer对象是一对多的关系,也就是说一旦Observable对象状态变化,它就要负责通知所有和它有关系的Observer对象,然后做相应的改变.
1. Observable对象不会主动去通知各个具体的Observer对象其状态发生了变化,而是提供一个注册接口供Observer对象使用,任何一个Observer对象如果想要被通知,则可以使用这个接口来注册.
3. 在Observable中有一个集合和一个状态控制开关,所有注册了通知的Observer对象会被保存在这个集合中.这个控制开关就是用来控制Observable是否发生了变化,一旦发生了变化,就通知所有的Observer对象更新状态.
在java api中分别提供了Observable对象:java.util.Observable和Observer接口:java.util.Observer. 下面用实例来实现一下观察者模式: 股票系统
所有的类如下:
StockData (Observable对象,也就是所股票数据发生了变化,它就要通知所有和它有关系的交易实体做相应的变化)
BigBuyer (Observer对象, 实现了Observer接口)
TradingFool (Observer对象, 实现了Observer接口)
StockQuote 测试类
在这个例子中一旦StockData对象的状态发生了变化,那BigBuyer和TradingFool都应该受到通知:
StockData.java:
import java.util.Observable;
public class StockData extends Observable
{
private String symbol;
private float close;
private float high;
private float low;
private long volume;
public StockData()
{}
public String getSymbol()
{
return symbol;
}
public float getClose()
{
return close;
}
public float getHigh()
{
return high;
}
public float getLow()
{
return low;
}
public long getVolume()
{
return volume;
}
public void sendStockData()
{
setChanged();
notifyObservers();
}
public void setStockData(String symbol,float close,float high,float low,long volume)
{
this.symbol = symbol;
this.close = close;
this.high = high;
this.low = low;
this.volume = volume;
sendStockData();
}
}
BigBuyer.java:
public class BigBuyer implements Observer
{
private String symbol;
private float close;
private float high;
private float low;
private long volume;
public BigBuyer(Observable observable)
{
observable.addObserver(this); //注册关系
}
public void update(Observable observable,Object args)
{
if(observable instanceof StockData)
{
StockData stockData = (StockData)observable;
this.symbol = stockData.getSymbol();
this.close = stockData.getClose();
this.high = stockData.getHigh();
this.low = stockData.getLow();
this.volume = stockData.getVolume();
display();
}
}
public void display()
{
DecimalFormatSymbols dfs = new DecimalFormatSymbols();
DecimalFormat volumeFormat = new DecimalFormat("###,###,###,###",dfs);
DecimalFormat priceFormat = new DecimalFormat("###.00",dfs);
System.out.println("Big Buyer reports... ");
System.out.println("\tThe lastest stock quote for " + symbol + " is:");
System.out.println("\t$" + priceFormat.format(close) + " per share (close).");
System.out.println("\t$" + priceFormat.format(high) + " per share (high).");
System.out.println("\t$" + priceFormat.format(low) + " per share (low).");
System.out.println("\t" + volumeFormat.format(volume) + " shares traded.");
System.out.println();
}
}
TradingFool.java:
public class TradingFool implements Observer
{
private String symbol;
private float close;
public TradingFool(Observable observable)
{
observable.addObserver(this);//注册关系
}
public void update(Observable observable,Object args)
{
if(observable instanceof StockData)
{
StockData stockData = (StockData)observable;
this.symbol = stockData.getSymbol();
this.close = stockData.getClose();
display();
}
}
public void display()
{
DecimalFormatSymbols dfs = new DecimalFormatSymbols();
DecimalFormat priceFormat = new DecimalFormat("###.00",dfs);
System.out.println("Trading Fool says... ");
System.out.println("\t" + symbol + " is currently trading at $" + priceFormat.format(close) + " per share.");
System.out.println();
}
}
StokeQuote.java
public class StockQuotes
{
public static void main(String[] args)
{
System.out.println();
System.out.println("-- Stock Quote Application --");
System.out.println();
StockData stockData = new StockData();
// register observers...
new TradingFool(stockData);
new BigBuyer(stockData);
// generate changes to stock data...
stockData.setStockData("JUPM",16.10f,16.15f,15.34f,(long)481172);
stockData.setStockData("SUNW",4.84f,4.90f,4.79f,(long)68870233);
stockData.setStockData("MSFT",23.17f,23.37f,23.05f,(long)75091400);
}
}
在测试类中我们可以看到俩个Observer对象都注册了Observable对象,而当Observable对象发生改变时,这俩个Observable对象就会做相应的更新了, 运行结果如下:
Big Buyer reports...
The lastest stock quote for JUPM is:
$16.10 per share (close).
$16.15 per share (high).
$15.34 per share (low).
481,172 shares traded.
Trading Fool says...
JUPM is currently trading at $16.10 per share.
Big Buyer reports...
The lastest stock quote for SUNW is:
$4.84 per share (close).
$4.90 per share (high).
$4.79 per share (low).
68,870,233 shares traded.
Trading Fool says...
SUNW is currently trading at $4.84 per share.
Big Buyer reports...
The lastest stock quote for MSFT is:
$23.17 per share (close).
$23.37 per share (high).
$23.05 per share (low).
75,091,400 shares traded.
Trading Fool says...
MSFT is currently trading at $23.17 per share.
我们通过Observable源码可以看到,其实Observable对象不关心具体的Observer的实例类型. 只要是实现了Observer接口的Observer对象都可以得到通知,这就为我们如果想要对模型进行扩展提供了方便,使Observable对象和Observer对象实现了松耦合. 如果我们需要添加一个新的Observer对象时,我们只要注册一下,当Observable对象发生变化时就可以得到通知,而不要做其他任何改变,非常方便.
发表评论
-
Myeclipse激活教程(windows&linux)
2014-03-03 14:42 0Myeclipse激活教程(windows&linux ... -
JAVA学习路线图
2014-03-03 14:40 0第一阶段-Java基础 ... -
java.util.Date和java.sql.Date的区别及应用
2014-03-03 14:36 509java.util.Date 就是在除了SQL语句的情况下面使 ... -
Java程序员面试中的多线程问题
2014-03-03 14:25 665很多核心Java面试题来源于多线程(Multi-Threadi ... -
如何从Oracle公司官网下载java7 API文档
2014-03-03 14:19 16781、首先打开官网: http://www.oracle.com ... -
java 4中代码块执行顺序
2014-03-03 14:04 542public class FF extends DD { ... -
java 代码块分类说明
2014-03-03 13:42 396一、普通代码块 直 ... -
String转变Date
2014-02-27 18:42 471import java.text.DateFormat; im ... -
Java正则表达式大全
2014-02-26 08:50 898[正则表达式]文本框输入内容控制 整数或者小数:^[0-9]+ ... -
java多线程总结
2014-01-16 11:38 909在java中要想实现多线程 ... -
java 中枚举类型,整型,字符串之间转换
2014-01-08 20:31 460enum<->int enum -> int ... -
创建Json
2014-01-08 09:39 390JSON解析类可以分为以下几个类 JSONObje ... -
JSON解析工具-json-lib
2014-01-08 09:31 519一、简介 json-lib是一个Java类库,提供将Java ...
相关推荐
java观察者模式观察者模式java观察者模式观察者模式java观察者模式观察者模式
观察者模式:对象之间多对一依赖的一种设计方案,被依赖的对象为Subject,依赖的对象为Observer,Subject通知Observer变化,这个例子是java内置观察者模式
java 设计模式 观察者模式 简单实例 包括测试test类
Java 观察者模式的浅析 简单地说,观察者模式定义了一个一对多的依赖关系,让一个或多个观察者对象监察一个主题对象。这样一个主题对象在状态上的变化能够通知所有的依赖于此对象的那些观察者对象,使这些观察者...
java实现观察者设计模式,利用ApplicationListener和ApplicationEvent。Test包里有测试代码
设计模式之观察者模式Java版本实现和UML类设计图
java观察者模式的实例代码。从最简单的实例开始,到观察者模式。有什么问题可以加扣扣共同探讨
Java设计模式的观察者模式讲解,可以由浅入深了解观察者模式的应用。
设计模式--观察者模式java例子
运用观察者模式及MVC模式的整合,是javaWeb的简单的实现了选民投票
观察者模式java 应用场景如下 现在有一个销售各类的电子商务网站的购物车(Shopping Cart)系统。现在本网站进行打折,分别情况如下: 1. 对所有的教材类图书实行每本降价一元的折扣 2. 对连环画类图书提供7%的...
设计模式----观察者模式demo,使用java自带的工具类,实现,后面会上传一个完全自己代码实现的demo
一个很简单但是明了的java观察者模式的demo。备注几乎每行都加了。
Java线程池及观察者模式解决多线程意外死亡重启问题,附件含两个要运行代码!
我们说学习Java应该从Swing开始,那么学习Swing最重要的思想就是对于观察者模式的理解(Observer Pattern)。因为,该设计模式在Java Swing框架中贯穿了始终。对于C#的委托、代理概念所使用的Callback(回调模式--...
java 子线程通过观察者模式通知主线程
设计模式的分类,Java代码中使用观察者模式的案例以及文档
观察者模式实例,用到java的继承,多态,加深概念理解.
结合微信公众号讲解观察者模式,生动形象,关键是上手快啊
用到了纯粹的被观察者 和 一个 既是观察者又是被观察者 和 纯粹的观察者之间的故事