badu/bus是一个基于 Go 泛型实现的轻量级发布-订阅事件总线库。它通过事件机制让不同组件解耦，避免直接调用彼此的函数。

使用者痛点与方法

在传统的程序开发中。开发者往往面临以下痛点：

• 模块间耦合度高，修改一个组件会导致全局回归测试。怎么说呢，
• 难以实现异步消息流。 导致程序性能瓶颈，
• 业务拆分后难以维护，缺少统一的事件通信规范。其实，
• 在多租户或插件化架构下增加功能需要手动集成调用链路。

badu/bus 正是针对上述问题提供了简洁、类型安全且支持异步的事件总线方法。让开发者可以专注业务逻辑，而不必担心模块间调用细节。

安装

go get github.com/badu/bus

从示例来看。解耦订单程序

项目结构

📦 order-system
├── 📂 events # 事件定义
│ └── events.go # 所有事件
├── 📂 order # 订单模块
│ └── order.go # 下单逻辑
├── 📂 notification # 通知模块
│ └── notify.go # 消息通知
├── 📂 logging # 日志模块
│ └── log.go # 日志记录
├── 📂 shipping # 发货模块
│ └── ship.go # 自动发货
└── main.go # 启动入口

events/events.go

所有业务事件都放在单独的 events 包中，避免循环依赖。

package events
// OrderEvent 表示订单创建事件
type OrderEvent struct {
ID string
}

order/order.go - 下单并发布事件

package order
import (
"fmt"
"github.com/badu/bus"
"order-system/events"
)
// PlaceOrder 创建订单并发布 OrderEvent
func PlaceOrder {
fmt.Println
bus.Pub
}

notification/notify.go - 通知使用者

package notification
import (
"fmt"
"github.com/badu/bus"
"order-system/events"
)
// NotifyUser 发送通知给使用者
func NotifyUser {
fmt.Println
}
// Init 在启动时订阅 OrderEvent
func Init {
bus.Sub
}

logging/log.go - 日志记录

package logging
import (
"fmt"
"github.com/badu/bus"
"order-system/events"
)
// LogOrder 写入日志文件或数据库等持久化层
func LogOrder {
fmt.Println
}
// Init 在启动时订阅 OrderEvent
func Init {
bus.Sub
}

shipping/ship.go - 自动发货

package shipping
import (
"fmt"
"github.com/badu/bus"
"order-system/events"
)
// AutoShip 自动进入发货流程
func AutoShip {
fmt.Println
}
// Init 在启动时订阅 OrderEvent
func Init {
bus.Sub
}

main.go - 程序入口与订阅初始化

package main
import (
"order-system/logging"
"order-system/notification"
"order-system/order"
"order-system/shipping"
)
func main {
// 初始化所有订阅者
notification.Init
logging.Init
shipping.Init
// 使用者下单触发整个流程
order.PlaceOrder
}

运行结果示例

🛒 订单已创建: 📢 通知使用者: 订单  已创建 📝 记录日志: 订单  已创建 🚚 订单  已进入发货流程 

常见问题与使用技巧

基本订阅与发布示例

// 定义自定义事件类型
type InterestingEvent struct{}
// 虚拟处理函数
func OnMyEventOccurred { /* ... */ }
// 注册监听器
bus.Sub
// 发布事件
bus.Pub

再看取消订阅。

subscription := bus.Sub
// 如需取消监听
subscription.Cancel

只监听一次这方面，

// OnMyEventOccurred 返回 true 表示继续保持订阅
func OnMyEventOccurred bool {
// ...
return true
}

bus.SubCancel // 单次订阅后自动取消