java 觀察者模式

定義了對象之間的一對多的依賴,這樣一來,當一個對象改變時,它的全部的依賴者都會收到通知並自動更新。java

被觀察者要繼承: Observable類  實現消息推送  、setChanged  notifyObservers();ide

觀察者要繼承: Observer類  實現updata(); 註冊 this

 

package 觀察者模式;

import java.util.Observable;
import java.util.Observer;

/**
 * 
 * @author 紅塵Dream
 * 觀察者模式: 一對多的模式 
 * 當被觀察者發生變化時, 觀察者會受到通知自動更新
 * 服務被觀察者 : 推送消息 通知觀察者
 * 觀察者: 訂閱主題    自動更新消息
 */
public class Test
{
    public static void main(String[] args)
    {
        Service s = new Service(); //建立被觀察者 服務者
        Observerl o = new Observerl(); //建立觀察者
        Observerl o1 = new Observerl(); //建立觀察者
        Observerl o2 = new Observerl(); //建立觀察者
        Observerl o3 = new Observerl(); //建立觀察者
        Observerl o4 = new Observerl(); //建立觀察者
        
        o.registerService(s);//訂閱服務
        o1.registerService(s);
        o2.registerService(s);
        o3.registerService(s);
        o4.registerService(s);
        //取消訂閱
        o1.unRegisterService(s);
        s.setMsg("今天新聞熱點");
        
        
        
    }
}

/**
 * 服務類  被觀察者  用於推送消息
 */

class Service extends Observable
{
    private String msg;
    
    public String getMsg()
    {
        return msg+"(來自服務者(被觀察者))";
    }
    
    /**
     * 
     * 推送消息
     */
    public void setMsg(String msg)
    {
        this.msg = msg;
        setChanged();//設置改變
        notifyObservers();// 通知觀察者
    }
    
    
}

/**
* 被觀察者 類
*/
class Observerl implements Observer { /** * 訂閱 服務 * */ public void registerService(Observable observable) { observable.addObserver(this); } /** * 取消訂閱 */ public void unRegisterService(Observable observable) { observable.deleteObserver(this); } /** * 實現觀察者的更新方法 */ @Override public void update(Observable arg0, Object arg1) { if(arg0 instanceof Service) { Service s = (Service) arg0; System.out.println("觀察者更新:"+s.getMsg()); } } }

執行結果:spa

觀察者更新:今天新聞熱點(來自服務者(被觀察者))
觀察者更新:今天新聞熱點(來自服務者(被觀察者))
觀察者更新:今天新聞熱點(來自服務者(被觀察者))
觀察者更新:今天新聞熱點(來自服務者(被觀察者))
相關文章
相關標籤/搜索