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

LOCKLOSE 发表于 2018-8-1 10:39:07

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

import zmq　　
import time
　　
import sys
　　

　　
port = "5556"
　　
if len(sys.argv) > 1:
　　
      port =sys.argv
　　
      int(port)
　　

　　
context = zmq.Context()
　　
socket = context.socket(zmq.REP)
　　
socket.bind("tcp://*:%s" % port)
　　

　　
while True:
　　
      #Wait for next request from client
　　
      try:
　　
                message = socket.recv()
　　
                print "Received request: ", message
　　
                time.sleep (1)
　　
                socket.send("World from %s:%s" % ('192.168.79.49',port))
　　
      except KeyboardInterrupt:
　　
                break

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