python zeromq 使用

Reference: http://blog.csdn.net/kwsy2008/article/details/49464663

本篇博客将介绍zmq应答模式，所谓应答模式，就是一问一答，规则有这么几条

        1、 必须先提问，后回答

        2、 对于一个提问，只能回答一次

        3、 在没有收到回答前不能再次提问

        上代码，服务端：

[python] view plain copy
 
  1. #coding=utf-8  
  2. ''''' 
  3. Created on 2015-10-10 
  4. 回复请求 
  5. @author: kwsy2015 
  6. '''  
  7. import zmq  
  8. import time  
  9.   
  10. context = zmq.Context()  
  11. socket = context.socket(zmq.REP)  
  12. socket.bind('tcp://*:5555')  
  13.   
  14. while True:  
  15.     message = socket.recv()  
  16.     print 'received request: ' ,message  
  17.       
  18.     time.sleep(1)  
  19.     socket.send('World')  


        客户端：

[python] view plain copy
 
  1. #coding=utf-8  
  2. ''''' 
  3. Created on 2015-10-10 
  4. 你无法连续向服务器发送数据，必须发送一次，接收一次 
  5. REQ和REP模式中，客户端必须先发起请求 
  6. @author: kwsy2015 
  7. '''  
  8. import zmq  
  9.   
  10. context = zmq.Context()  
  11. print 'connect to hello world server'  
  12. socket =  context.socket(zmq.REQ)  
  13. socket.connect('tcp://localhost:5555')  
  14.   
  15. for request in range(1,10):  
  16.     print 'send ',request,'...'  
  17.     socket.send('hello')  
  18.     message = socket.recv()  
  19.     print 'received reply ',request,'[',message,']'  


        为了满足条件1，所以，客户端必须先接收问题，客户端总是必须先提问，客户端提问后，必须等待回答，在收到回答前如果又发出提问，那么会报错。

        zmq.REP是应答方，zmq.REQ是提问方，显然，我们可以有多个提问方，但只能有一个提问方，这就好比正在学生正在上课，只能有一个老师来回答问题，可以有多个学生提问，老师只能一个问题一个问题的来回答，所以喽，必须是学生先提问，老师来回答，然后回答下一个学生的提问。

       自问自答环节：

       问题1： 应答方和提问方谁先启动呢？（服务端和客户端谁先启动呢？）

            答： 谁先启动都可以，和pub/sub模式一样

       问题2： 如果服务端断掉或者客户端断掉会产生怎样的影响？

            答：  如果是客户端断掉，对服务端没有任何影响，如果客户端随后又重新启动，那么两方继续一问一答，但是如果是服务端断掉了，就可能会产生一些问题，这要看服务端是在什么情况下断掉的，如果服务端收是在回答完问题后断掉的，那么没影响，重启服务端后，双发继续一问一答，但如果服务端是在收到问题后断掉了，还没来得及回答问题，这就有问题了，那个提问的客户端迟迟得不到答案，就会一直等待答案，因此不会再发送新的提问，服务端重启后，客户端迟迟不发问题，所以也就一直等待提问。

       问题3： 看代码，服务端根本就没去区分提问者是谁，如果有两个提问题的人，如何保证服务端的答案准确的发给那个提问的客户端呢？

            答：  关于这一点，大家不必担心，zmq的内部机制已经做了保证，提问者必然只收到属于自己的答案，我们不必去操心zmq是怎么做到的，你只需关于业务本身即可。

             现在，我们把服务端代码做修改

      

[python] view plain copy
 
  1. #coding=utf-8  
  2. ''''' 
  3. Created on 2015-10-15 
  4.  
  5. @author: kwsy2015 
  6. '''  
  7. import zmq  
  8. import time  
  9.   
  10. context = zmq.Context()  
  11. socket = context.socket(zmq.REP)  
  12. socket.bind('tcp://*:5555')  
  13.   
  14. while True:  
  15.     message = socket.recv()  
  16.     print 'received request: ' ,message  
  17.     time.sleep(1)  
  18.     if message == 'hello':  
  19.         socket.send('World')  
  20.     else:  
  21.         socket.send('success')  

           写两个客户端

           客户端1：

[python] view plain copy
 
  1. #coding=utf-8  
  2. ''''' 
  3. Created on 2015-10-15 
  4.  
  5. @author: kwsy2015 
  6. '''  
  7. import zmq  
  8.   
  9. context = zmq.Context()  
  10. print 'connect to hello world server'  
  11. socket =  context.socket(zmq.REQ)  
  12. socket.connect('tcp://localhost:5555')  
  13.   
  14. for request in range(1,10):  
  15.     print 'send ',request,'...'  
  16.     socket.send('hello')  
  17.     message = socket.recv()  
  18.     print 'received reply ',request,'[',message,']'  

            客户端2：

[python] view plain copy
 
  1. #coding=utf-8  
  2. ''''' 
  3. Created on 2015-10-15 
  4.  
  5. @author: kwsy2015 
  6. '''  
  7. import zmq  
  8.   
  9. context = zmq.Context()  
  10. print 'connect to hello world server'  
  11. socket =  context.socket(zmq.REQ)  
  12. socket.connect('tcp://localhost:5555')  
  13.   
  14. for request in range(1,10):  
  15.     print 'send ',request,'...'  
  16.     socket.send('ok')  
  17.     message = socket.recv()  
  18.     print 'received reply ',request,'[',message,']'  


          实际的运行结果如图：

             不难看出，每个客户端都收到了只属于自己的答案

【推广】 免费学中医，健康全家人
原文地址：https://www.cnblogs.com/skying555/p/8118770.html