/** 
 * 觀察目標(biāo) 繼承自 java.util.Observable 
 * @author stone 
 * 
 */ 
public class UpdateObservable extends Observable { 
   
  private int data; 
   
  public UpdateObservable(Observer observer) { 
    addObserver(observer); 
    /* 
     * add other observer 
     */ 
  } 
   
  public int getData() { 
    return data; 
  } 
   
  public void setData(int data) { 
    if (data != this.data) { 
      this.data = data; 
      setChanged(); //標(biāo)記 改變, 只有標(biāo)記后才能通知到 
      notifyObservers(); //通知 
    } 
     
  } 
 
  @Override 
  public synchronized void addObserver(Observer o) { 
    super.addObserver(o); 
  } 
 
  @Override 
  public synchronized void deleteObserver(Observer o) { 
    super.deleteObserver(o); 
  } 
 
  @Override 
  public void notifyObservers() { 
    super.notifyObservers(); 
  } 
 
  @Override 
  public void notifyObservers(Object arg) { 
    super.notifyObservers(arg); 
  } 
 
  @Override 
  public synchronized void deleteObservers() { 
    super.deleteObservers(); 
  } 
 
  @Override 
  protected synchronized void setChanged() { 
    super.setChanged(); 
  } 
 
  @Override 
  protected synchronized void clearChanged() { 
    super.clearChanged(); 
  } 
 
  @Override 
  public synchronized boolean hasChanged() { 
    return super.hasChanged(); 
  } 
 
  @Override 
  public synchronized int countObservers() { 
    return super.countObservers(); 
  } 
   
} 

/** 
 * 觀察者 實現(xiàn) java.util.Observer接口 
 * @author stone 
 * 
 */ 
public class UpdateObserver implements Observer { 
 
  @Override 
  public void update(Observable o, Object arg) { 
    System.out.println("接收到數(shù)據(jù)變化的通知:"); 
    if (o instanceof UpdateObservable) { 
      UpdateObservable uo = (UpdateObservable) o; 
      System.out.print("數(shù)據(jù)變更為：" + uo.getData()); 
    } 
  } 
 
} 

/** 
 * 抽象觀察者  Observer 
 * 觀察 更新     
 * @author stone 
 * 
 */ 
public interface IWatcher { 
  /* 
   * 通知接口： 
   * 1. 簡單通知 
   * 2. 觀察者需要目標(biāo)的變化的數(shù)據(jù)，那么可以將目標(biāo)用作參數(shù), 見Java的Observer和Observable 
   */ 
// void update(IWatched watched); 
   
  void update(); 
   
} 

/** 
 * 抽象目標(biāo) Subject 
 * 提供注冊和刪除觀察者對象的接口, 及通知觀察者進(jìn)行觀察的接口 
 * 及目標(biāo) 自身被觀察的業(yè)務(wù)的接口 
 * @author stone 
 * 
 */ 
public interface IWatchedSubject { 
   
  public void add(IWatcher watch); 
 
  public void remove(IWatcher watch); 
   
  public void notifyWhatchers(); 
   
  public void update();//被觀察業(yè)務(wù)變化的接口 
} 

/** 
 * 具體觀察者    Concrete Observer 
 * 
 * @author stone 
 * 
 */ 
public class UpdateWatcher implements IWatcher { 
 
  @Override 
  public void update() { 
    System.out.println(this + "觀察到：目標(biāo)已經(jīng)更新了"); 
  } 
 
} 

/** 
 * 具體目標(biāo)角色  Concrete Subject 
 * @author stone 
 * 
 */ 
public class UpdateWatchedSubject implements IWatchedSubject { 
  private List<IWatcher> list; 
   
  public UpdateWatchedSubject() { 
    this.list = new ArrayList<IWatcher>(); 
  } 
   
  @Override 
  public void add(IWatcher watch) { 
    this.list.add(watch); 
  } 
 
  @Override 
  public void remove(IWatcher watch) { 
    this.list.remove(watch); 
  } 
 
  @Override 
  public void notifyWhatchers() { 
    for (IWatcher watcher : list) { 
      watcher.update(); 
    } 
  } 
   
  @Override 
  public void update() { 
    System.out.println("目標(biāo)更新中...."); 
    notifyWhatchers(); 
  } 
 
} 

/** 
 * 監(jiān)聽 用戶在注冊后 
 * @author stone 
 * 
 */ 
public interface IRegisterListener { 
  void onRegistered(); 
} 

/** 
 * 監(jiān)聽 當(dāng)用戶登錄后 
 * @author stone 
 * 
 */ 
public interface ILoginListener { 
  void onLogined(); 
} 

/* 
 * 監(jiān)聽器 是觀察者模式的一種實現(xiàn) 
 * 一些需要監(jiān)聽的業(yè)務(wù)接口上添加 監(jiān)聽器，調(diào)用監(jiān)聽器的相應(yīng)方法，實現(xiàn)監(jiān)聽 
 */ 
public class User { 
   
  public void register(IRegisterListener register) { 
    /* 
     * do ... register 
     */ 
    System.out.println("正在注冊中..."); 
    //注冊后 
    register.onRegistered(); 
  } 
 
  public void login(ILoginListener login) { 
    /* 
     * do ... login 
     */ 
    System.out.println("正在登錄中..."); 
    //登錄后 
    login.onLogined(); 
  } 
 
} 

/** 
 * 觀察者(Observer)模式 行為型模式 
 *  觀察者模式定義了一種一對多的依賴關(guān)系，讓多個觀察者對象同時觀察某一個目標(biāo)對象。 
 *  這個目標(biāo)對象在狀態(tài)上發(fā)生變化時，會通知所有觀察者對象，讓它們能夠自動更新自己 
 * 目標(biāo)對象中需要有添加、移除、通知 觀察者的接口 
 *  
 * @author stone 
 */ 
public class Test { 
   
  public static void main(String[] args) { 
    /* 
     * 使用Java自帶的Observer接口和Observable類 
     */ 
    UpdateObservable observable = new UpdateObservable(new UpdateObserver()); 
    observable.setData(99); 
    System.out.println(""); 
    System.out.println(""); 
    /* 
     * 自定義的觀察者模型 
     */ 
    IWatchedSubject watched = new UpdateWatchedSubject(); 
    watched.add(new UpdateWatcher()); 
    watched.add(new UpdateWatcher()); 
    watched.update(); 
    System.out.println(""); 
     
    /* 
     * 子模式-監(jiān)聽器 
     */ 
     
    User user = new User(); 
    user.register(new IRegisterListener() { 
       
      @Override 
      public void onRegistered() { 
        System.out.println("監(jiān)聽到注冊后。。。"); 
      } 
    }); 
    user.login(new ILoginListener() { 
       
      @Override 
      public void onLogined() { 
        System.out.println("監(jiān)聽到登錄后。。。"); 
      } 
    }); 
     
  } 
} 

接收到數(shù)據(jù)變化的通知: 
數(shù)據(jù)變更為：99 
 
目標(biāo)更新中.... 
observer.UpdateWatcher@457471e0觀察到：目標(biāo)已經(jīng)更新了 
observer.UpdateWatcher@5fe04cbf觀察到：目標(biāo)已經(jīng)更新了 
 
正在注冊中... 
監(jiān)聽到注冊后。。。 
正在登錄中... 
監(jiān)聽到登錄后。。。