python使用zeromq多进程简单交互

参考：https://learning-0mq-with-pyzmq.readthedocs.io/en/latest/pyzmq/multiprocess/multiprocess.html#
实现request_reply_processes.py

点击(此处)折叠或打开

1. import zmq
   
2. import time
   
3. import sys
   
4. from multiprocessing import Process
   
5. 
   
6. def server(port="5556"):
   
7.     context = zmq.Context()
   
8.     socket = context.socket(zmq.REP)
   
9.     socket.bind("tcp://*:%s" % port)
   
10.     print ("Running server on port: ", port)
    
11.     # serves only 5 request and dies
    
12.     for reqnum in range(5):
    
13.         # Wait for next request from client
    
14.         message = socket.recv()
    
15.         print ("Received request #%s: %s" % (reqnum, message))
    
16.         socket.send( ("World from %s" % port).encode("ascii") )
    
17.          
    
18. def client(ports=["5556"]):
    
19.     context = zmq.Context()
    
20.     print ("Connecting to server with ports %s" % ports)
    
21.     socket = context.socket(zmq.REQ)
    
22.     for port in ports:
    
23.         socket.connect ("tcp://localhost:%s" % port)
    
24.     for request in range (20):
    
25.         print ("Sending request ", request,"...")
    
26.         socket.send ("Hello".encode("ascii"))
    
27.         message = socket.recv()
    
28.         print ("Received reply ", request, "[", message, "]")
    
29.         time.sleep (1)
    
30. 
    
31. 
    
32. if __name__ == "__main__":
    
33.     # Now we can run a few servers
    
34.     server_ports = range(5550,5558,2)
    
35.     for server_port in server_ports:
    
36.         Process(target=server, args=(server_port,)).start()
    
37.         
    
38.     # Now we can connect a client to all these servers
    
39.     Process(target=client, args=(server_ports,)).start()

运行：
#python3 request_reply_processes.py