/**
 * 抽象主題，被觀察者
 *
 */
public interface Subject {
 /**
  * 添加觀察者
  * 
  * @param observer
  */
 void addObserver(Observer observer);
 
 /**
  * 移除指定的觀察者
  * 
  * @param observer
  */
 void removeObserver(Observer observer);
 
 /**
  * 移除所有的觀察者
  */
 void removeAll();
 
 /**
  * data 是要通知給觀察者的數(shù)據(jù) 因?yàn)镺bject是所有類的父類，可以使用多態(tài)，當(dāng)然 你也可以使用 泛型
  * 
  * @param data
  */
 void notifyAllObserver(Object data);
 
 /**
  * 單獨(dú) 通知某一個(gè)觀察者
  * 
  * @param observer
  * @param data
  *   data 是要通知給觀察者的數(shù)據(jù) 因?yàn)镺bject是所有類的父類，可以使用多態(tài)，當(dāng)然 你也可以使用 泛型
  */
 void notify(Observer observer, Object data);
 
}

/**
 * 抽象觀察者接口
 */
public interface Observer {
 /**
  * 
  * @param subject 被觀察者
  * @param data 被觀察者傳遞給觀察者的 數(shù)據(jù)
  */
 void update(Subject subject,Object data);
}

public class ConcreteSubject implements Subject {
 
 //觀察者集合，用于管理所有的觀察者
 List<Observer> mList = new ArrayList<>();
 
 @Override
 public void addObserver(Observer observer) {
  // TODO Auto-generated method stub
  // 確保相同的觀察者只含有一個(gè)
  if (observer == null) {
   throw new NullPointerException("observer == null");
  }
 
  if (!mList.contains(observer)) {
   mList.add(observer);
  }
 }
 
 @Override
 public void removeObserver(Observer observer) {
  // TODO Auto-generated method stub
  mList.remove(observer);
 }
 
 @Override
 public void removeAll() {
  // TODO Auto-generated method stub
  mList.clear();
 }
 
 @Override
 public void notifyAllObserver(Object data) {
  // TODO Auto-generated method stub
  for (Observer observer : mList) {
   observer.update(this, data);
  }
 }
 
 @Override
 public void notify(Observer observer, Object data) {
  // TODO Auto-generated method stub
  if (observer != null) {
   observer.update(this, data);
  }
 }
 
}

public class ObserverOne implements Observer {
 
 @Override
 public void update(Subject subject, Object data) {
  // TODO Auto-generated method stub
  System.err
    .println("the messge from subject to-->" + this.getClass().getName() + "<---is " + data.toString());
 }
 
}

public class ObserverTwo implements Observer {
 
 @Override
 public void update(Subject subject, Object data) {
  // TODO Auto-generated method stub
  System.err
  .println("the messge from subject to-->" + this.getClass().getName() + "<---is " + data.toString());
 }
 
}

public class ObserverThree implements Observer {
 
 @Override
 public void update(Subject subject, Object data) {
  // TODO Auto-generated method stub
  System.err
  .println("the messge from subject to-->" + this.getClass().getName() + "<---is " + data.toString());
 }
 
}

public class TestObservePattern {
 
 public static void main(String[] args) {
  // TODO Auto-generated method stub
  ConcreteSubject concreteSubject = new ConcreteSubject();
  ObserverOne observerOne=new ObserverOne();
  ObserverTwo observerTwo=new ObserverTwo();
  ObserverThree observerThree=new ObserverThree();
  
  concreteSubject.addObserver(observerOne);
  concreteSubject.addObserver(observerTwo);
  concreteSubject.addObserver(observerThree);
  
  
  //通知所有的觀察者
  concreteSubject.notifyAllObserver("wake up,wake up");
  //通知某個(gè)特定的觀察者OberverTwo
  concreteSubject.notify(observerTwo, "Specila msg for you");
  //觀察者ObserveThree 決定不再訂閱主題
  concreteSubject.removeObserver(observerThree);
  //通知所有的觀察者
  concreteSubject.notifyAllObserver("new Message come ");
 }
 
}