文件名称:经纪人:琐碎的消息经纪人
文件大小:9KB
文件格式:ZIP
更新时间:2024-03-08 05:48:46
go golang pubsub broker golang-library
经纪人-最小的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) } 发布消息给经纪人 err := broker.Publish("/foo", "some payload") 取消订阅 err := sub.Cancel() 关闭经纪人 broker.Shutdown() 主题 主题是
【文件预览】:
broker-main
----go.mod(150B)
----go.sum(1KB)
----subscriber.go(608B)
----broker_test.go(2KB)
----broker.go(5KB)
----LICENSE(11KB)
----README.md(2KB)