pyzmq_request_reply_hello_world_client_server.py

1# Pair of scripts for a simple Request-Reply pattern. 
2# Usually, these would be in two separate files.
3
4import zmq
5import time
6
7# --- SERVER ---
8def run_server():
9    context = zmq.Context()
10    socket = context.socket(zmq.REP)
11    socket.bind("tcp://*:5555")
12
13    while True:
14        #  Wait for next request from client
15        message = socket.recv()
16        print(f"Received request: {message}")
17
18        #  Do some 'work'
19        time.sleep(1)
20
21        #  Send reply back to client
22        socket.send(b"World")
23
24# --- CLIENT ---
25def run_client():
26    context = zmq.Context()
27
28    #  Socket to talk to server
29    print("Connecting to hello world server…")
30    socket = context.socket(zmq.REQ)
31    socket.connect("tcp://localhost:5555")
32
33    #  Do 10 requests, waiting each time for a response
34    for request in range(10):
35        print(f"Sending request {request} …")
36        socket.send(b"Hello")
37
38        #  Get the reply.
39        message = socket.recv()
40        print(f"Received reply {request} [ {message} ]")
41
42if __name__ == "__main__":
43    # To run this example, you would typically run the server in one 
44    # terminal and the client in another.
45    print("Example contains both Server and Client logic.")