经纪人:琐碎的消息经纪人 源码
经纪人-最小的pubsub pubsub是一个很小的库,用于使用渠道为Go实现最简单的发布-订阅机制。 用法 import "github.com/borud/broker" 创建一个新的经纪人 broker := broker.New() 订阅主题或主题前缀 sub, err := broker.Subscribe("/foo/bar") 从订阅中获取消息 for msg := range sub.Messages() { log.Printf("topic = '%s', message = '%+v'", msg.Topic, msg.Payload) } 发布消息给经纪人 e
文件列表
broker-main.zip
(预估有个7文件)
broker-main
go.mod
150B
go.sum
1KB
subscriber.go
608B
broker_test.go
2KB
broker.go
5KB
LICENSE
11KB
README.md
2KB
暂无评论