设计模式 之 观察者模式

前言

• 定义：观察者设计模式定义了对象间的一种一对多的依赖关系，以便一个对象的状态发生变化时，所有依赖于它的对象都得到通知并自动刷新，此种模式通常被用来实现事件处理系统
• 别称：发布（Publish ）-订阅（Subscribe）模式
• 别称：模型（Modole）-视图（View）模式

UML类图

• 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）
public interface Subject {
/**
* 增加订阅者
/
public void attach(Observer observer);
/*
* 删除订阅者
/
public void detach(Observer observer);
/*
* 通知订阅者更新消息
*/
public void notify(String message);
}

具体被观察者（ConcreteSubject）
public class SubscriptionSubject implements Subject {
// 储存订阅公众号的微信用户
private List<Observer> wechatUserlist = new ArrayList<Observer>();

    @Override
    public void attach(Observer observer) {
        wechatUserlist.add(observer);
    }

    @Override
    public void detach(Observer observer) {
        wechatUserlist.remove(observer);
    }

    @Override
    public void notify(String message) {
        for (Observer observer : wechatUserlist) {
            observer.update(message);
        }
    }
}

客户端调用
public class Client {
public static void main(String[] args) {
SubscriptionSubject mSubject = new SubscriptionSubject();
// 创建微信用户
WechatUser user1 = new WechatUser("张三");
WechatUser user2 = new WechatUser("李四");
WechatUser user3 = new WechatUser("王五");
// 订阅公众号
mSubject.attach(user1);
mSubject.attach(user2);
mSubject.attach(user3);
// 公众号更新发出消息给订阅的微信用户
mSubject.notify("公众号更新消息");
}
}

输出结果
张三-公众号更新消息
李四-公众号更新消息
王五-公众号更新消息

使用场景及优缺点

• 使用场景
• 关联行为场景，需要注意的是，关联行为是可拆分的，而不是“组合”关系。
• 事件多级触发场景。
• 跨系统的消息交换场景，如消息队列、事件总线的处理机制。
• 优点
  解除耦合，让耦合的双方都依赖于抽象，从而使得各自的变换都不会影响另一边的变换。
• 缺点
  在应用观察者模式时需要考虑一下开发效率和运行效率的问题，程序中包括一个被观察者、多个观察者，开发、调试等内容会比较复杂，而且在Java中消息的通知一般是顺序执行，那么一个观察者卡顿，会影响整体的执行效率，在这种情况下，一般会采用异步实现

Android 当中的应用

• OnClickListener
• ContentObserver
• android.database.Observable
• 还有组件通讯库RxJava、RxAndroid
• EventBus
• 经典：Adapter 的 notifyDataSetChanged()