观察者模式

作者: gaaaaaaaaaao | 来源:发表于2016-10-28 19:57 被阅读0次

11.9设计模式-观察者模式-详解
RxJava基础—观察者模式
前端面试考点之手写系列
RxJava 原理篇
观察者模式
设计模式-观察者模式
观察者模式
iOS设计模式之观察者模式
观察者模式和发布订阅模式区别
RxJava(二)

观察者模式定义了对象之间的一对多依赖，这样一来，当一个对象改变状态时，它的所有依赖者都会受到通知并自动更新。
通俗的讲，观察者先告诉被观察者我需要观察的你的某些属性，当这些属性发生变化时就主动通知我。

栗子：不同的读者可以在书店进行订阅服务，当有新书到来时，就让书店主动通知这些订阅者。
在这个例子中，书店就属于被观察者（主题），读者就属于观察者，观察的内容为是否有新书到来。
要实现这样的一种机制，那么首先，读者需要在书店进行订阅，然后书店需要有一份订阅者的名单，然后在有新书到来时就通知读者。
我们需要在书店类中定义一个读者的集合，在读者订阅时添加，取消订阅时就移除，当有新书到来时就遍历集合通知读者。
由于读者有各种类型的人，因此就将这些读者的共同点抽象出来，他们都需要的是订阅服务并受到通知，那么我们就可以定义一个读者接口，其中定义的方法是接受书店传来的通知，不同的读者只需要实现这个接口，然后在受到书店的通知后自己再进行处理即可。
而书店方面，为了让各种类型的书店都能够有这样一种服务，我们就把书店的这种订阅服务也抽象出来定义成一个接口，其中定义方法是注册、取消注册、通知观察者。

代码：
首先是抽象出的书店的订阅服务接口

//主题接口，即书店提供的订阅服务
public interface Subject {
    //注册
    void register(Observer observer);
    //取消注册
    void unRegister(Observer observer);
    //通知
    void notifyObservers();
}

然后是书店的具体实现类，书店不需要管具体的读者是那种类型的，只需要知道，读者是需要订阅服务的，因此在注册时传入的是读者实现的订阅服务的接口

//书店类，实现了订阅服务具体的逻辑
public class BookStore implements Subject{
    private List<Observer> observerLsit = new ArrayList<>();
    @Override
    public void register(Observer observer) {
        if(!observerLsit.contains(observer)){
            observerLsit.add(observer);
        }
    }
    @Override
    public void unRegister(Observer observer) {
        if(observerLsit.contains(observer)){
            observerLsit.remove(observer);
        }
    }
    public void onNewBookArrived(){
        notifyObservers();
    }
    @Override
    public void notifyObservers() {
        for(Observer o : observerLsit){
            o.update();
        }
    }
}

然后是读者的接口：

public interface Observer {
    void update();
}

最后是两个读者实现类：

public class Boy implements Observer {
    private Subject subject;
    public Boy(Subject subject){
        this.subject = subject;
        subject.register(this);
    }
    @Override
    public void update() {
        System.out.println("boy----->receive newBookArrived!");
    }
}

public class Girl implements Observer {
    private Subject subject;
    public Girl(Subject subject){
        this.subject = subject;
        subject.register(this);
    }
    @Override
    public void update() {
        System.out.println("girl----->receive newBookArrived!");
    }
}

读者在实现类中，需要持有一个书店（被观察者）的接口对象，用来注册和取消注册，并分别具体实现了在收到新书之后的动作。
Test:

public static void main(String[] args) {
    BookStore bookStore = new BookStore();
    Boy boy = new Boy(bookStore);
    Girl girl = new Girl(bookStore);
    bookStore.onNewBookArrived();
}