python与zmq系列(3)
2015-12-18 15:32
691 查看
本篇博客将介绍zmq应答模式,所谓应答模式,就是一问一答,规则有这么几条
1、 必须先提问,后回答
2、 对于一个提问,只能回答一次
3、 在没有收到回答前不能再次提问
上代码,服务端:
客户端:
为了满足条件1,所以,客户端必须先接收问题,客户端总是必须先提问,客户端提问后,必须等待回答,在收到回答前如果又发出提问,那么会报错。
zmq.REP是应答方,zmq.REQ是提问方,显然,我们可以有多个提问方,但只能有一个提问方,这就好比正在学生正在上课,只能有一个老师来回答问题,可以有多个学生提问,老师只能一个问题一个问题的来回答,所以喽,必须是学生先提问,老师来回答,然后回答下一个学生的提问。
自问自答环节:
问题1: 应答方和提问方谁先启动呢?(服务端和客户端谁先启动呢?)
答: 谁先启动都可以,和pub/sub模式一样
问题2: 如果服务端断掉或者客户端断掉会产生怎样的影响?
答: 如果是客户端断掉,对服务端没有任何影响,如果客户端随后又重新启动,那么两方继续一问一答,但是如果是服务端断掉了,就可能会产生一些问题,这要看服务端是在什么情况下断掉的,如果服务端收是在回答完问题后断掉的,那么没影响,重启服务端后,双发继续一问一答,但如果服务端是在收到问题后断掉了,还没来得及回答问题,这就有问题了,那个提问的客户端迟迟得不到答案,就会一直等待答案,因此不会再发送新的提问,服务端重启后,客户端迟迟不发问题,所以也就一直等待提问。
问题3: 看代码,服务端根本就没去区分提问者是谁,如果有两个提问题的人,如何保证服务端的答案准确的发给那个提问的客户端呢?
答: 关于这一点,大家不必担心,zmq的内部机制已经做了保证,提问者必然只收到属于自己的答案,我们不必去操心zmq是怎么做到的,你只需关于业务本身即可。
现在,我们把服务端代码做修改
客户端1:
实际的运行结果如图:
不难看出,每个客户端都收到了只属于自己的答案
1、 必须先提问,后回答
2、 对于一个提问,只能回答一次
3、 在没有收到回答前不能再次提问
上代码,服务端:
#coding=utf-8 ''' Created on 2015-10-10 回复请求 @author: kwsy2015 ''' import zmq import time context = zmq.Context() socket = context.socket(zmq.REP) socket.bind('tcp://*:5555') while True: message = socket.recv() print 'received request: ' ,message time.sleep(1) socket.send('World')
客户端:
#coding=utf-8 ''' Created on 2015-10-10 你无法连续向服务器发送数据,必须发送一次,接收一次 REQ和REP模式中,客户端必须先发起请求 @author: kwsy2015 ''' import zmq context = zmq.Context() print 'connect to hello world server' socket = context.socket(zmq.REQ) socket.connect('tcp://localhost:5555') for request in range(1,10): print 'send ',request,'...' socket.send('hello') message = socket.recv() print 'received reply ',request,'[',message,']'
为了满足条件1,所以,客户端必须先接收问题,客户端总是必须先提问,客户端提问后,必须等待回答,在收到回答前如果又发出提问,那么会报错。
zmq.REP是应答方,zmq.REQ是提问方,显然,我们可以有多个提问方,但只能有一个提问方,这就好比正在学生正在上课,只能有一个老师来回答问题,可以有多个学生提问,老师只能一个问题一个问题的来回答,所以喽,必须是学生先提问,老师来回答,然后回答下一个学生的提问。
自问自答环节:
问题1: 应答方和提问方谁先启动呢?(服务端和客户端谁先启动呢?)
答: 谁先启动都可以,和pub/sub模式一样
问题2: 如果服务端断掉或者客户端断掉会产生怎样的影响?
答: 如果是客户端断掉,对服务端没有任何影响,如果客户端随后又重新启动,那么两方继续一问一答,但是如果是服务端断掉了,就可能会产生一些问题,这要看服务端是在什么情况下断掉的,如果服务端收是在回答完问题后断掉的,那么没影响,重启服务端后,双发继续一问一答,但如果服务端是在收到问题后断掉了,还没来得及回答问题,这就有问题了,那个提问的客户端迟迟得不到答案,就会一直等待答案,因此不会再发送新的提问,服务端重启后,客户端迟迟不发问题,所以也就一直等待提问。
问题3: 看代码,服务端根本就没去区分提问者是谁,如果有两个提问题的人,如何保证服务端的答案准确的发给那个提问的客户端呢?
答: 关于这一点,大家不必担心,zmq的内部机制已经做了保证,提问者必然只收到属于自己的答案,我们不必去操心zmq是怎么做到的,你只需关于业务本身即可。
现在,我们把服务端代码做修改
#coding=utf-8 ''' Created on 2015-10-15 @author: kwsy2015 ''' import zmq import time context = zmq.Context() socket = context.socket(zmq.REP) socket.bind('tcp://*:5555') while True: message = socket.recv() print 'received request: ' ,message time.sleep(1) if message == 'hello': socket.send('World') else: socket.send('success')写两个客户端
客户端1:
#coding=utf-8 ''' Created on 2015-10-15 @author: kwsy2015 ''' import zmq context = zmq.Context() print 'connect to hello world server' socket = context.socket(zmq.REQ) socket.connect('tcp://localhost:5555') for request in range(1,10): print 'send ',request,'...' socket.send('hello') message = socket.recv() print 'received reply ',request,'[',message,']'客户端2:
#coding=utf-8 ''' Created on 2015-10-15 @author: kwsy2015 ''' import zmq context = zmq.Context() print 'connect to hello world server' socket = context.socket(zmq.REQ) socket.connect('tcp://localhost:5555') for request in range(1,10): print 'send ',request,'...' socket.send('ok') message = socket.recv() print 'received reply ',request,'[',message,']'
实际的运行结果如图:
不难看出,每个客户端都收到了只属于自己的答案
相关文章推荐
- python与zmq系列(2)
- 用python调用R做数据分析-准备工作
- python与zmq系列(1)
- 使用python操作solr
- python多线程
- python基础类型
- ROS_12.18_BaxterAPI_python
- python文件夹复制
- Python类的地址
- Learning Python(4)--错误处理
- [Python] 分布式新浪爬虫的实现
- 使用Python编写简单的端口扫描器的实例分享
- 使用python爬取豆瓣电影图片(-)
- 每天学点Python之布尔类型
- python怎么生成EXE(python3以上版本)
- python代码追踪
- python通过pyserial读写串口--2013-06-02
- Python元组
- python初学―-实现excel里面读数据进行排序
- Python(2.5)语言小结