golang观察者模式实现的代码怎么写

   2025-02-15 4800
核心提示:在Go语言中实现观察者模式,可以按照以下步骤进行:定义主题(Subject)接口,包含以下方法:type Subject interface {Register(

在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会收到通知。

 
 
更多>同类维修知识
推荐图文
推荐维修知识
点击排行
网站首页  |  关于我们  |  联系方式  |  用户协议  |  隐私政策  |  网站留言