guillaumevincent · January 15, 2017 11:12 · ADanayi · Dec 24, 2018 · Jackiexiao · May 10, 2021
diff --git a/output.txt b/output.txt
 $ python push.py 
 message n°0
 message n°1
 message n°2
 message n°3
 message n°4
 message n°5
 message n°6
 message n°7
 message n°8
 message n°9


 python pull.py 
 Received message n°0
 Received message n°1
 Received message n°4
 Received message n°7

 python pull.py
 Received message n°2
 Received message n°5
 Received message n°8

 Lost message 3,6 and 9



diff --git a/pull.py b/pull.py
 import zmq

 context = zmq.Context()

 socket = context.socket(zmq.PULL)
 socket.connect("tcp://127.0.0.1:5557")

 while True:
    print("Received %s" % socket.recv_string())
diff --git a/push.py b/push.py
 import time
 import zmq

 context = zmq.Context()
 socket = context.socket(zmq.PUSH)
 socket.bind("tcp://127.0.0.1:5557")

 for i in range(10):
    message = "message n°%d" % i
    print(message)
    socket.send_string(message)
    time.sleep(1)
	import zmq

	context = zmq.Context()

	socket = context.socket(zmq.PULL)
	socket.connect("tcp://127.0.0.1:5557")

	while True:
	print("Received %s" % socket.recv_string())
	import time
	import zmq

	context = zmq.Context()
	socket = context.socket(zmq.PUSH)
	socket.bind("tcp://127.0.0.1:5557")

	for i in range(10):
	message = "message n°%d" % i
	print(message)
	socket.send_string(message)
	time.sleep(1)