Python实现跨进程通信：基于multiprocessing.connection的完整示例

程一诺

发布时间：2026-10-15| 6人浏览过

原创

本文介绍如何使用Python的multiprocessing模块实现跨进程通信。通过封装Server端和Client端代码，展示基于监听器和客户端连接的交互流程。示例包含完整的接收、发送及异常处理逻辑，适用于字符串、数字等多种数据类型的跨文件通信场景。

前言

在开发过程中，经常需要处理跨进程的数据交换需求。本文将提供一套简洁的跨进程通信实现方案，该方案由服务端和客户端两部分组成，旨在帮助开发者快速建立进程间的数据通道。

一、server端

import multiprocessing
import time

def do_socket(conn, addr, ):
    try:

        while True:
            if conn.poll(1) == False:
                time.sleep(0.5)
                continue
            data = conn.recv()  # 等待接受数据
            conn.send('sucess')
            # ***********************
            # 要执行的程序写在这里
            # ***********************
            print(data)

    except Exception as e:
        print('Socket Error', e)

    finally:
        try:
            conn.close()
            print('Connection close.', addr)
        except:
            print('close except')


def run_server(host, port):
    from multiprocessing.connection import Listener
    server_sock = Listener((host, port))

    print("Sever running...", host, port)

    pool = multiprocessing.Pool(10)
    while True:
        # 接受一个新连接:

        conn = server_sock.accept()
        addr = server_sock.last_accepted
        print('Accept new connection', addr)

        # 创建进程来处理TCP连接:
        pool.apply_async(func=do_socket, args=(conn, addr,))


if __name__ == '__main__':
    server_host = '127.0.0.1'
    server_port = 8000
    run_server(server_host, server_port)

二、client端

import time

from multiprocessing.connection import Client

client = Client(('127.0.0.1', 8000))

while True:
    data = 'send data'
    client.send(data)
    data = client.recv()  # 等待接受数据
    print(data)
    time.sleep(1)

上述示例仅展示了client端的实现逻辑，实际应用中通信的数据类型具有多样性，支持字符串、数值、图像等多种格式的数据传输。