Golang Observer事件通知实现示例

package main

import "fmt"

// Observer 观察者接口，定义接收通知的方法
type Observer interface {
    Update(message string)
}

// Subject 被观察者，维护观察者列表并发送通知
type Subject struct {
    observers []Observer
}

// Attach 添加观察者
func (s *Subject) Attach(o Observer) {
    s.observers = append(s.observers, o)
}

// Notify 通知所有观察者
func (s *Subject) Notify(message string) {
    for _, observer := range s.observers {
        observer.Update(message)
    }
}

// EmailNotifier 具体观察者：发送邮件通知
type EmailNotifier struct{}

func (e *EmailNotifier) Update(message string) {
    fmt.Printf("? Email 发送通知: %s\n", message)
}

// SMSNotifier 具体观察者：发送短信通知
type SMSNotifier struct{}

func (s *SMSNotifier) Update(message string) {
    fmt.Printf("? SMS 发送通知: %s\n", message)
}

// LogNotifier 具体观察者：记录日志
type LogNotifier struct{}

func (l *LogNotifier) Update(message string) {
    fmt.Printf("? 日志记录: %s\n", message)
}

func main() {
    // 创建被观察者
    subject := &Subject{}

    // 创建观察者实例
    email := &EmailNotifier{}
    sms := &SMSNotifier{}
    log := &LogNotifier{}

    // 注册观察者
    subject.Attach(email)
    subject.Attach(sms)
    subject.Attach(log)

    // 触发事件，通知所有观察者
    subject.Notify("用户已成功注册")
}

? Email 发送通知: 用户已成功注册
? SMS 发送通知: 用户已成功注册
? 日志记录: 用户已成功注册