思考一种场景

• 每当对象a产生变化之后，对象b，c，d希望能获知a是否产生变化了或者具体产生的变化内容。
• 例如：每当购物车里面的商品a数量变化之后，购物车的总金额都需要跟随商品a数量变化而变化。

如果b,c,d每次都去询问a是否发生变化，然后a来判断下状态是否变化，也能实现这个场景，但是

观察者模式（observable pattern）

• 概念的定义：
  观察者模式定义了对象之间的一对多依赖，这样一来，当一个对象状态发生变化，他所有的订阅者都能收到状态更新消息。
• 场景类比：
  报纸订阅者和报社之间的关系，订阅者只要向报社登记了订阅信息，就能一直收到报社发布的报纸。
  映射到观察者模式当中：其实报社就是主题发布者Subject,订阅者就是Observer
• 当对象a发生变化的时候，所有跟其建立观察关系的对象，都会收到其发生变化的通知。
• 这种模式中对象的关系是一对多关系，也就是说，被观察的对象只有一个，而观察它的对象可以有很多个。
• 可观察订阅对象（subject）：发布一些信息

Subject Interface应该有几个方法

• add：添加观察者
• remove：删除观察者
• notify：变化通知

观察者observer

• update：当收到notify方法通知后，所做的变化处理

发布者Subject 的实现

export interface Subject {
    add(obs: Observable);
    remove(obs: Observable);
    notify(data);
}
export class DataSubject implements Subject {
    private observers = [];
    add(obs: Observable) {
        this.observers.push(obs);
    }

    remove(obs: Observable) {
        const i = this.observers.indexOf(obs);
        if (i > -1) {
            this.observers.splice(i, 1);
        }
    }

    notify(data) {
        this.observers.forEach(cur => {
            cur.update(data);
        })
    }
}

观察者Observable的实现

export interface Observable {
    update(data);
}

export class ObservableEntity implements Observable {
    public data:any;
    private subject:DataSubject = new DataSubject();

    initSubject(s:DataSubject){
        this.subject = s;
        this.subject.add(this);
    }

    update(data:any){
        this.data = data;
    }
}

观察者模式的特点

观察者模式提供了发布者和订阅者之间的松耦合模式。
因为观察者不用关心每一个订阅者的具体实现的细节是什么，只要订阅者订阅了接口，就给它发送更新的消息。
也就是说:
观察者模式中，所有消息的变化都是由发布者主动去通知所有的订阅者。
订阅者对于发布者发布的变化以及变化的内容，只能被动的接收。
但是，可能订阅者并不希望每一次都接收到消息变化的订阅。
观察者会接收到发布者发布的所有数据，但是有的观察者可能只需要其中的一点数据而已。

可观察对象Observable

export class Observable{
    private observers = [];
    private changed:boolean = false;
    add(obs: Observable) {
        this.observers.push(obs);
    }

    remove(obs: Observable) {
        const i = this.observers.indexOf(obs);
        if (i > -1) {
            this.observers.splice(i, 1);
        }
    }

    notify(data) {
        if(this.changed){
            this.observers.forEach(cur => {
                cur.update(data);
            })
        }
        this.changed = false;

    }

    setChanged(){
        this.changed = true;
    }
}

setChanged的方法可以用来标识发布者的状态是否变化
如果状态变化了，再通知观察者。
设置setChanged方法的优点在于，可观察对象可以更加灵活的处理在什么时候去通知发布者。
比如：温度变化时候每时每刻都在变化，通过setChanged状态的标记，可观察对象可以灵活决定，比如每变化超过1度才去通知。

需墙-Observer Pattern – Design Patterns (ep 2)
《head first设计模式》

发布订阅模式（publisher-subscribe pattern）

在发布订阅模式当中，发布者并不会主动去通知订阅者，他们之间的信息交互是通过第三者消息队列（Broker）去交流。

发布订阅模式

通常有两种模式来进行消息过滤：topic-based & content-based.

In a topic-based system, messages are published to "topics" or named logical channels. Subscribers in a topic-based system will receive all messages published to the topics to which they subscribe. The publisher is responsible for defining the topics to which subscribers can subscribe.
In a content-based system, messages are only delivered to a subscriber if the attributes or content of those messages matches constraints defined by the subscriber. The subscriber is responsible for classifying the messages.
Publish–subscribe pattern
基于主题过滤：当订阅者订阅了某个主题，那么只要任何发布者发布了这个主题相关的消息，消息队列就会通知这个订阅者
基于内容过滤：只有当发布的消息的内容或者属性复合订阅者订阅的具体条件，那么消息队列才会把对应的消息分发给订阅者

优点

• 在发布订阅模式当中，发布者和订阅者是完全解耦的，而不是松耦合。也就是说，发布者和订阅者的具体实现并不会互相影响。
• 可扩展性强，因为发布者和订阅者之间的通信是通过Broker进行的，订阅者只用关心自己想收到怎样的消息，可以灵活的制定接收消息的规则。发布者也是相同，只需要发布消息就可以，具体的订阅请求，可以让broker灵活的处理。

发布订阅模式和观察者模式的异同

observable vs publisher

• 观察者模式中，观察者和订阅者是明确知道彼此存在，存在关联，观察者也需要管理订阅者。但是发布订阅模式下，发布者和订阅者不需要知道彼此的存在，只需要第三方消息队列帮助他们通信就可以。
• 发布订阅模式，发布和订阅是完全解耦的，因为发布者不需要去管理观察者的订阅状态，也就是观察者想干什么，发布者完全不用操心。但是观察者模式下，他们之间还是松耦合的。
• 观察者模式通常应用于异步相关，发布订阅模式通常需要基于同步消息去通信。
• 观察者模式需要在单个应用当中使用，但是发布订阅模式通常会使用于跨平台和跨应用模式当中。
  Microsoft-Publisher-Subscriber pattern