设计模式-观察者模式

第一种方式：拉

1. package

com.work.pattern.observer;

/**

*@authorwangmingjie

*@date2008-6-29下午07:21:38

*/

importjava.util.Observable;

importjava.util.Observer;

publicclassEvenObserverimplementsObserver{

publicvoidupdate(Observableo,Objectarg){

if(oinstanceofNumsObservable)

if(((NumsObservable)o).getData()%2==0){

NumsObservablemyObserable=(NumsObservable)o;

System.out.println("EvenObserver:Datahaschangedto"

+myObserable.getData());

}

}

}

1. packagecom.work.pattern.observer;
3. importjava.util.Observable;
5. /**
6. *@authorwangmingjie
7. *@date2008-6-29下午07:19:30
8. */
9. publicclassNumsObservableextendsObservable{
10. publicfinalstaticIntegerODD=1;
11. publicfinalstaticIntegerEVEN=2;
12. privateintdata=0;
14. publicintgetData(){
15. returndata;
16. }
18. publicvoidsetData(inti){
19. data=i;
20. Integerflag=EVEN;
21. if((data&0x0001)==1)
22. flag=ODD;
23. setChanged();
24. notifyObservers();//拉
25. }
26. //setChange()方法用来设置一个内部标志位注明数据发生了变化；notifyObservers()方法会去调用观察者对象列表中所有的Observer的update()方法，通知它们数据发生了变化。
27. //只有在setChange()被调用后，notifyObservers()才会去调用update()。
29. }

测试代码如下：

public class ObserverTest {
public static void main(String[] args) {
NumsObservable number = new NumsObservable();
number.addObserver(new EvenObserver());
number.setData(1);
number.setData(2);
number.setData(3);
}

}

第二中方式是推：

1. publicclassNumsObservableextendsObservable{
2. publicfinalstaticIntegerODD=1;
3. publicfinalstaticIntegerEVEN=2;
4. privateintdata=0;
6. publicintgetData(){
7. returndata;
8. }
10. publicvoidsetData(inti){
11. data=i;
12. Integerflag=EVEN;
13. if((data&0x0001)==1)
14. flag=ODD;
15. setChanged();
16. notifyObservers(flag);//推送方式
17. }
18. //setChange()方法用来设置一个内部标志位注明数据发生了变化；notifyObservers()方法会去调用观察者对象列表中所有的Observer的update()方法，通知它们数据发生了变化。
19. //只有在setChange()被调用后，notifyObservers()才会去调用update()。
20. }

1. publicclassEvenObserverimplementsObserver{
2. publicvoidupdate(Observableo,Objectarg){
3. if(arg==NumsObservable.EVEN){
4. NumsObservablemyObserable=(NumsObservable)o;
5. System.out.println("EvenObserver:Datahaschangedto"
6. +myObserable.getData());
7. }
8. }
9. }