行为型
11 

观察者模式

观察者模式将观察者和被观察者代码解耦。观察者模式的应用场景非常广泛,小到代码层面的解耦,大到架构层面的系统解耦,再或者一些产品的设计思路,都有这种模式的影子,比如,邮件订阅、RSS Feeds,本质上都是观察者模式。

// 观察者模式:(Observer Design Pattern)也被称为发布订阅模式(Publish-Subscribe Design Pattern
package main

import "fmt"

// 主题接口
type Subject interface {
	registerObserver(observer Observer)
	removeObserver(observer Observer)
	notifyObservers(message Message)
}

// 观察者接口,用于订阅的主题状态有变动的时候,做一些操作
type Observer interface {
	update(message Message)
}

type Message struct{}

func NewMessage() Message {
	return Message{}
}

// ConcreteSubject 具体主题类
type ConcreteSubject struct {
	observers []Observer
}

// 返回指针类型,需要修改 observers
func NewConcreteSubject() *ConcreteSubject {
	return &ConcreteSubject{}
}

// 增加订阅者
func (cs *ConcreteSubject) registerObserver(observer Observer) {
	cs.observers = append(cs.observers, observer)
}

// 删除订阅者
func (cs *ConcreteSubject) removeObserver(observer Observer) {
	// TODO
}

// 通知所有订阅者
func (cs *ConcreteSubject) notifyObservers(message Message) {
	for _, observer := range cs.observers {
		observer.update(message)
	}
}

// ConcreteObserverOne
type ConcreteObserverOne struct{}

func NewConcreteObserverOne() ConcreteObserverOne {
	return ConcreteObserverOne{}
}

func (coo ConcreteObserverOne) update(message Message) {
	//TODO: 获取消息通知,执行自己的逻辑...
	fmt.Println("ConcreteObserverOne is notified.")
}

// ConcreteObserverTwo
type ConcreteObserverTwo struct{}

func NewConcreteObserverTwo() ConcreteObserverTwo {
	return ConcreteObserverTwo{}
}

func (cot ConcreteObserverTwo) update(message Message) {
	//TODO: 获取消息通知,执行自己的逻辑...
	fmt.Println("ConcreteObserverTwo is notified.")
}