观察者模式

定义

一系列对象之间的一对多的关系,当一个对象改变状态时,它的所有依赖者都会收到通知。原理是观察者订阅被观察者,如果被观察者状态变化,通知订阅的观察者。

角色

  1. 被观察者
  2. 被观察者订阅抽象接口
  3. 观察者结构体实现订阅接口

角色关系为:观察者实现被观察者抽象的订阅接口,观察者订阅被观察者,被观察者一旦数据状态改变,就通知调用订阅者订阅的抽象接口。

例子

一个公司业务部门接到业务需求后,产品、开发、测试观察到需求后做不同的事情。即公司业务部门为被观察者,产品、开发、测试为订阅者。

type Business struct{
	Task string
	SubscribeList []Subscribe //订阅列表
}
//订阅任务
func (b *Business)SubscribeJob(job Subscribe){
	b.SubscribeList = append(b.SubscribeList,job)
}
//发布任务
func(b *Business)ReleaseJob(){
	for_,job :=range b.SubscribeList{
	   job.ReceiveJob()
	}
}
type Subscribe interface{
	ReceiveJob()
}
//开发
type Developer struct{
	
}
func (d *Developer)ReceiveJob(){
	fmt.Println("develop job")
}
//产品
type Producter struct{
	
}
func (p *Producter)ReceiveJob(){
	fmt.Println("Product job")
}
//测试
type Tester struct{
	
}
func (t *Tester)ReceiveJob(){
	fmt.Println("test job")
}

func main(){
	//定义被订阅主体
	b := &Business{}
	//订阅
	b.SubscribeJob(&Developer{})
	b.SubscribeJob(&Producter{})
	b.SubscribeJob(&Tester{})
	//发布
	b.Task = "new task"
	b.ReleaseJob()
}

总结

抽象经常变动的订阅者,并通过注册的方式向被订阅者注册,被订阅者保存订阅者订阅的抽象接口,一旦被订阅者数据状态改变,然后调用注册的接口。