文章目录

• 前言
• 一、server端
• 二、client端
• 三、运行效果
• 总结

前言

项目中总会遇到数据需要跨进程通信的问题，今天就给大家带来一套简单的跨进程通信代码。代码分为服务端与客户端两部分。

一、server端

import multiprocessing
import timedef do_socket(conn, addr, ):try:while True:if conn.poll(1) == False:time.sleep(0.5)continuedata = 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 Listenerserver_sock = Listener((host, port))print("Sever running...", host, port)pool = multiprocessing.Pool(10)while True:# 接受一个新连接:conn = server_sock.accept()addr = server_sock.last_acceptedprint('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 = 8000run_server(server_host, server_port)

二、client端

import timefrom multiprocessing.connection import Clientclient = 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端

总结

本文简单给大家提供了一套简单封装的跨进程通信代码，方便大家快速上手实现跨进程通信，有需要的伙伴可以根据自己的需求调整代码。
如果阅读本文对你有用，欢迎一键三连呀！！！
2022年3月1日14:26:42

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！