Java中观察者模式的使用

在一对多依赖的对象关系中, 如果这个'一'对象状态发生了变化,那么它所有依赖的'多'对象都应该被通知,然后做相应的变化,这就是观察者模式. 就如同'多'对象一直在观察'一'对象的状态变化一样.

创新互联公司2013年成立，先为永定等服务建站，永定等地企业，进行企业商务咨询服务。为永定企业网站制作PC+手机+微官网三网同步一站式服务解决您的所有建站问题。

在观察者模式中最重要的俩个对象分别是: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:

Java代码

 
 
 
    
  
  
  
  1. import java.util.Observable;     
    2.   
  
  
  2.     
    3.   
  
  
  3. public class StockData extends Observable     
    4.   
  
  
  4.     {     
    5.   
  
  
  5.     private String symbol;     
    6.   
  
  
  6.     private float close;     
    7.   
  
  
  7.     private float high;     
    8.   
  
  
  8.     private float low;     
    9.   
  
  
  9.     private long volume;     
    10.   
  
  
  10.     
    11.   
  
  
  11.     public StockData()     
    12.   
  
  
  12.         {}     
    13.   
  
  
  13.     
    14.   
  
  
  14.     public String getSymbol()     
    15.   
  
  
  15.         {     
    16.   
  
  
  16.         return symbol;     
    17.   
  
  
  17.         }     
    18.   
  
  
  18.     
    19.   
  
  
  19.     public float getClose()     
    20.   
  
  
  20.         {     
    21.   
  
  
  21.         return close;     
    22.   
  
  
  22.         }     
    23.   
  
  
  23.     
    24.   
  
  
  24.     public float getHigh()     
    25.   
  
  
  25.         {     
    26.   
  
  
  26.         return high;     
    27.   
  
  
  27.         }     
    28.   
  
  
  28.     
    29.   
  
  
  29.     public float getLow()     
    30.   
  
  
  30.         {     
    31.   
  
  
  31.         return low;     
    32.   
  
  
  32.         }     
    33.   
  
  
  33.     
    34.   
  
  
  34.     public long getVolume()     
    35.   
  
  
  35.         {     
    36.   
  
  
  36.         return volume;     
    37.   
  
  
  37.         }     
    38.   
  
  
  38.     
    39.   
  
  
  39.     public void sendStockData()     
    40.   
  
  
  40.         {     
    41.   
  
  
  41.         setChanged();     
    42.   
  
  
  42.         notifyObservers();     
    43.   
  
  
  43.         }     
    44.   
  
  
  44.     
    45.   
  
  
  45.     public void setStockData(String symbol,float close,float high,float low,long volume)     
    46.   
  
  
  46.         {     
    47.   
  
  
  47.         this.symbol = symbol;     
    48.   
  
  
  48.         this.close = close;     
    49.   
  
  
  49.         this.high = high;     
    50.   
  
  
  50.         this.low = low;     
    51.   
  
  
  51.         this.volume = volume;     
    52.   
  
  
  52.         sendStockData();     
    53.   
  
  
  53.         }     
    54.   
  
  
  54.     }    
    55.

BigBuyer.java:

