因为要阅读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的各个节点了。。。