本来是想做个翻译的,奈何英文太差,还是逐个的对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~
(未完待续)