NATS 介绍
nats 是一个轻量级的云消息系统,目前提供了使用 Go 开发的服务器版本以及多种编程语言的客户端开发包。
NATS是一个基于事件驱动的、基于发布和订阅模型的轻量级消息系统。它基于EventMachine实现。
吞吐量比较:
基本使用:
require "nats/client" NATS.start do # Simple Subscriber NATS.subscribe('foo') { |msg| puts "Msg received : '#{msg}'" } # Simple Publisher NATS.publish('foo.bar.baz', 'Hello World!') # Unsubscribing sid = NATS.subscribe('bar') { |msg| puts "Msg received : '#{msg}'" } NATS.unsubscribe(sid) # Requests NATS.request('help') { |response| puts "Got a response: '#{response}'" } # Replies NATS.subscribe('help') { |msg, reply| NATS.publish(reply, "I'll help!") } # Stop using NATS.stop, exits EM loop if NATS.start started the loop NATS.stop end
NATS 官网
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。