Java代码

 
 
 
    
  
  
  
  1. public class BigBuyer implements Observer     
    2.   
  
  
  2.     {     
    3.   
  
  
  3.     private String symbol;     
    4.   
  
  
  4.     private float close;     
    5.   
  
  
  5.     private float high;     
    6.   
  
  
  6.     private float low;     
    7.   
  
  
  7.     private long volume;     
    8.   
  
  
  8.     
    9.   
  
  
  9.     public BigBuyer(Observable observable)     
    10.   
  
  
  10.         {     
    11.   
  
  
  11.         observable.addObserver(this); //注册关系     
    12.   
  
  
  12.         }     
    13.   
  
  
  13.     
    14.   
  
  
  14.     public void update(Observable observable,Object args)     
    15.   
  
  
  15.         {     
    16.   
  
  
  16.         if(observable instanceof StockData)     
    17.   
  
  
  17.             {     
    18.   
  
  
  18.             StockData stockData = (StockData)observable;     
    19.   
  
  
  19.             this.symbol = stockData.getSymbol();     
    20.   
  
  
  20.             this.close = stockData.getClose();     
    21.   
  
  
  21.             this.high = stockData.getHigh();     
    22.   
  
  
  22.             this.low = stockData.getLow();     
    23.   
  
  
  23.             this.volume = stockData.getVolume();     
    24.   
  
  
  24.             display();     
    25.   
  
  
  25.             }     
    26.   
  
  
  26.         }     
    27.   
  
  
  27.     
    28.   
  
  
  28.     public void display()     
    29.   
  
  
  29.         {     
    30.   
  
  
  30.         DecimalFormatSymbols dfs = new DecimalFormatSymbols();     
    31.   
  
  
  31.         DecimalFormat volumeFormat = new DecimalFormat("###,###,###,###",dfs);     
    32.   
  
  
  32.         DecimalFormat priceFormat = new DecimalFormat("###.00",dfs);     
    33.   
  
  
  33.         System.out.println("Big Buyer reports... ");     
    34.   
  
  
  34.         System.out.println("\tThe lastest stock quote for " + symbol + " is:");     
    35.   
  
  
  35.         System.out.println("\t$" + priceFormat.format(close) + " per share (close).");     
    36.   
  
  
  36.         System.out.println("\t$" + priceFormat.format(high) + " per share (high).");     
    37.   
  
  
  37.         System.out.println("\t$" + priceFormat.format(low) + " per share (low).");     
    38.   
  
  
  38.         System.out.println("\t" + volumeFormat.format(volume) + " shares traded.");     
    39.   
  
  
  39.         System.out.println();     
    40.   
  
  
  40.         }     
    41.   
  
  
  41.     }    
    42.

TradingFool.java:

Java代码

 
 
 
    
  
  
  
  1. public class TradingFool implements Observer     
    2.   
  
  
  2.     {     
    3.   
  
  
  3.     private String symbol;     
    4.   
  
  
  4.     private float close;     
    5.   
  
  
  5.     
    6.   
  
  
  6.     public TradingFool(Observable observable)     
    7.   
  
  
  7.         {     
    8.   
  
  
  8.         observable.addObserver(this);//注册关系     
    9.   
  
  
  9.         }     
    10.   
  
  
  10.     
    11.   
  
  
  11.     public void update(Observable observable,Object args)     
    12.   
  
  
  12.         {     
    13.   
  
  
  13.         if(observable instanceof StockData)     
    14.   
  
  
  14.             {     
    15.   
  
  
  15.             StockData stockData = (StockData)observable;     
    16.   
  
  
  16.             this.symbol = stockData.getSymbol();     
    17.   
  
  
  17.             this.close = stockData.getClose();     
    18.   
  
  
  18.             display();     
    19.   
  
  
  19.             }     
    20.   
  
  
  20.         }     
    21.   
  
  
  21.     
    22.   
  
  
  22.     public void display()     
    23.   
  
  
  23.         {     
    24.   
  
  
  24.         DecimalFormatSymbols dfs = new DecimalFormatSymbols();     
    25.   
  
  
  25.         DecimalFormat priceFormat = new DecimalFormat("###.00",dfs);     
    26.   
  
  
  26.         System.out.println("Trading Fool says... ");     
    27.   
  
  
  27.         System.out.println("\t" + symbol + " is currently trading at $" + priceFormat.format(close) + " per share.");     
    28.   
  
  
  28.         System.out.println();     
    29.   
  
  
  29.         }     
    30.   
  
  
  30.     }    
    31.

StokeQuote.java

