Golang异步事件处理技巧与实现

type Event struct {
    Type string
    Data interface{}
}
type EventHandler func(event Event)

type EventBus struct {
    handlers map[string][]EventHandler
    events   chan Event
}
func NewEventBus(bufferSize int) *EventBus {
bus := &EventBus{
handlers: make(map[string][]EventHandler),
events:   make(chan Event, bufferSize),
}
go bus.start()
return bus
}
func (bus *EventBus) start() {
for event := range bus.events {
if handlers, exists := bus.handlers[event.Type]; exists {
for _, h := range handlers {
go h(event) // 异步执行每个处理器
}
}
}
}
func (bus *EventBus) Publish(event Event) {
bus.events <- event
}
func (bus *EventBus) Subscribe(eventType string, handler EventHandler) {
bus.handlers[eventType] = append(bus.handlers[eventType], handler)
}

func main() {
    bus := NewEventBus(100)
// 订阅用户创建事件
bus.Subscribe("user.created", func(e Event) {
    fmt.Printf("邮件服务收到：新用户 %v\n", e.Data)
})

bus.Subscribe("user.created", func(e Event) {
    fmt.Printf("日志服务记录：用户 %v 已创建\n", e.Data)
})

// 发布事件
bus.Publish(Event{
    Type: "user.created",
    Data: "Alice",
})

// 给足够时间让异步处理完成（生产环境可用WaitGroup）
time.Sleep(time.Millisecond * 100)
}