Go中通过接口定义Command并结合EventBus实现观察者+命令模式组合，用闭包将命令绑定为事件处理器，支持同步/异步执行、撤销、日志与测试。
在 Go 中实现“观察者 + 命令模式”组合以支持事件驱动的请求执行，核心是解耦事件产生者（Subject）与响应者（Observer），同时让每个响应动作封装为可调度、可撤销、可记录的命令（Command）。这不是简单套用两个设计模式，而是利用 Go 的接口、闭包和 channel 特性，构建轻量、类型安全、易于测试的事件处理链。
定义命令接口与具体命令
命令模式的关键是统一行为契约。Go 中用接口表达最自然：
type Command interface {
Execute() error
Undo() error // 可选：支持回滚
Name() string
}例如一个用户注册请求可封装为命令：
type RegisterUserCmd struct {
Email, Password string
UserID int
Store UserStore // 依赖注入，便于测试
}
func (c *RegisterUserCmd) Execute() error {
user := User{Email: c.Email, Password: c.Password}
id, err := c.Store.Create(user)
c.UserID = id
return err
}
func (c *RegisterUserCmd) Undo() error {
return c.Store.Delete(c.UserID)
}
func (c *RegisterUserCmd) Name() string { return "RegisterUser" }
立即学习“go语言免费学习笔记（深入）”；
构建事件总线（观察者核心）
用泛型 map + sync.RWMutex 实现线程安全的事件注册/通知机制，事件类型用字符串或自定义类型（推荐枚举）：
type Event stringconst ( EventUserRegistered Event = "user.registered" EventPaymentProcessed Event = "payment.processed" )
type EventBus struct { mu sync.RWMutex handlers map[Event][]func(interface{}) error }
func NewEventBus() *EventBus { return &EventBus{ handlers: make(map[Event][]func(interface{}) error), } }
func (eb *EventBus) Subscribe(event Event, handler func(interface{}) error) { eb.mu.Lock() defer eb.mu.Unlock() eb.handlers[event] = append(eb.handlers[event], handler) }
func (eb *EventBus) Publish(event Event, payload interface{}) error { eb.mu.RLock() handlers := make([]func(interface{}) error, len(eb.handlers[event])) copy(handlers, eb.handlers[event]) eb.mu.RUnlock()
var errs []error for _, h := range handlers { if err := h(payload); err != nil { errs = append(errs, err) } } if len(errs) > 0 { return fmt.Errorf("event %s failed: %v", event, errs) } return nil}
连接命令与事件：命令作为事件处理器
让命令本身成为观察者——即把
Execute()绑定到事件总线。更灵活的做法是用工厂函数生成 handler：// 创建命令执行器（handler 工厂） func MakeCommandHandler(cmd Command) func(interface{}) error { return func(payload interface{}) error { // 可在此做 payload 转换、校验、日志等 log.Printf("Executing command: %s", cmd.Name()) return cmd.Execute() } }// 使用示例 bus := NewEventBus() bus.Subscribe(EventUserRegistered, MakeCommandHandler(&RegisterUserCmd{ Email: "a@b.com", Store: &MockUserStore{}, }))
// 触发事件 → 自动执行命令 bus.Publish(EventUserRegistered, nil)
这样既保持命令的独立性，又通过闭包将其接入事件流。你还可以包装成带重试、超时、事务的增强 handler。
支持异步、队列与生命周期管理
真实场景中，命令常需异步执行或排队。可用 channel + goroutine 实现轻量消息队列：
- 定义命令队列：
cmdCh := make(chan Command, 100) - 启动消费者：
go func() { for cmd := range cmdCh { _ = cmd.Execute() } }() - 事件 handler 改为发送命令到 channel：
cmdCh
若需保证顺序、失败重试或持久化，可集成第三方库如 asynq 或 machinery，它们本身已内置命令语义和观察者钩子（OnSuccess, OnError）。
不复杂但容易忽略的是错误传播与可观测性——建议在 handler 中统一打日志、上报 metrics，并让 Command 接口支持上下文（Execute(ctx context.Context) error）以支持取消和超时。
