Golang观察者模式事件订阅教程

偷偷努力，悄无声息地变强，然后惊艳所有人！哈哈，小伙伴们又来学习啦~今天我将给大家介绍《Golang观察者模式事件订阅示例》，这篇文章主要会讲到等等知识点，不知道大家对其都有多少了解，下面我们就一起来看一吧！当然，非常希望大家能多多评论，给出合理的建议，我们一起学习，一起进步！

Go语言通过观察者模式解耦事件发布与订阅，定义Observer和Subject接口，实现EventCenter管理订阅并通知，结合具体观察者完成状态广播。

在Go语言中实现观察者模式，可以很好地解耦事件的发布者与订阅者。这种设计模式常用于状态变更通知、消息广播等场景。下面通过一个简单的例子展示如何用Golang实现事件的订阅与通知机制。

定义观察者接口与主题

观察者模式包含两个核心部分：一是被观察的主题（Subject），它维护一组观察者并负责通知它们；二是观察者（Observer），它实现更新方法以响应状态变化。

我们先定义接口：

// Observer 观察者接口
type Observer interface {
    Update(message string)
}

// Subject 主题接口
type Subject interface {
    Subscribe(observer Observer)
    Unsubscribe(observer Observer)
    Notify(message string)
}

Observer 接口只有一个 Update 方法，用于接收通知。Subject 接口提供订阅、取消订阅和广播通知的功能。

实现事件中心

接下来实现一个事件中心，作为具体的主题，管理所有订阅者。

import "sync"

// EventCenter 具体的主题实现
type EventCenter struct {
    observers []Observer
    mutex     sync.Mutex
}

// NewEventCenter 创建新的事件中心
func NewEventCenter() *EventCenter {
    return &EventCenter{
        observers: make([]Observer, 0),
    }
}

// Subscribe 添加观察者
func (ec *EventCenter) Subscribe(observer Observer) {
    ec.mutex.Lock()
    defer ec.mutex.Unlock()
    ec.observers = append(ec.observers, observer)
}

// Unsubscribe 移除观察者
func (ec *EventCenter) Unsubscribe(observer Observer) {
    ec.mutex.Lock()
    defer ec.mutex.Unlock()
    for i, obs := range ec.observers {
        if obs == observer {
            ec.observers = append(ec.observers[:i], ec.observers[i+1:]...)
            break
        }
    }
}

// Notify 向所有观察者发送通知
func (ec *EventCenter) Notify(message string) {
    ec.mutex.Lock()
    defer ec.mutex.Unlock()
    for _, observer := range ec.observers {
        observer.Update(message)
    }
}

使用 sync.Mutex 保证并发安全，避免多个goroutine同时修改观察者列表。

创建具体观察者

定义几个具体的观察者类型，比如邮件通知和日志记录。

// EmailNotifier 邮件通知观察者
type EmailNotifier struct{}

func (e *EmailNotifier) Update(message string) {
    println("发送邮件通知: " + message)
}

// LogWatcher 日志监听观察者
type LogWatcher struct{}

func (l *LogWatcher) Update(message string) {
    println("记录日志: " + message)
}

使用示例

现在将所有部分组合起来，测试事件订阅与通知流程。

func main() {
    // 创建事件中心
    eventCenter := NewEventCenter()

    // 创建观察者
    emailNotifier := &EmailNotifier{}
    logWatcher := &LogWatcher{}

    // 订阅事件
    eventCenter.Subscribe(emailNotifier)
    eventCenter.Subscribe(logWatcher)

    // 发布通知
    eventCenter.Notify("系统配置已更新")

    // 取消某个订阅
    eventCenter.Unsubscribe(emailNotifier)

    // 再次通知，只有日志观察者收到
    eventCenter.Notify("用户登录成功")
}

输出结果：

发送邮件通知: 系统配置已更新
记录日志: 系统配置已更新
记录日志: 用户登录成功

可以看到，第一次通知时两个观察者都收到了消息；取消 emailNotifier 的订阅后，它不再接收后续通知。

基本上就这些。这个实现简单、清晰，适用于大多数本地事件通知场景。可根据需要扩展支持按事件类型分类、异步通知、带上下文的事件等。不复杂但容易忽略并发安全和取消订阅的边界处理。

理论要掌握，实操不能落！以上关于《Golang观察者模式事件订阅教程》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！