Golang如何应用观察者模式_Golang 观察者模式使用实践

观察者模式通过接口和组合在Go中实现对象间一对多依赖，当主体状态变化时自动通知所有观察者。示例中EventManager管理Observer列表，支持注册、注销与通知，EmailService和LogService作为具体观察者接收消息。主函数模拟用户登录触发通知，输出显示注册的观察者收到事件，注销后不再接收。使用互斥锁可保证并发安全，建议异步处理通知以避免阻塞，适用于解耦事件发布与处理逻辑。

观察者模式是一种行为设计模式，适用于对象之间存在一对多依赖关系的场景，当一个对象状态改变时，所有依赖它的对象都会自动收到通知。在 Go 语言中，虽然没有类和继承的概念，但通过接口和组合机制可以非常简洁地实现观察者模式。

定义主题（Subject）和观察者（Observer）接口

核心是定义两个角色：主题（被观察者）和观察者。主题维护一组观察者，并提供注册、注销和通知的方法；观察者实现接收通知的接口。

示例代码：

type Observer interface {
    Update(message string)
}

type Subject interface {
    Register(observer Observer)
    Unregister(observer Observer)
    Notify(message string)
}

这里定义了 Observer 接口，包含一个 Update 方法用于接收更新消息；Subject 接口则提供了注册、注销和广播通知的能力。

实现具体的主题和观察者

以一个简单的事件通知系统为例，比如用户登录后需要通知日志服务、邮件服务等模块。

type EventManager struct {
    observers []Observer
}

func (em *EventManager) Register(observer Observer) {
    em.observers = append(em.observers, observer)
}

func (em *EventManager) Unregister(observer Observer) {
    for i, obs := range em.observers {
        if obs == observer {
            em.observers = append(em.observers[:i], em.observers[i+1:]...)
            break
        }
    }
}

func (em *EventManager) Notify(message string) {
    for _, observer := range em.observers {
        observer.Update(message)
    }
}

// 具体观察者
type EmailService struct{}

func (e *EmailService) Update(message string) {
    fmt.Println("EmailService received:", message)
}

type LogService struct{}

func (l *LogService) Update(message string) {
    fmt.Println("LogService logged:", message)
}

上面实现了 EventManager 作为具体主题，管理多个观察者。两个具体观察者 EmailService 和 LogService 在收到通知时执行各自逻辑。

使用场景示例：用户登录事件通知

模拟用户登录后触发事件，通知所有监听该事件的服务。

func main() {
    eventManager := &EventManager{}

    emailSvc := &EmailService{}
    logSvc := &LogService{}

    // 注册观察者
    eventManager.Register(emailSvc)
    eventManager.Register(logSvc)

    // 模拟用户登录
    eventManager.Notify("User logged in")

    // 取消某个观察者
    eventManager.Unregister(emailSvc)

    // 再次通知，此时只有日志服务会收到
    eventManager.Notify("User updated profile")
}

输出结果：

EmailService received: User logged in
LogService logged: User logged in
LogService logged: User updated profile

可以看到，在注销邮箱服务后，它不再接收到后续的通知。

优化建议与注意事项

使用互斥锁保护观察者列表，避免并发修改问题
可扩展为支持多种事件类型（如按事件名分类通知）
观察者更新尽量异步执行，防止阻塞其他通知
注意循环引用或未及时注销导致的内存泄漏

基本上就这些。Go 的接口和结构体组合让观察者模式实现变得轻量且灵活，适合用于解耦事件发布与处理逻辑，提升系统的可维护性和扩展性。

# go # golang # app # ai # 邮箱 # 结构体 # 循环 # 继承 # 接口 # 并发 # 对象 # 事件 # 异步 # 用户登录 # 适用于 # 是一种 # 互斥 # 多个 # 可以看到 # 为例 # 它不 # 或未 # 再接

返回目录在线咨询

上一篇：东莞建站公司哪家更专业可靠？
下一篇：C#中TCP粘包问题的解决方法

您的项目需求