利用multiprocessing.connection模块实现进程间的socket通信

使用multiprocessing.connection模块可以实现进程间的socket通信，可以方便地在不同进程之间传递数据。

multiprocessing.connection模块提供了一种在进程之间传递数据的机制。它使用了底层的套接字（socket）技术，可以用来实现进程间的通信。具体来说，它通过创建一个服务器对象（Server）和一个客户端对象（Client）来实现进程间的通信。

以下是使用multiprocessing.connection模块实现进程间socket通信的示例代码：

# 服务器端代码
from multiprocessing.connection import Listener

address = ('localhost', 6000)  # 服务器地址和端口
listener = Listener(address)  # 创建监听器对象

conn = listener.accept()  # 等待客户端连接
print('连接成功')

while True:
    data = conn.recv()  # 接收客户端发送的数据
    print('接收到数据:', data)
    
    if data == 'exit':
        break
    
    # 处理接收到的数据，这里简单地将接收到的数据转为大写
    processed_data = data.upper()
    
    conn.send(processed_data)  # 将处理后的数据发送给客户端

conn.close()  # 关闭连接
listener.close()  # 关闭监听器


# 客户端代码
from multiprocessing.connection import Client

address = ('localhost', 6000)  # 服务器地址和端口
conn = Client(address)  # 创建客户端对象

while True:
    data = input('请输入要发送的数据（输入\'exit\'退出）: ')
    conn.send(data)  # 发送数据给服务器
    
    if data == 'exit':
        break
    
    processed_data = conn.recv()  # 接收服务器返回的处理后的数据
    print('接收到处理后的数据:', processed_data)
    
conn.close()  # 关闭连接

上述代码的运行过程如下：

1. 在服务器端代码中，创建了一个监听器对象（Listener），指定服务器的地址和端口。然后使用监听器对象的accept()方法等待客户端连接。一旦客户端连接成功，就会打印出连接成功的消息。

2. 在服务器端的主循环中，使用连接对象（conn）的recv()方法接收客户端发送的数据。然后将接收到的数据转为大写（这里只是个简单的示例代码，实际的处理逻辑可以根据需求定制），并使用连接对象的send()方法将处理后的数据返回给客户端。

3. 当服务器接收到的数据为'exit'时，跳出循环，关闭连接和监听器对象。

4. 在客户端代码中，创建了一个客户端对象（Client），指定服务器的地址和端口。通过输入来发送数据给服务器，输入'exit'退出。

5. 使用连接对象的recv()方法接收服务器返回的处理后的数据，并打印出来。

6. 当输入的数据为'exit'时，跳出循环，关闭连接。

通过运行上述代码，就可以实现服务器与客户端之间的进程间socket通信。其中，服务器代码监听在localhost的6000端口上，客户端代码连接到该地址和端口。当客户端发送数据给服务器时，服务器将接收到的数据转为大写，并返回给客户端。