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

2023-10-23 14:18

短信预约 -IT技能 免费直播动态提醒

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

免责声明：

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

golang

阅读原文内容投诉