阅读量:0
在Go语言中实现观察者模式,可以按照以下步骤进行:
- 定义主题(Subject)接口,包含以下方法:
type Subject interface { Register(observer Observer) // 注册观察者 Unregister(observer Observer) // 取消注册观察者 Notify() // 通知观察者 }
- 定义观察者(Observer)接口,包含以下方法:
type Observer interface { Update() // 观察者更新方法 }
- 实现主题(Subject)结构体,同时实现Subject接口的方法:
type ConcreteSubject struct { observers []Observer } func (s *ConcreteSubject) Register(observer Observer) { s.observers = append(s.observers, observer) } func (s *ConcreteSubject) Unregister(observer Observer) { for i, o := range s.observers { if o == observer { s.observers = append(s.observers[:i], s.observers[i+1:]...) break } } } func (s *ConcreteSubject) Notify() { for _, observer := range s.observers { observer.Update() } }
- 实现观察者(Observer)结构体,同时实现Observer接口的方法:
type ConcreteObserver struct { name string } func (o *ConcreteObserver) Update() { fmt.Println(o.name, "received notification") }
- 使用观察者模式:
func main() { subject := &ConcreteSubject{} observer1 := &ConcreteObserver{name: "Observer 1"} observer2 := &ConcreteObserver{name: "Observer 2"} subject.Register(observer1) subject.Register(observer2) subject.Notify() subject.Unregister(observer1) subject.Notify() }
在上述代码中,ConcreteSubject实现了Subject接口,ConcreteObserver实现了Observer接口。当Subject的状态发生变化时,通过调用Notify方法通知所有注册的观察者进行更新。在main函数中,我们创建了一个ConcreteSubject对象,并注册了两个ConcreteObserver对象。然后通过调用Notify方法通知所有观察者进行更新。最后,我们取消注册了observer1,并再次调用Notify方法,此时只有observer2会收到通知。