Advertisement
Guest User

broken fsm on req-rep

a guest
Sep 4th, 2022
53
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Python 0.60 KB | None | 0 0
  1. import click
  2. import zmq
  3.  
  4. context = zmq.Context()
  5.  
  6.  
  7. @click.group()
  8. def cli():
  9.     pass
  10.  
  11.  
  12. @cli.command()
  13. def server():
  14.     socket = context.socket(zmq.REP)
  15.     socket.bind("tcp://*:5555")
  16.  
  17.     while True:
  18.         msg = socket.recv()
  19.         print(msg)
  20.         socket.send(b"A" + msg[1:])
  21.  
  22.  
  23. @cli.command()
  24. def client():
  25.     socket = context.socket(zmq.REQ)
  26.     socket.connect("tcp://127.0.0.1:5556")
  27.  
  28.     cnt = 0
  29.     while True:
  30.         socket.send(b"D" + str(cnt).encode())
  31.         msg = socket.recv()
  32.         print(msg)
  33.         cnt += 1
  34.  
  35.  
  36. if __name__ == "__main__":
  37.     cli()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement