python實現(xiàn)跨進程(跨py文件)通信示例

更新時間：2022年03月03日 08:30:05 作者：JulyLi2019

本文主要介紹了python實現(xiàn)跨進程(跨py文件)通信示例，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下

前言

項目中總會遇到數(shù)據(jù)需要跨進程通信的問題，今天就給大家?guī)硪惶缀唵蔚目邕M程通信代碼。代碼分為服務(wù)端與客戶端兩部分。

一、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()  # 等待接受數(shù)據(jù)
            conn.send('sucess')
            # ***********************
            # 要執(zhí)行的程序?qū)懺谶@里
            # ***********************
            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)

        # 創(chuàng)建進程來處理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()  # 等待接受數(shù)據(jù)
    print(data)
    time.sleep(1)

這里只是給了client端的示例代碼，實際通信的數(shù)據(jù)類型可以是多樣的（字符串、數(shù)字、圖片等）