Python进程专题8：分布集群的消息传递

上一篇文章&＃xff1a;Python进程专题7&＃xff1a;托管对象
下一篇文章&＃xff1a;Python进程专题9&＃xff1a;关于进程的实用工具函数

使用multiprocessing模块的程序不仅可以于运行在同一计算机的其它程序进行消息传递&＃xff0c;还可以于位于不到计算机的远程系统程序进行消息传递。其中的multiprocessing.connection子模块包含该目的的函数和类&＃xff1a;

connections.Client(address,family,authenticate,authkey)

连接到另一个进程&＃xff0c;此进程必须已经正在监听地址address。
address:代表网络地址的元组(hostname,port),或者代表UNIX域套接字的文件名&＃xff0c;或者代表
r&＃39;\\servername\pipe\pipename&＃39;形式的字符串&＃xff0c;代表远程系统servername(本地计算机的servername为&＃39;.&＃39;)上的一条Windows命名管道。family:表示地址格式的字符串。一般是&＃39;AF_INET&＃39;、&＃39;AF_UNIX&＃39;、或&＃39;AF_PIPE&＃39;.如果省略此参数&＃xff0c;将从address的格式退出它的值。backlog:是一个整数&＃xff0c;当address参数指定了一个网络连接时&＃xff0c;对应于传递给套接字的listen()方法的值&＃xff0c;backlog默认为1。authenticate:一个布尔标志&＃xff0c;指定是否使用摘要身份验证。
authkey:包含身份验证密钥的字符串&＃xff0c;如果忽略此参数&＃xff0c;将使用current_process().authkey的值。此函数的返回值是Connection对象&＃xff0c;管道中有讲过。

connections.Listener(address,family,backlog,authenticate,authkey)

实现了一台服务器&＃xff0c;用于侦听和处理Client()函数发送的连接。
如果省略address参数&＃xff0c;将选择默认地址&＃xff0c;如果同时省略address和family两个参数&＃xff0c;将选择本地系统上速度最快的可用通信模式。

Listener实例listener支持一下方法和属性。

实例&＃xff1a;服务器端与客户端发送消息

• 服务器端代码&＃xff1a;

#服务器端&＃xff0c;负责监听客户端并实现简单的远程操作
from multiprocessing.connection import Listener
serv&＃61;Listener((&＃39;&＃39;,11111),authkey&＃61;&＃39;123456&＃39;.encode())
while True:conn&＃61;serv.accept()while True:try:x,y&＃61;conn.recv()except EOFError:print("出错了")breakresult&＃61;x&＃43;yconn.send(result)conn.close()


• 客户端代码&＃xff1a;

#客户端&＃xff0c;向服务器端发送消息
from multiprocessing.connection import Client
conn&＃61;Client((&＃39;localhost&＃39;,11111),authkey&＃61;&＃39;123456&＃39;.encode())
conn.send((5,6))
r&＃61;conn.recv()
print(r)conn.send(("mark","帅哥"))
r&＃61;conn.recv()
print(r)
conn.close()

• 客户端打印结果&＃xff1a;

11
mark帅哥