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プロセスコード
参照先:http://outofmemory.cn/code-snippet/1715/python-usage-Connection-achieve-duojincheng-between-correspond
#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