快捷導(dǎo)航

全面解析Java觀察者模式

更新時(shí)間：2016年09月08日 11:54:00 作者：生命壹號(hào)

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

【正文】

一、觀察者模式的定義：

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

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

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

圖表描述如下：

注：在被觀察者類中需要有一個(gè)集合維護(hù)所有觀察者。

三、舉例說(shuō)明：

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

步驟如下：

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

package com.vince.observer;
public interface Observable {
 //注冊(cè)為一個(gè)觀察者 
 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{
 //被觀察者維護(hù)的一個(gè)觀察者對(duì)象列表
 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) {
  //修改價(jià)格時(shí)，通知所有觀察者
  this.price = price;
  notifyObservers();
 }
 @Override
 public void registerObserver(Observer observer) {
  //注冊(cè)觀察者
  vector.add(observer);
 }
 @Override
 public void removeObserver(Observer observer) {
  //取消觀察者
  vector.remove(observer);
 }
 @Override
 public void notifyObservers() {
  //實(shí)現(xiàn)通知所有的觀察者對(duì)象
  for (Observer observer:vector) {
   observer.update(price);
  }
 }
}

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

package com.vince.observer;

public interface Observer {

  public void update(float price);5 

}

（4）定義具體的觀察者對(duì)象：

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)注的杯子的價(jià)格已更新為："+price);
 }
}

（5）測(cè)試：

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

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

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

步驟如下：

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

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）通過(guò)實(shí)現(xiàn)java.util.Observer接口實(shí)現(xiàn)具體的觀察者對(duì)象：

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)注的杯子價(jià)格已更新為："+cup.getPrice());
  }
 }
}

（3）測(cè)試：

package com.vince.observer2;
public class Test {
 public static void main(String[] args) {
  Cup cup = new Cup(3000);
  Person p1 = new Person("生命壹號(hào)");
  Person p2 = new Person("生命貳號(hào)");
  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);
 }
}

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