Pythonプロセス間通信はmultiprocessing.connectionのListenerとClientで実現

2091 ワード

Aプロセスコード
#encoding=utf-8__author__ = 'outofmemory.cn'from multiprocessing.connection import Listener address = ('localhost', 6000) # family is deduced to be 'AF_INET'listener = Listener(address, authkey='secret password')while True:     conn = listener.accept()    print 'connection accepted from', listener.last_accepted     data = conn.recv()    print data    try:         result = 'haha'        conn.send_bytes('get %s'%(result,))    except Exception,e:        print e    finally:         conn.close() listener.close()
 
Bプロセスコード
#encoding=utf-8
__author__ = 'outofmemory.cn' from multiprocessing.connection import Client address = ('localhost', 6000) for x in range(0,10): conn = Client(address, authkey='secret password') conn.send('         ')  print conn.recv_bytes() conn.close() 

 
参照先:http://outofmemory.cn/code-snippet/1715/python-usage-Connection-achieve-duojincheng-between-correspond