易学设计方式11 观察者(Observer)
易学设计模式11 观察者(Observer)
Observer模式是行为模式之一,它的作用是当一个对象的状态发生变化时,能够自动通知其他关联对象,自动刷新对象状态。Observer模式提供给关联对象一种同步通信的手段,使某个对象与依赖它的其他对象之间保持状态同步
1) 抽象目标角色(Subject):目标角色知道它的观察者,可以有任意多个观察者观察同一个目标。并且提供注册和删除观察者对象的接口。目标角色往往由抽象类或者接口来实现。
2) 抽象观察者角色(Observer):为那些在目标发生改变时需要获得通知的对象定义一个更新接口。抽象观察者角色主要由抽象类或者接口来实现。
3)具体目标角色(Concrete Subject):将有关状态存入各个Concrete Observer对象。当它的状态发生改变时, 向它的各个观察者发出通知。
4) 具体观察者角色(Concrete Observer):存储有关状态,这些状态应与目标的状态保持一致。实现Observer的更新接口以使自身状态与目标的状态保持一致。在本角色内也可以维护一个指向Concrete Subject对象的引用。
Observer(Observer)
NumberGenerator--(Subject)
RandomNumberGenerator--(Concrete Subject)
NumberObserver(Concrete Observer)
SymbolObserver(Concrete Observer)
输出结果:
NumberObserver:8
SymbolObserver:*^_^* *^_^* *^_^* *^_^* *^_^* *^_^* *^_^* *^_^*
NumberObserver:4
SymbolObserver:*^_^* *^_^* *^_^* *^_^*
NumberObserver:8
SymbolObserver:*^_^* *^_^* *^_^* *^_^* *^_^* *^_^* *^_^* *^_^*
NumberObserver:7
SymbolObserver:*^_^* *^_^* *^_^* *^_^* *^_^* *^_^* *^_^*
NumberObserver:1
SymbolObserver:*^_^*
参考:http://blog.csdn.net/csh624366188/article/details/7477116
Observer模式是行为模式之一,它的作用是当一个对象的状态发生变化时,能够自动通知其他关联对象,自动刷新对象状态。Observer模式提供给关联对象一种同步通信的手段,使某个对象与依赖它的其他对象之间保持状态同步
1) 抽象目标角色(Subject):目标角色知道它的观察者,可以有任意多个观察者观察同一个目标。并且提供注册和删除观察者对象的接口。目标角色往往由抽象类或者接口来实现。
2) 抽象观察者角色(Observer):为那些在目标发生改变时需要获得通知的对象定义一个更新接口。抽象观察者角色主要由抽象类或者接口来实现。
3)具体目标角色(Concrete Subject):将有关状态存入各个Concrete Observer对象。当它的状态发生改变时, 向它的各个观察者发出通知。
4) 具体观察者角色(Concrete Observer):存储有关状态,这些状态应与目标的状态保持一致。实现Observer的更新接口以使自身状态与目标的状态保持一致。在本角色内也可以维护一个指向Concrete Subject对象的引用。
Observer(Observer)
NumberGenerator--(Subject)
RandomNumberGenerator--(Concrete Subject)
NumberObserver(Concrete Observer)
SymbolObserver(Concrete Observer)
public interface Observer { public void upadate(NumberGenerator generator); }
public abstract class NumberGenerator { private List<Observer> observers = new ArrayList<Observer>(); /** 添加观察者*/ public void addObserver(Observer observer) { observers.add(observer); } /** 删除观察者*/ public void removeObserver(Observer observer) { observers.remove(observer); } /** 通知所有观察者*/ public void notifyObservers() { for(Observer obs : observers) { obs.upadate(this); } } public abstract int getNumber(); public abstract void generate();//产生数字 }
public class RandomNumberGenerator extends NumberGenerator { private Random random = new Random(); private int number; public void generate() { for(int i = 0; i < 5; i++) { number = random.nextInt(10);//产生10以内的随机数 notifyObservers(); } } public int getNumber() { return number; } public void setNumber(int number) { this.number = number; } }
public class NumberObserver implements Observer { public void upadate(NumberGenerator generator) { System.out.println("NumberObserver:"+ generator.getNumber()); try { Thread.sleep(1000 * 3); } catch (InterruptedException e) { e.printStackTrace(); } } }
public class SymbolObserver implements Observer { public void upadate(NumberGenerator generator) { System.out.print("SymbolObserver:"); int count = generator.getNumber(); for(int i=0; i<count; i++) { System.out.print("*^_^* "); } System.out.println(""); try { Thread.sleep(1000*3); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } }
public class Client { public static void main(String[] args) { //实例化数字产生对象 NumberGenerator generator = new RandomNumberGenerator(); //实例化观察者 Observer observer1 = new NumberObserver(); Observer observer2 = new SymbolObserver(); //注册观察者 generator.addObserver(observer1); generator.addObserver(observer2); generator.generate(); //产生数字 } }
输出结果:
NumberObserver:8
SymbolObserver:*^_^* *^_^* *^_^* *^_^* *^_^* *^_^* *^_^* *^_^*
NumberObserver:4
SymbolObserver:*^_^* *^_^* *^_^* *^_^*
NumberObserver:8
SymbolObserver:*^_^* *^_^* *^_^* *^_^* *^_^* *^_^* *^_^* *^_^*
NumberObserver:7
SymbolObserver:*^_^* *^_^* *^_^* *^_^* *^_^* *^_^* *^_^*
NumberObserver:1
SymbolObserver:*^_^*
参考:http://blog.csdn.net/csh624366188/article/details/7477116