文件名称：zmqpubsub:在zeromq之上实现友好的pubsub实现
文件大小：8KB
文件格式：ZIP
更新时间：2024-05-27 23:11:55
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)