Python使用Manager对象实现不同机器上的进程跨网络传输数据

本文主要演示不同机器上的进程之间如何通过网络进行数据交换。

(1)首先编写程序文件multiprocessing_server.py，启动服务器进程，创建可共享的队列对象。

from multiprocessing.managers import BaseManager
from queue import Queue

q = Queue()
class QueueManager(BaseManager):
    pass
QueueManager.register('get_queue', callable=lambda:q)

m = QueueManager(address=('', 30030), authkey=b'dongfuguo')
s = m.get_server()
s.serve_forever()

(2)然后编写程序文件multiprocessing_client1.py，连接服务器进程，并往共享的队列中存入一些数据。

from multiprocessing.managers import BaseManager

class QueueManager(BaseManager):
    pass
QueueManager.register('get_queue')
#假设服务器的IP地址为10.2.1.2
m = QueueManager(address=('10.2.1.2', 30030), authkey=b'dongfuguo')
m.connect()
q = m.get_queue()
for i in range(3):
    q.put(i)

(3)最后编写程序文件multiprocessing_client2.py，连接服务器进程，从共享的队列对象中读取数据并输出显示。

from multiprocessing.managers import BaseManager

class QueueManager(BaseManager):
    pass
QueueManager.register('get_queue')
m = QueueManager(address=('10.2.1.2', 30030), authkey=b'dongfuguo')
m.connect()
q = m.get_queue()
for i in range(3):
    print(q.get())