【文件属性】：
文件名称：zmqpubsub:在zeromq之上实现友好的pubsub实现
文件大小：8KB
文件格式：ZIP
更新时间：2021-05-08 05:25:15
Go
zmqpubsub
zmqpubsub是在ZeroMQ之上的一个简单的Go pubsub实现。
它抽象了底层的ZeroMQ机械，以为发布-订阅消息传递模式提供Go友好的API。
安装
go get -tags zmq_3_x github.com/hpcloud/zmqpubsub
用法
经纪人
首先设置一个经纪人：
var Broker zmqpubsub. Broker
func init () {
Broker . PubAddr = "tcp://127.0.0.1:4000"
Broker . SubAddr = "tcp://127.0.0.1:4001"
Broker . BufferSize = 100
}
func main () {
...
Broker . MustRun ()
}
代理指定发布者/订阅者将连接到的地址或从中连接的地址。
【文件预览】：
zmqpubsub-master
----example()
--------pubsub.go(1KB)
----message.go(469B)
----publisher.go(686B)
----subscription.go(2KB)
----context.go(630B)
----broker_test.go(1KB)
----deps.json(441B)
----forwarder.go(1011B)
----socket.go(1KB)
----README.md(1KB)
----broker.go(1KB)
----LICENSE.txt(1KB)