eventlet/examples/zmq_simple.py

   1 from eventlet.green import zmq
   2 import eventlet
   3
   4 CTX = zmq.Context(1)
   5
   6
   7 def bob_client(ctx, count):
   8     print("STARTING BOB")
   9     bob = zmq.Socket(CTX, zmq.REQ)
  10     bob.connect("ipc:///tmp/test")
  11
  12     for i in range(0, count):
  13         print("BOB SENDING")
  14         bob.send("HI")
  15         print("BOB GOT:", bob.recv())
  16
  17
  18 def alice_server(ctx, count):
  19     print("STARTING ALICE")
  20     alice = zmq.Socket(CTX, zmq.REP)
  21     alice.bind("ipc:///tmp/test")
  22
  23     print("ALICE READY")
  24     for i in range(0, count):
  25         print("ALICE GOT:", alice.recv())
  26         print("ALIC SENDING")
  27         alice.send("HI BACK")
  28
  29 alice = eventlet.spawn(alice_server, CTX, 10)
  30 bob = eventlet.spawn(bob_client, CTX, 10)
  31
  32 bob.wait()
  33 alice.wait()