zeromq中文教程

立即下载 作者: 记忆短浅♡思念不变
上传时间: 2024-09-30
关键词: 代码 thon 模式 Py send 1. importzmq 2.3. zmq.Context()4 c.socket
大小 1.4 MB
描述
zeromq中文教程
简介：
?MQ (ZeroMQ, 0MQ, zmq), 这一堆表达方式看哪个顺眼就选哪个吧，都指的咱要讲的这玩
意儿。
它出现的目的只有一个：更高效的利用机器。好吧，这是我个人的看法，官方说法是：让任
何地方、任何代码可以互联。
应该很明白吧，如果非要做联想类比，好吧，可以想成经典的 C/S 模型，这个东东封装了
所有底层细节，开发人员只要关注代码逻辑就可以了。 (虽然联想成 C/S，但可不仅仅如此
哦，具体往下看 )。
它的通信协议是 AMQP, 具体的 Google 之吧，在自由市场里， 它有一个对头 RabbitMQ ，关
于那只 "兔子 "，那又是另外一个故事了。
C/S 模式：
server
Python 代码
1. import zmq
2.
3. c = zmq.Context()
4. s = c.socket(zmq.REP)
5. #s.bind('tcp://127.0.0.1:10001')
6. s.bind( 'ipc:///tmp/zmq' )
7.
8. while True:
9. msg = s.recv_pyobj()
10. s.send_pyobj(msg)
11. s.close()
client
Python 代码
1. import zmq
2.
3. c = zmq.Context()
4. s = c.socket(zmq.REQ)
5. #s.connect('tcp://127.0.0.1:10001')
6. s.connect( 'ipc:///tmp/zmq' )
7. s.send_pyobj( 'hello' )
8. msg = s.recv_pyobj()
9. print msg
注意：
这个经典的模式在 zeroMQ中是应答状态的，不能同时 send多个数据，只能
ababab这样。还有这里 send_pyobj 是 pyzmq特有的，用以传递 python 的对象，
通用的还是如同 socket 的 send~
pub/sub 模式：
发布端 (pub)
Python 代码
1. import
目录
代码/thon/模式/Py/send/1./importzmq/2.3./zmq.Context()4/c.socket/ 代码/thon/模式/Py/send/1./importzmq/2.3./zmq.Context()4/c.socket/