python实现跨进程(跨py文件)通信示例

Oralie ·
更新时间:2024-11-01
· 102 次阅读

目录

前言

一、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端的示例代码,实际通信的数据类型可以是多样的(字符串、数字、图片等)

三、运行效果

先运行server端,再运行client端。

server

client

总结

本文简单给大家提供了一套简单封装的跨进程通信代码,方便大家快速上手实现跨进程通信,有需要的伙伴可以根据自己的需求调整代码。

到此这篇关于python实现跨进程(跨py文件)通信示例的文章就介绍到这了,更多相关python 跨进程通信内容请搜索软件开发网以前的文章或继续浏览下面的相关文章希望大家以后多多支持软件开发网!



进程 示例 通信 Python

需要 登录 后方可回复, 如果你还没有账号请 注册新账号