52 lines
1.0 KiB
Go
52 lines
1.0 KiB
Go
package main
|
||
|
||
import "fmt"
|
||
|
||
// 抽象观察者
|
||
type IObserver interface {
|
||
Notify() // 当被观察对象有更改的时候，出发观察者的Notify() 方法
|
||
}
|
||
|
||
// 抽象被观察者
|
||
type ISubject interface {
|
||
AddObservers(observers ...IObserver) // 添加观察者
|
||
NotifyObservers() // 通知观察者
|
||
}
|
||
|
||
type Observer struct {
|
||
}
|
||
|
||
func (o *Observer) Notify() {
|
||
fmt.Println("已经触发了观察者")
|
||
}
|
||
|
||
type Subject struct {
|
||
observers []IObserver
|
||
}
|
||
|
||
func (s *Subject) AddObservers(observers ...IObserver) {
|
||
//fmt.Println(1)
|
||
s.observers = append(s.observers, observers...)
|
||
//fmt.Println(s.observers)
|
||
}
|
||
|
||
func (s *Subject) NotifyObservers() {
|
||
for k := range s.observers {
|
||
s.observers[k].Notify() // 触发观察者
|
||
}
|
||
}
|
||
|
||
func main() {
|
||
// 创建被观察者
|
||
s := new(Subject)
|
||
// 创建观察者
|
||
o := new(Observer)
|
||
// 为主题添加观察者
|
||
s.AddObservers(o)
|
||
|
||
// 这里的被观察者要做各种更改...
|
||
|
||
// 更改完毕，触发观察者
|
||
s.NotifyObservers()
|
||
}
|