PubSub - 发布订阅
PubSub 提供发布订阅模式。
特性
- 主题订阅
- 消息发布
- 消息过滤
- 异步处理
安装
bash
go get github.com/go-zoox/pubsub快速开始
基本使用
go
package main
import (
"fmt"
"github.com/go-zoox/pubsub"
)
func main() {
ps := pubsub.New()
// 订阅主题
ps.Subscribe("news", func(msg pubsub.Message) {
fmt.Printf("Received: %s\n", msg.Data)
})
// 发布消息
ps.Publish("news", pubsub.Message{
Data: "Breaking news!",
})
}