阅读量:0
在Go语言中,可以使用接口和通道来实现观察者模式。
首先,定义一个观察者接口,其中有一个更新方法,用于接收被观察者的通知:
type Observer interface { Update(string) }
接下来,定义一个被观察者结构体,其中有一个观察者切片,用于保存所有注册的观察者:
type Subject struct { observers []Observer } func (s *Subject) Attach(observer Observer) { s.observers = append(s.observers, observer) } func (s *Subject) Notify(message string) { for _, observer := range s.observers { observer.Update(message) } }
然后,定义一个具体的观察者结构体,实现观察者接口的更新方法:
type ConcreteObserver struct { name string } func (co *ConcreteObserver) Update(message string) { fmt.Printf("%s received message: %s\n", co.name, message) }
最后,可以创建一个被观察者对象,并注册多个观察者对象,然后调用被观察者的Notify方法发送通知:
func main() { subject := &Subject{} observer1 := &ConcreteObserver{name: "Observer 1"} observer2 := &ConcreteObserver{name: "Observer 2"} subject.Attach(observer1) subject.Attach(observer2) subject.Notify("Hello, observers!") }
运行以上代码,就可以看到输出结果:
Observer 1 received message: Hello, observers! Observer 2 received message: Hello, observers!
以上就是用Go语言实现观察者模式的一种方式。通过定义观察者接口和被观察者结构体,以及具体的观察者结构体,实现了观察者模式的功能。