观察者模式
发布时间 :
阅读 :
Observer Pattern
观察者模式使得一种类型的实例可以发送事件给其他类型，前提是接收事件的实例要跟发送者订阅这个事件。
实现
先来定义要使用到的接口
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
| package observer
type(
Event struct{
Data int64
}
Observer interface{
OnNotify(Event)
}
Notifier interface{
Register(Observer)
Degister(Observer)
Notify(Event)
}
)
|
然后写几个简单的类型实现这些接口
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
| package observer
import "fmt"
type EventCenter struct{
observers []Observer
}
func (this *EventCenter)Notify(event Event){
for _,v:=range this.observers{
v.OnNotify(event)
}
}
func (this *EventCenter)Register(o Observer){
this.observers=append(this.observers,o)
}
func (this *EventCenter)Degister(o Observer){
for i:=0;i<len(this.observers);i++{
if this.observers[i]==o{
this.observers=append(this.observers[:i],this.observers[i+1:]...)
break
}
}
}
func NewEventCenter()*EventCenter{
res := EventCenter{}
res.observers=make([]Observer,0)
return &res
}
type EventReciver struct{
}
func (this *EventReciver)OnNotify(event Event){
fmt.Printf("Event receive:%d\n",event.Data)
}
|
最后是main文件
1
2
3
4
5
6
7
8
9
10
11
12
13
| package main
func main(){
eventCenter := observer.NewEventCenter()
r_1 := observer.EventReciver{}
r_2 := observer.EventReciver{}
eventCenter.Register(&r_1)
eventCenter.Register(&r_2)
eventCenter.Notify(observer.Event{1})
eventCenter.Degister(&r_1)
eventCenter.Notify(observer.Event{2})
}
|
转载请注明来源，欢迎对文章中的引用来源进行考证，欢迎指出任何有错误或不够清晰的表达。可以邮件
粤ICP备2024314277号
©2024 寒江雪