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

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

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

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

// 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("用户登录成功")
}

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