您的位置：首页 > 编程语言 > Python开发

Python进程间通信，使用multiprocessing.connection的Listener和Client实现

2017-11-21 11:46 781 查看

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

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签：

相关文章推荐

新的分享

章节导航