论坛 › Saltstack › 了解saltstack的通信协议zeromq(二)

skypaladin 发表于 2018-8-1 10:39:58

了解saltstack的通信协议zeromq(二)

import sys　　
import time
　　
import zmq
　　

　　
context = zmq.Context()
　　
# Socket to receive messages on
　　
receiver = context.socket(zmq.PULL)
　　
receiver.bind("tcp://*:5558")
　　

　　
# Wait for start of batch
　　
s = receiver.recv()
　　
sum = 0
　　
flag = 0
　　
# Start our clock now
　　
tstart = time.time()
　　
while True:
　　
      a_str = receiver.recv_string()
　　
      num = int(a_str)
　　
      sum += num
　　
      if a_str == '0':
　　
                flag += 1
　　
      if flag == 10:
　　
                break
　　

　　
tend = time.time()
　　
tdiff = tend - tstart
　　
total_msec = tdiff * 1000
　　
print "Total elapsed time: %d msec" % total_msec

查看完整版本: 了解saltstack的通信协议zeromq(二)