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

新闻中心 NEWS CENTER

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

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

2025-11-27

浏览次数：次

返回列表

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

golang如何应用观察者模式_golang 观察者模式使用实践

观察者模式是一种行为设计模式，适用于对象之间存在一对多依赖关系的场景，当一个对象状态改变时，所有依赖它的对象都会自动收到通知。在 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 在收到通知时执行各自逻辑。

Motiff妙多

Motiff妙多是一款AI驱动的界面设计工具，定位为“AI时代设计工具”

334 查看详情 Motiff妙多

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

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

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")
}