定义
一系列对象之间的一对多的关系,当一个对象改变状态时,它的所有依赖者都会收到通知。原理是观察者订阅被观察者,如果被观察者状态变化,通知订阅的观察者。
角色
- 被观察者
- 被观察者订阅抽象接口
- 观察者结构体实现订阅接口
角色关系为:观察者实现被观察者抽象的订阅接口,观察者订阅被观察者,被观察者一旦数据状态改变,就通知调用订阅者订阅的抽象接口。
例子
一个公司业务部门接到业务需求后,产品、开发、测试观察到需求后做不同的事情。即公司业务部门为被观察者,产品、开发、测试为订阅者。
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()
}
总结
抽象经常变动的订阅者,并通过注册的方式向被订阅者注册,被订阅者保存订阅者订阅的抽象接口,一旦被订阅者数据状态改变,然后调用注册的接口。