• 微信公众号:美女很有趣。 工作之余,放松一下,关注即送10G+美女照片!

观察者模式

开发技术 开发技术 5天前 6次浏览

观察者模式,有时又被称为模型-视图(View)模式,有的叫发布-订阅模式,监听模式或从属者模式,是软件设计模式的一种。

观察者: 观察目标对象的状态、行为等的的主体。观察将自己存放到被观察对象中,被观察对象将观察者存放
在一个容器(Vector)里。
被观察的对象:被观察者所研究或关注的对象。当被观察的对象发生了某种变化时,将循环遍历容器中的所
有观察者,并将发生的变化通知予观察者。

 

场景:用户张三、李四、王五(观察者)都关注了微信公众号(被观察者),当微信公众号发布消息后会给观察者推送消息。

利用观察者模式:微信公众号发布消息,调用原来的实现的观察者接口。

以下代码实现为,用户(观察者)关注微信公众号(被观察者)后,微信公众号会保存一个用户的集合在类中。然后微信公众号发布消息,就会触发遍历集合中的所有用户,调用每个用户的方法,推送消息。

 

//main方法
public class DemoMain {
    public static void main(String[] args) {
        WeChatOfficialAccount wechat = new WeChatOfficialAccount("微信公众号");
        WeChatUser wechatUser = new WeChatUser("张三");
        wechat.addObserver(wechatUser);
        wechatUser = new WeChatUser("李四");
        wechat.addObserver(wechatUser);
        wechatUser = new WeChatUser("王五");
        wechat.addObserver(wechatUser);
        wechat.postMessage("改变中国IT教育,我们正在行动...");
    }
}


/**
* 观察者接口
*/
public interface Observer {

    /**
          * 被观察体发生变化时调用的方法,用来通知观察者
          * @param args
          */
    void update(Object args);

    /**
      * 获取观察者名称
      * @return
      */
    String getName();


}


/**
 *  * 被观察者接口
 * 
 */
public interface Observable {
    /**
     *      * 添加观察者
     *      * @param observer
     *      
     */
    void addObserver(Observer observer);

    /**
     *      * 解除观察者
     *      * @param observer
     *      
     */
    void delObserver(Observer observer);

    /**
     *      * 通知所有的观察者
     *      
     */
    void notifiyObservers(Object args);
}




/**
 * 微信用户
 */
public class WeChatUser implements Observer {
    private String username;

    public WeChatUser(String username) {
        this.username = username;
    }

    @Override
    public void update(Object args) {
        readMessage((String) args);
    }

    public void readMessage(String message) {
        System.out.println(String.format("%s  读取了信息‐>  %s", this.username, message));
    }

    @Override
    public String getName() {
        return this.username;
    }
}



/**
 * 被观察者,微信公众号
 */
public class WeChatOfficialAccount implements Observable {
    private String name;
    /**
     * 保存所有的观察者
     */
    private Vector<Observer> observers;

    public WeChatOfficialAccount(String name) {
        this.name = name;
        this.observers = new Vector<Observer>();
    }

    @Override
    public synchronized void addObserver(Observer observer) {
        System.out.println(observer.getName() + " 关注了公众号 " + this.name);
        this.observers.add(observer);
    }

    @Override
    public synchronized void delObserver(Observer observer) {
        observers.remove(observer);
    }

    @Override
    public void notifiyObservers(Object args) {
        Observer[] arr = observers.toArray(new Observer[]{});
        for (int i = arr.length - 1; i >= 0; i--) {
            // 通知每个观察者
            arr[i].update(args);
        }
    }

    /**
     * 发布新的消息
     *
     * @param message
     */
    public void postMessage(String message) {
        System.out.println(name + "微信公众号发布新的消息: " + message);
        notifiyObservers(message);
    }
}

输出结果:

张三 关注了公众号 微信公众号
李四 关注了公众号 微信公众号
王五 关注了公众号 微信公众号
微信公众号微信公众号发布新的消息: 改变中国IT教育,我们正在行动…
王五 读取了信息‐> 改变中国IT教育,我们正在行动…
李四 读取了信息‐> 改变中国IT教育,我们正在行动…
张三 读取了信息‐> 改变中国IT教育,我们正在行动…


程序员灯塔
转载请注明原文链接:观察者模式
喜欢 (0)