快捷導(dǎo)航

全面解析Java觀察者模式

更新時間：2016年09月08日 11:54:00 作者：生命壹號

這篇文章主要幫助大家全面解析Java觀察者模式，了解java設(shè)計模式中的觀察者模式，感興趣的小伙伴們可以參考一下

【正文】

一、觀察者模式的定義：

簡單地說，觀察者模式定義了一個一對多的依賴關(guān)系，讓一個或多個觀察者對象監(jiān)聽一個主題對象。這樣一來，當被觀察者狀態(tài)發(fā)生改變時，需要通知相應(yīng)的觀察者，使這些觀察者對象能夠自動更新。例如：GUI中的事件處理機制采用的就是觀察者模式。

二、觀察者模式的實現(xiàn)：

Subject（被觀察的對象接口）:規(guī)定ConcreteSubject的統(tǒng)一接口 ; 每個Subject可以有多個Observer；ConcreteSubject（具體被觀察對象）:維護對所有具體觀察者的引用的列表；–狀態(tài)發(fā)生變化時會發(fā)送通知給所有注冊的觀察者。Observer（觀察者接口）:規(guī)定ConcreteObserver的統(tǒng)一接口；定義了一個update()方法，在被觀察對象狀態(tài)改變時會被調(diào)用。ConcreteObserver（具體觀察者）:維護一個對ConcreteSubject的引用；特定狀態(tài)與ConcreteSubject同步；實現(xiàn)Observer接口，update()方法的作用：一旦檢測到Subject有變動，就更新信息。

圖表描述如下：

注：在被觀察者類中需要有一個集合維護所有觀察者。

三、舉例說明：

【方案一】：自己定義接口或者類來實現(xiàn)觀察者模式。

步驟如下：

（1）定義被觀察者所具有的接口：

package com.vince.observer;
public interface Observable {
 //注冊為一個觀察者 
 public void registerObserver(Observer observer);
 
 //取消觀察者 
 public void removeObserver(Observer observer);
 
 //通知所有觀察者更新信息 
 public void notifyObservers();
}

（2）定義具體的被觀察者：杯子

package com.vince.observer;
import java.util.Vector;

public class Cup implements Observable{
 //被觀察者維護的一個觀察者對象列表
 private Vector<Observer> vector = new Vector<Observer>();
 private float price;
 
 public Cup(float price){
  this.price = price;
 }
 
 public float getPrice() {
  return price;
 }
 public void setPrice(float price) {
  //修改價格時，通知所有觀察者
  this.price = price;
  notifyObservers();
 }
 @Override
 public void registerObserver(Observer observer) {
  //注冊觀察者
  vector.add(observer);
 }
 @Override
 public void removeObserver(Observer observer) {
  //取消觀察者
  vector.remove(observer);
 }
 @Override
 public void notifyObservers() {
  //實現(xiàn)通知所有的觀察者對象
  for (Observer observer:vector) {
   observer.update(price);
  }
 }
}

（3）定義觀察者所具有的共同的接口：（更新數(shù)據(jù)最終當然是在觀察者那里進行啦）

package com.vince.observer;

public interface Observer {

  public void update(float price);5 

}

（4）定義具體的觀察者對象：

package com.vince.observer;
public class Person implements Observer{
 private String name;
 public Person(String name){
  this.name = name;
 }
 @Override
 public void update(float price) {
  System.out.println(name+"關(guān)注的杯子的價格已更新為："+price);
 }
}

（5）測試：

package com.vince.observer;
public class Test {
 public static void main(String[] args) {
  //創(chuàng)建一個被觀察者對象
  Cup doll = new Cup(3000);
  //創(chuàng)建兩個觀察者對象
  Person p1 = new Person("生命壹號");
  Person p2 = new Person("生命貳號");
  //注冊成為一個觀察者
  doll.registerObserver(p1);
  doll.registerObserver(p2);
  
  System.out.println("第一輪促銷：");
  doll.setPrice(2698);// 價格變動
  System.out.println("第二輪促銷：");
  doll.setPrice(2299);//
  System.out.println("第三輪促銷：");
  doll.setPrice(1998);
  
  doll.removeObserver(p2); //將生命二號移除
  System.out.println("第四輪促銷：");
  doll.setPrice(1098);  
  
 }
}

運行后，顯示結(jié)果如下：

【方案二】：直接調(diào)用JDK的API去實現(xiàn)。

步驟如下：

（1）通過繼承Observable類實現(xiàn)具體的被觀察者對象：

package com.vince.observer2;
import java.util.Observable;

public class Cup extends Observable{
 private float price;
 
 public Cup(float price){
  this.price = price;
 }
 public float getPrice() {
  return price;
 }
 public void setPrice(float price) {
  this.price = price;
  this.setChanged();//通知，數(shù)據(jù)已改變
  this.notifyObservers();
 }
 
 
}

（2）通過實現(xiàn)java.util.Observer接口實現(xiàn)具體的觀察者對象：

package com.vince.observer2;
import java.util.Observable;
import java.util.Observer;

public class Person implements Observer{
 private String name;
 public Person(String name){
  this.name = name;
 }
 @Override
 public void update(Observable o, Object arg) {
  if(o instanceof Cup){
   Cup cup = (Cup)o;
   System.out.println(name+"關(guān)注的杯子價格已更新為："+cup.getPrice());
  }
 }
}

（3）測試：

package com.vince.observer2;
public class Test {
 public static void main(String[] args) {
  Cup cup = new Cup(3000);
  Person p1 = new Person("生命壹號");
  Person p2 = new Person("生命貳號");
  cup.addObserver(p1);
  cup.addObserver(p2);
  System.out.println("第一輪促銷");
  cup.setPrice(2988);
  System.out.println("第二輪促銷");
  cup.setPrice(2698);
  
  cup.deleteObserver(p2);
  System.out.println("第三輪促銷");
  cup.setPrice(1998);
 }
}

運行后，結(jié)果如下：