Golang如何使用观察者模式实现事件订阅_Golang观察者模式事件订阅实践详解

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

Golang如何使用观察者模式实现事件订阅_Golang观察者模式事件订阅实践详解

2025-10-30

浏览次数：次

返回列表

观察者模式通过接口与结构体实现事件订阅，主题维护观察者列表并通知状态变更，如用户注册时触发邮件发送与资料初始化。

golang如何使用观察者模式实现事件订阅_golang观察者模式事件订阅实践详解

在Go语言中，观察者模式是一种常见的设计模式，用于实现对象间的一对多依赖关系，当一个对象状态改变时，所有依赖它的对象都会得到通知。这种机制非常适合实现事件订阅系统。下面通过一个清晰的结构来说明如何用Golang实践观察者模式来实现事件订阅。

观察者模式的核心组成

观察者模式包含两个主要角色：

主题（Subject）：维护观察者列表，提供注册、注销和通知接口。
观察者（Observer）：实现通知响应方法，接收主题的状态更新。

在事件系统中，主题通常称为“事件发布者”，观察者则是“事件订阅者”。

定义接口与结构体

先定义统一的接口，让代码更灵活可扩展。

type Event string

type Observer interface {
    OnNotify(Event)
}

type Subject struct {
    observers []Observer
}

Subject结构体持有一个Observer切片，用来管理所有订阅者。接下来实现注册、注销和广播方法。

Musho

AI网页设计Figma插件

76 查看详情 Musho

func (s *Subject) Subscribe(o Observer) {
    s.observers = append(s.observers, o)
}

func (s *Subject) Unsubscribe(o Observer) {
    for i, observer := range s.observers {
        if observer == o {
            s.observers = append(s.observers[:i], s.observers[i+1:]...)
            break
        }
    }
}

func (s *Subject) Notify(event Event) {
    for _, observer := range s.observers {
        observer.OnNotify(event)
    }
}

实现具体的事件订阅逻辑

现在我们创建几个实际的观察者来响应事件。

type UserEmailService struct{}

func (u *UserEmailService) OnNotify(event Event) {
    if event == "user_registered" {
        println("发送欢迎邮件...")
    }
}

type UserService struct{}

func (u *UserService) OnNotify(event Event) {
    if event == "user_registered" {
        println("初始化用户资料...")
    }
}

这两个服务会在用户注册时被触发。使用方式如下：

func main() {
    subject := &Subject{}
    emailService := &UserEmailService{}
    profileService := &UserService{}

    subject.Subscribe(emailService)
    subject.Subscribe(profileService)

    // 模拟用户注册事件
    subject.Notify("user_registered")
}

输出结果为：

发送欢迎邮件...
初始化用户资料...