NATS云消息系統(tǒng)

nats 是一個(gè)輕量級(jí)的云消息系統(tǒng)，目前提供了使用 Go 開(kāi)發(fā)的服務(wù)器版本以及多種編程語(yǔ)言的客戶端開(kāi)發(fā)包。 NATS是一個(gè)基于事件驅(qū)動(dòng)的、基于發(fā)布和訂閱模型的輕量級(jí)消息系統(tǒng)。它基于EventMachine實(shí)現(xiàn)。

吞吐量比較：

基本使用：

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