经纪人:琐碎的消息经纪人 源码

经纪人-最小的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