现在的位置: 首页 > 综合 > 正文

cloud foundry的消息中间件nats用法

2014年07月03日 ⁄ 综合 ⁄ 共 527字 ⁄ 字号 评论关闭

因为要阅读cloud foundry的源码,而作为cloud foundry各个部分之间进行通信的消息中间件,就算是不了解它的实现,也要了解一些它基本的用法的。。。


其实主要用到的方法也就那么几个。。。

首先是subscribe方法。。例如

NATS.subscribe('foo') { |msg|
    puts msg
}

代码其实一看也就懂了,订阅foo的消息,如果收到消息的话那么就将其输出。。。


有subscribe方法,那么肯定就的要有publish方法才行吧。。。。

NATS.publish('foo', 'hello world')

嗯,这个也是一看就懂的。。。


另外NATS还有比较有意思的功能(request),可以实现两个节点之间的通信。。。。

NATS.subscribe('help') { |msg, reply|
    NATS.publish(reply, 'hello, world')
}
NATS.request('help') { |response|
    puts response
}

代码也很容易看懂吧,订阅了help的节点,可以通过reply,发送信息回刚刚发送信息的节点。。。


好了,我觉得知道这几个方法应该也就差不多了。。下一周就可以分析cloud foundry的各个节点了。。。

抱歉!评论已关闭.