该
multiprocessing库提供包装套接字的侦听器和客户端,并允许您传递任意python对象。
您的服务器可以侦听接收python对象:
from multiprocessing.connection import Listeneraddress = ('localhost', 6000) # family is deduced to be 'AF_INET'listener = Listener(address, authkey='secret password')conn = listener.accept()print 'connection accepted from', listener.last_acceptedwhile True: msg = conn.recv() # do something with msg if msg == 'close': conn.close() breaklistener.close()您的客户端可以将命令作为对象发送:
from multiprocessing.connection import Clientaddress = ('localhost', 6000)conn = Client(address, authkey='secret password')conn.send('close')# can also send arbitrary objects:# conn.send(['a', 2.5, None, int, sum])conn.close()