Java代码

 
 
 
    
  
  
  
  1. public class StockQuotes     
    2.   
  
  
  2.     {     
    3.   
  
  
  3.     public static void main(String[] args)     
    4.   
  
  
  4.         {     
    5.   
  
  
  5.         System.out.println();     
    6.   
  
  
  6.         System.out.println("-- Stock Quote Application --");     
    7.   
  
  
  7.         System.out.println();     
    8.   
  
  
  8.     
    9.   
  
  
  9.         StockData stockData = new StockData();     
    10.   
  
  
  10.     
    11.   
  
  
  11.         // register observers...     
    12.   
  
  
  12.         new TradingFool(stockData);     
    13.   
  
  
  13.         new BigBuyer(stockData);     
    14.   
  
  
  14.     
    15.   
  
  
  15.         // generate changes to stock data...     
    16.   
  
  
  16.         stockData.setStockData("JUPM",16.10f,16.15f,15.34f,(long)481172);     
    17.   
  
  
  17.         stockData.setStockData("SUNW",4.84f,4.90f,4.79f,(long)68870233);     
    18.   
  
  
  18.         stockData.setStockData("MSFT",23.17f,23.37f,23.05f,(long)75091400);     
    19.   
  
  
  19.         }     
    20.   
  
  
  20.     }   
    21.

在测试类中我们可以看到俩个Observer对象都注册了Observable对象,而当Observable对象发生改变时,这俩个Observable对象就会做相应的更新了, 运行结果如下:

Java代码

 
 
 
    
  
  
  
  1. Big Buyer reports...      
    2.   
  
  
  2.     The lastest stock quote for JUPM is:     
    3.   
  
  
  3.     $16.10 per share (close).     
    4.   
  
  
  4.     $16.15 per share (high).     
    5.   
  
  
  5.     $15.34 per share (low).     
    6.   
  
  
  6.     481,172 shares traded.     
    7.   
  
  
  7.     
    8.   
  
  
  8. Trading Fool says...      
    9.   
  
  
  9.     JUPM is currently trading at $16.10 per share.     
    10.   
  
  
  10.     
    11.   
  
  
  11. Big Buyer reports...      
    12.   
  
  
  12.     The lastest stock quote for SUNW is:     
    13.   
  
  
  13.     $4.84 per share (close).     
    14.   
  
  
  14.     $4.90 per share (high).     
    15.   
  
  
  15.     $4.79 per share (low).     
    16.   
  
  
  16.     68,870,233 shares traded.     
    17.   
  
  
  17.     
    18.   
  
  
  18. Trading Fool says...      
    19.   
  
  
  19.     SUNW is currently trading at $4.84 per share.     
    20.   
  
  
  20.     
    21.   
  
  
  21. Big Buyer reports...      
    22.   
  
  
  22.     The lastest stock quote for MSFT is:     
    23.   
  
  
  23.     $23.17 per share (close).     
    24.   
  
  
  24.     $23.37 per share (high).     
    25.   
  
  
  25.     $23.05 per share (low).     
    26.   
  
  
  26.     75,091,400 shares traded.     
    27.   
  
  
  27.     
    28.   
  
  
  28. Trading Fool says...      
    29.   
  
  
  29.     MSFT is currently trading at $23.17 per share.    
    30.

我们通过Observable源码可以看到,其实Observable对象不关心具体的Observer的实例类型. 只要是实现了Observer接口的Observer对象都可以得到通知,这就为我们如果想要对模型进行扩展提供了方便,使Observable对象和Observer对象实现了松耦合. 如果我们需要添加一个新的Observer对象时,我们只要注册一下,当Observable对象发生变化时就可以得到通知,而不要做其他任何改变,非常方便.

网页标题：Java中观察者模式的使用
网页URL：http://www.shufengxianlan.com/qtweb/news16/134816.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

虚拟主机知识

行业网站建设

微信小程序　　 　成都ssl证书认证　　 　德阳电信服务器托管　　 　注册域名　　 　成发金汇　　 　成都包装盒设计　　 　重庆电信五里店机房　　 　重庆服务器托管　　 　温江做网站　　 　宇仓仓储　　 　广汉长尔科技　　 　公路打桩机　　 　尊格展览　　 　成都商城开发　　 　梓潼网站制作公司　　 　买友情链接　　 　高端定制网站建设　　 　成都移动服务器托管　　 　证企宝企业　　 　成都多线服务器托管