设计模式_观察者模式

public abstract class Subject {
//定义一个观察者数组
private Vector<Observer> obsVector = new Vector<Observer>();
//增加一个观察者
public void addObserver(Observer o){
this.obsVector.add(o);
}
//删除一个观察者
public void delObserver(Observer o){
this.obsVector.remove(o);
}
//通知所有观察者
public void notifyObservers(){
for(Observer o:this.obsVector){
o.update();
}
}
}

public interface Observer {
 public void update(String context);
}

/**
 * 这个接口的存在就是对观察者的统一管理
 * @author suibian
 *
 */
public interface ObserverManage {
 
 public void addObserver(Observer observer);
 public void deleteObserver(Observer observer);
 public void notifyObservers(String context);
}

/** 
 * 被观察者，该有的都有 
 * @author suibian 
 * 
 */ 
public interface IEmperorQin { 
 public void haveLove(); 
 public void haveUnited(); 
} 

public class EmperorQin implements ObserverManage,IEmperorQin{
 private ArrayList<Observer> observerList=new ArrayList<Observer>();
 
 /*private Vector<Observer> observerList=new ArrayList<Observer>(); 这样线程安全  */
 
 public void addObserver(Observer observer) {
  this.observerList.add(observer);
 }
 public void deleteObserver(Observer observer) {
  this.observerList.remove(observer);
 }
 public void notifyObservers(String context) {
  for(Observer ob:observerList){
   ob.update(context);
  }
 }
 public void haveLove() {
  System.out.println("秦始皇开始修阿房宫了");
  this.notifyObservers("秦始皇开始修阿房宫了");
 }
 public void haveUnited() {
  System.out.println("秦始皇已经统一天下了");
  this.notifyObservers("秦始皇已经统一天下了");
 }
}

public class RuJia implements Observer {
 public void update(String context) {
  System.out.println("儒家:看到李斯活动，准备配合");
  this.cry(context);
  System.out.println("儒家配合的好");
 }
 private void cry(String context) {
  System.out.println("儒家根据-》"+context+"制定了计划");
 }
}

public class MoJia implements Observer {
 public void update(String context) {
  System.out.println("墨家:观察到秦始皇活动，自己也开始行动了");
  this.cry(context);
  System.out.println("墨家修好了机关兽");
 }
 private void cry(String context) {
  System.out.println("墨家说，因为-》"+context+"所以我必须马上行动");
 }
}

public class FaJia implements Observer {
 public void update(String context) {
  System.out.println("法家:观察到秦始皇活动");
  this.reportToQinShiHuang(context);
  System.out.println("法家汇报完毕");
 }
 private void reportToQinShiHuang(String context) {
  System.out.println("法家:秦始皇有活动-》"+context);
 }
}

public class QinDynasty {
 
 public static void main(String[] args) {
  FaJia liSi=new FaJia();
  MoJia wanSi=new MoJia();
  RuJia rujia=new RuJia();
 
  EmperorQin qinshihuang=new EmperorQin();
 
  qinshihuang.addObserver(liSi);
  qinshihuang.addObserver(wanSi);
  qinshihuang.addObserver(rujia);
 
  qinshihuang.haveLove();
  qinshihuang.haveUnited();
 }
}
/*
如果这样设计，的确，订阅模式，但是前提是观察者需要被添加到被观察者的队列中
当被观察者行动时，循环队列，一个一个的调用队列中的提醒方法，也就是说，被观察者必须要知道观察者中的内部结构，
或者说他们俩个达成了某种协议
扩展性不好
代码结构清晰
*/

版权声明：本文为博主原创文章，未经博主允许不得转载。