Golang轻量级事件总线EventBus使用指南

EventBus是一个轻量级的异步事件总线库，用于在Golang应用中实现发布-订阅模式。下面我将详细介绍其使用方法并提供示例代码。

安装EventBus

go get github.com/asaskevich/EventBus

基本使用

1. 创建事件总线实例

import "github.com/asaskevich/EventBus"

func main() {
    bus := EventBus.New() // 创建新的事件总线实例
    // ...
}

2. 订阅事件

func handler1(data string) {
    fmt.Println("Handler1 received:", data)
}

func handler2(data string) {
    fmt.Println("Handler2 received:", data)
}

func main() {
    bus := EventBus.New()
    
    // 订阅事件
    bus.Subscribe("topic1", handler1)
    bus.Subscribe("topic1", handler2)
    
    // ...
}

3. 发布事件

func main() {
    // ... 前面的订阅代码
    
    // 发布事件
    bus.Publish("topic1", "Hello EventBus!")
    
    // 输出:
    // Handler1 received: Hello EventBus!
    // Handler2 received: Hello EventBus!
}

高级特性

1. 异步事件处理

func slowHandler(data string) {
    time.Sleep(2 * time.Second)
    fmt.Println("Slow handler completed:", data)
}

func main() {
    bus := EventBus.New()
    bus.SubscribeAsync("async_topic", slowHandler, false)
    
    fmt.Println("Publishing async event...")
    bus.Publish("async_topic", "Async message")
    fmt.Println("Event published, handler running in background")
    
    time.Sleep(3 * time.Second) // 等待异步处理完成
}

2. 取消订阅

func main() {
    bus := EventBus.New()
    bus.Subscribe("topic2", handler1)
    
    // 发布事件
    bus.Publish("topic2", "First message") // 会被handler1处理
    
    // 取消订阅
    bus.Unsubscribe("topic2", handler1)
    
    bus.Publish("topic2", "Second message") // 不会被处理
}

3. 等待异步处理完成

func main() {
    bus := EventBus.New()
    bus.SubscribeAsync("wait_topic", slowHandler, false)
    
    bus.Publish("wait_topic", "Message with wait")
    
    // 等待所有异步处理完成
    bus.WaitAsync()
    fmt.Println("All async handlers completed")
}

实际应用示例

下面是一个更完整的示例，模拟用户注册后发送欢迎邮件和记录日志的场景：

package main

import (
	"fmt"
	"time"
	
	"github.com/asaskevich/EventBus"
)

type User struct {
	ID    int
	Name  string
	Email string
}

func sendWelcomeEmail(user User) {
	time.Sleep(1 * time.Second) // 模拟发送邮件耗时
	fmt.Printf("Email sent to %s <%s>\n", user.Name, user.Email)
}

func logUserRegistration(user User) {
	fmt.Printf("Log: User %d (%s) registered at %v\n", 
		user.ID, user.Name, time.Now())
}

func registerUser(bus EventBus.Bus, name, email string) {
	// 模拟用户注册过程
	user := User{
		ID:    time.Now().Nanosecond(),
		Name:  name,
		Email: email,
	}
	
	// 发布用户注册事件
	bus.Publish("user_registered", user)
}

func main() {
	bus := EventBus.New()
	
	// 订阅用户注册事件
	bus.SubscribeAsync("user_registered", sendWelcomeEmail, false)
	bus.Subscribe("user_registered", logUserRegistration)
	
	// 注册新用户
	fmt.Println("Registering new user...")
	registerUser(bus, "Alice", "alice@example.com")
	
	// 确保异步操作完成
	bus.WaitAsync()
	fmt.Println("User registration process completed")
}

注意事项

1. 线程安全：EventBus是线程安全的，可以在多个goroutine中使用
2. 错误处理：如果处理器函数返回错误，可以使用SubscribeOnce或SubscribeOnceAsync来确保只执行一次
3. 性能：对于高性能场景，考虑使用带缓冲的通道或专门的消息队列系统
4. 内存泄漏：长期运行的应用中，注意及时取消不再需要的事件订阅

EventBus是一个简单但功能强大的库，非常适合在中小型Golang应用中实现组件间的松耦合通信。