在Go語言中,可以使用接口和通道來實現(xiàn)觀察者模式。
首先,定義一個觀察者接口,其中有一個更新方法,用于接收被觀察者的通知:
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)
}
}
然后,定義一個具體的觀察者結構體,實現(xiàn)觀察者接口的更新方法:
type ConcreteObserver struct {
name string
}
func (co *ConcreteObserver) Update(message string) {
fmt.Printf("%s received message: %s\n", co.name, message)
}
最后,可以創(chuàng)建一個被觀察者對象,并注冊多個觀察者對象,然后調(diào)用被觀察者的Notify方法發(fā)送通知:
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語言實現(xiàn)觀察者模式的一種方式。通過定義觀察者接口和被觀察者結構體,以及具體的觀察者結構體,實現(xiàn)了觀察者模式的功能。