观察者设计模式

观察者设计模式——我的理解

我们可以拿微信公众号来举例，假设微信用户就是观察者，微信公众号是被观察者，有多个的微信用户关注了“外酥里嫩唐僧肉”这个公众号，当这个公众号更新（不定时发布一些消息）时就会通知这些订阅的微信用户，关注公众号的微信用户就可以收到推送消息，取消关注就收不到推送消息。

*~~大白话：就是发布订阅模式，发布者发布信息，订阅者获取信息，订阅了就能收到信息，没订阅就收不到信息。~~ *

结构和图解

图解

结构

在观察者中有如下角色：

subject：抽象主题（抽象被观察者）。抽象主题角色把所有观察者对象保存在一个集合里，每个主题都有可以任意数量的观察者，抽象主题提供一个接口，可以增加、删除观察者对象。
ConcreteSubject：具体主题（具体被观察者）。该角色将有关状态存入具体观察者对象，在具体主题的内部状态发生改变时，给所有注册过的观察者发送通知。
Observer：抽象观察者，是具体观察者的抽象类。它定义了一个更新接口，使得在得到主题更改通知时更新自己。
ConcrereObserver：具体观察者。实现抽象观察者定义的更新接口，以便在得到主题更改通知时更新自身的状态。

代码实现

抽象观察者（Observer）

里面定义了一个更新(更新发布的消息)的方法

public interface Observer {
    public void update(String message);
}

具体观察者（ConcrereObserver）######

微信用户是具体观察者，里面实现了更新消息的方法

public class WeChatUser implements Observer {
    // 微信用户名
    private String name;
    // 
    public WeChatUser(String name) {
        this.name = name;
    }
    // 更新消息的方法
    @Override
    public void update(String message) {
        System.out.println(name + "-" + message);
    }
}

抽象被观察者（Subject）

抽象主题，提供了attach(增加)、detach(删除)、notify(通知)三个方法

public interface Subject {
    /**
     * 增加订阅者
     * @param observer 微信用户
     */
    public void attach(Observer observer);
    /**
     * 删除订阅者
     * @param observer 微信用户
     */
    public void detach(Observer observer);
    /**
     * 通知订阅者更新消息
     */
    public void notify(String message);
}

具体被观察者（ConcreteSubject）######

微信公众号是具体主题（具体被观察者），里面存储了订阅该公众号的微信用户，并实现了抽象主题中的方法

public class SubscriptionSubject implements Subject {
    // 储存订阅公众号的微信用户
    private List<Observer> weChatUserList = new ArrayList<Observer>();
    // 公众号发布的消息
	private String message;

    // 增加订阅者
    @Override
    public void attach(Observer observer) {
        weChatUserList.add(observer);
    }

    // 删除订阅者
    @Override
    public void detach(Observer observer) {
        weChatUserList.remove(observer);
    }

    // 通知所有订阅者公众号更新了消息
    @Override
    public void notify() {
    	// 循环遍历每个订阅者，通知订阅者更新消息
        for (Observer observer : weChatUserList) {
        	// 订阅者更新公众号发布的消息
            observer.update(message);
        }
    }

    // 设置发布的信息，同时通知订阅者
    public void setInfomation(String s) {
        this.message = s;
        System.out.println("微信服务更新消息： " + s);
        // 消息更新，通知所有观察者
        notify();
    }
}

微信客户端

注册成为微信用户

微信用户订阅“外酥里嫩唐僧肉”公众号，公众号储存该微信用户

公众号更新信息，同时，公众号通知订阅的微信用户公众号更新了信息

取消订阅的微信用户无法接收到公众号更新信息的通知

public class Client {
    public static void main(String[] args) {
        SubscriptionSubject mSubscriptionSubject=new SubscriptionSubject();
        // 创建微信用户
        weChatUser user1=new weChatUser("杨影枫");
        weChatUser user2=new weChatUser("月眉儿");
        weChatUser user3=new weChatUser("紫轩");
        // 订阅公众号
        mSubscriptionSubject.attach(user1);
        mSubscriptionSubject.attach(user2);
        mSubscriptionSubject.attach(user3);
        // 公众号更新发出消息给订阅的微信用户
        mSubscriptionSubject.notify("刘望舒的专栏更新了");
    }
}