zeroMQ初体验-1.简介及C/S模式_C/C++_编程开发_程序员俱乐部

中国优秀的程序员网站程序员频道CXYCLUB技术地图
热搜:
更多>>
 
您所在的位置: 程序员俱乐部 > 编程开发 > C/C++ > zeroMQ初体验-1.简介及C/S模式

zeroMQ初体验-1.简介及C/S模式

 2012/3/13 15:33:31  iyuan  程序员俱乐部  我要评论(0)
  • 摘要:本来是想做个翻译的,奈何英文太差,还是逐个的对zeroMQ各用法进行简析,文中代码主要来自pyzmq中的example,详细原文请自行参看这里,也不清楚有没有兄台做过类似工作,这里主要供自个儿学习备忘,如有谬误,欢迎指出~简介:?MQ(ZeroMQ,0MQ,zmq),这一堆表达方式看哪个顺眼就选哪个吧,都指的咱要讲的这玩意儿。它出现的目的只有一个:更高效的利用机器。好吧,这是我个人的看法,官方说法是:让任何地方、任何代码可以互联。应该很明白吧,如果非要做联想类比,好吧,可以想成经典的C/S模型
  • 标签:简介 模式
本来是想做个翻译的,奈何英文太差,还是逐个的对zeroMQ各用法进行简析,文中代码主要来自pyzmq中的example,详细原文请自行参看这里,也不清楚有没有兄台做过类似工作,这里主要供自个儿学习备忘,如有谬误,欢迎指出~

简介:
?MQ (ZeroMQ, 0MQ, zmq),这一堆表达方式看哪个顺眼就选哪个吧,都指的咱要讲的这玩意儿。
它出现的目的只有一个:更高效的利用机器。好吧,这是我个人的看法,官方说法是:让任何地方、任何代码可以互联。
应该很明白吧,如果非要做联想类比,好吧,可以想成经典的C/S模型,这个东东封装了所有底层细节,开发人员只要关注代码逻辑就可以了。(虽然联想成C/S,但可不仅仅如此哦,具体往下看)。
它的通信协议是AMQP,具体的Google之吧,在自由市场里,它有一个对头RabbitMQ,关于那只"兔子",那又是另外一个故事了。

C/S模式:



server
import zmq

c = zmq.Context()
s = c.socket(zmq.REP)
#s.bind('tcp://127.0.0.1:10001')
s.bind('ipc:///tmp/zmq')

while True:
    msg = s.recv_pyobj()
    s.send_pyobj(msg)
s.close()


client
import zmq

c = zmq.Context()
s = c.socket(zmq.REQ)
#s.connect('tcp://127.0.0.1:10001')
s.connect('ipc:///tmp/zmq')
s.send_pyobj('hello')
msg = s.recv_pyobj()
print msg


注意:
这个经典的模式在zeroMQ中是应答状态的,不能同时send多个数据,只能ababab这样。还有这里send_pyobj是pyzmq特有的,用以传递python的对象,通用的还是如同socket的send~

(未完待续)
发表评论
用户名: 匿名