java設計模式--事件監聽器模式和觀察者模式

監聽器模式：事件源經過事件的封裝傳給監聽器，當事件源觸發事件后，監聽器接收到事件對象可以回調事件的方法

觀察者模式：觀察者(Observer)相當於事件監聽者，被觀察者(Observable)相當於事件源和事件，執行邏輯時通知observer即可觸發oberver的update,同時可傳被觀察者和參數

 

監聽器模式demo

1、首要定義事件源對象（事件源相當於單擊按鈕事件當中的按鈕對象、屬於被監聽者）：

 

public class DemoSource {
    private Vector repository = new Vector();//監聽自己的監聽器隊列
    public DemoSource(){}
    public void addDemoListener(DemoListener dl) {
           repository.addElement(dl);
    }
    public void notifyDemoEvent() {//通知所有的監聽器
           Enumeration enum = repository.elements();
           while(enum.hasMoreElements()) {
                   DemoListener dl = (DemoListener)enum.nextElement();
                 dl.handleEvent(new DemoEvent(this));
           }
    }
}

2、其次定義事件（狀態）對象（該事件對象包裝了事件源對象、作為參數傳遞給監聽器、很薄的一層包裝類）：

 

 

public class DemoEvent extends java.util.EventObject {
    public DemoEvent(Object source) {
      super(source);//source—事件源對象—如在界面上發生的點擊按鈕事件中的按鈕
       //所有 Event 在構造時都引用了對象 "source"，在邏輯上認為該對象是最初發生有關 Event 的對象
    }
    public void say() {
           System.out.println("This is say method...");
    }
}

3、最后定義我們的事件偵聽器接口如下

 

 

public interface DemoListener extends java.util.EventListener {
    //EventListener是所有事件偵聽器接口必須擴展的標記接口、因為它是無內容的標記接口、
    //所以事件處理方法由我們自己聲明如下：
    public void handleEvent(DemoEvent dm);
}

監聽器實現類

 

 

public class DemoListener1 implements DemoListener {
       public void handleEvent(DemoEvent de) {
              System.out.println("Inside listener1...");
              de.say();//回調
       }
}

4、測試代碼

 

 

public class TestDemo {
   DemoSource ds;
   public TestDemo(){
      try{
         ds = new DemoSource();
         //將監聽器在事件源對象中登記：
         DemoListener1 listener1 = new DemoListener1();
         ds.addDemoListener(listener1);
         ds.addDemoListener(new DemoListener() {
            public void handleEvent(DemoEvent event) {
            System.out.println("Method come from 匿名類...");
          }
        });
       ds.notifyDemoEvent();//觸發事件、通知監聽器
     }catch(Exception ex){
       ex.printStackTrace();
       }
    }

    public static void main(String args[]) {
           new TestDemo();
    }
}

觀察者模式demo

觀察者

 

class Watcher implements java.util.Observer {
  public void update(java.util.Observable obj, Object arg) {
    System.out.println("Update() called, count is "
                                + ((Integer) arg).intValue());
}
}

被觀察者

 

 

class BeingWatched extends java.util.Observable {
    void counter(int period) {
        for(; period>=0; period-- ) {
                setChanged();
                notifyObservers(new Integer(period));
                try {
                        Thread.sleep(100);
                } catch( InterruptedException e) {
                  System.out.println("Sleep interrupeted" );
                }
        }
}
};

測試

 

 

public class ObserverDemo {
    public static void main(String[] args) {
        BeingWatched beingWatched = new BeingWatched();//受查者
        Watcher watcher = new Watcher();//觀察者
        beingWatched.addObserver(watcher);
        beingWatched.counter(10);
    }
}

查閱了一些相關的東東 
原來這兩種api可以說都是基於：訂閱-發布模式的事件/消息通知模式，二者應該都算是“推”方式吧，就是被監控者將消息通知給所有監控者。 
1、訂閱：Observable.addObserver； 
事件源.addDemoListener（這個方法是自己定義的）。 

2、發布：Observable需要兩步：setChanged()、notifyObservers(newValue); 
事件源.notifyDemoEvent()（這個方法也是自己定義的）。