Golang观察者模式事件订阅与通知-Golang-PHP中文网

Golang观察者模式事件订阅与通知

P粉602998670

发布： 2025-09-28 10:45:01

原创

402人浏览过

观察者模式通过定义Subject和Observer接口实现解耦，EventCenter作为具体主体管理观察者列表并通知，Logger和Mailer作为观察者接收消息，使用互斥锁保证并发安全，通过复制列表避免通知时的竞态问题，适用于状态变更通知场景。

golang观察者模式事件订阅与通知

在Go语言中实现观察者模式，可以很好地解耦事件的发布者与订阅者。这种设计模式常用于状态变更通知、消息广播等场景。核心思想是：一个主体（被观察者）维护一组观察者列表，当主体状态发生变化时，自动通知所有注册的观察者。

定义观察者接口和主体

要实现观察者模式，先定义两个核心部分：主体（Subject）和观察者（Observer）。主体负责管理订阅者并发送通知，观察者则实现接收更新的方法。

Observer 接口：包含一个 Notify 方法，用于接收通知。

Subject 接口：提供 Subscribe 和 Notify 方法，用于增删观察者和触发通知。

立即学习“go语言免费学习笔记（深入）”；

示例代码：

type Observer interface {
    Notify(data interface{})
}

type Subject interface {
    Subscribe(obs Observer)
    Unsubscribe(obs Observer)
    NotifyAll(data interface{})
}

登录后复制

实现具体的被观察者

以一个简单的事件中心为例，使用切片存储观察者，并通过互斥锁保证并发安全。

燕雀Logo

为用户提供LOGO免费设计在线生成服务

101

查看详情

type EventCenter struct {
    observers []Observer
    mutex     sync.Mutex
}

func NewEventCenter() *EventCenter {
    return &EventCenter{
        observers: make([]Observer, 0),
    }
}

func (ec *EventCenter) Subscribe(obs Observer) {
    ec.mutex.Lock()
    defer ec.mutex.Unlock()
    ec.observers = append(ec.observers, obs)
}

func (ec *EventCenter) Unsubscribe(obs Observer) {
    ec.mutex.Lock()
    defer ec.mutex.Unlock()
    for i, o := range ec.observers {
        if o == obs {
            ec.observers = append(ec.observers[:i], ec.observers[i+1:]...)
            break
        }
    }
}

func (ec *EventCenter) NotifyAll(data interface{}) {
    ec.mutex.Lock()
    observers := make([]Observer, len(ec.observers))
    copy(observers, ec.observers)
    ec.mutex.Unlock()

    for _, obs := range observers {
        obs.Notify(data)
    }
}

登录后复制

这里复制观察者列表是为了避免在通知过程中因加锁时间过长影响性能，也防止观察者在回调中修改列表导致竞态问题。

定义具体观察者

每个观察者只需实现 Notify 方法即可响应事件。例如，创建两个处理日志和发送邮件的观察者：

type Logger struct{}

func (l *Logger) Notify(data interface{}) {
    fmt.Printf("日志记录: %v\n", data)
}

type Mailer struct{}

func (m *Mailer) Notify(data interface{}) {
    if user, ok := data.(map[string]string); ok {
        fmt.Printf("发送邮件给: %s, 内容: 欢迎 %s\n", user["email"], user["name"])
    }
}

登录后复制

使用示例

将观察者注册到事件中心，触发事件后自动通知所有订阅者：

func main() {
    center := NewEventCenter()

    logger := &Logger{}
    mailer := &Mailer{}

    center.Subscribe(logger)
    center.Subscribe(mailer)

    newUser := map[string]string{
        "name":  "Alice",
        "email": "alice@example.com",
    }

    center.NotifyAll(newUser)

    center.Unsubscribe(mailer)
    center.NotifyAll("系统更新")
}

登录后复制

输出结果：

日志记录: map[name:Alice email:alice@example.com]
发送邮件给: alice@example.com, 内容: 欢迎 Alice
日志记录: 系统更新

登录后复制

可以看到，第一次通知时两个观察者都收到消息；取消订阅后，只有日志观察者继续接收。

基本上就这些。用接口和切片就能清晰实现事件的订阅与通知机制，适合中小型场景。如果需要更复杂的调度或异步处理，可结合 channel 进一步扩展。

以上就是Golang观察者模式事件订阅与通知的详细内容，更多请关注php中文网其它相关文章！

大家都在看：

Go语言：高效将字节切片（[]uint8）转换为浮点数（float64） Go语言中利用反射机制调用方法并正确处理其返回值 Go语言：[]uint8数据转换为float64的实用指南 Go语言：将字节切片[]uint8转换为浮点数float64的实用指南 Go语言中将[]uint8转换为float64的实用指南