0

0

如何使用 Python Socket 在客户端与服务器间可靠传输图像

碧海醫心

碧海醫心

发布时间:2026-03-16 15:00:30

|

754人浏览过

|

来源于php中文网

原创

如何使用 Python Socket 在客户端与服务器间可靠传输图像

本文详解基于 tcp socket 的图像传输方案,通过固定长度头部传递图像尺寸,确保客户端完整接收二进制数据,并使用 pil 正确解析显示,彻底解决因 recv() 不保证一次性收全导致的图像截断问题。

本文详解基于 tcp socket 的图像传输方案,通过固定长度头部传递图像尺寸,确保客户端完整接收二进制数据,并使用 pil 正确解析显示,彻底解决因 recv() 不保证一次性收全导致的图像截断问题。

在 Python 的 Socket 编程中,直接调用 socket.recv(n) 并不能保证一次性接收满 n 字节——它可能返回 1~n 之间的任意字节数(甚至 0,表示连接关闭)。这正是原问题中图像损坏的根本原因:服务端发送了完整的 JPEG 数据,但客户端未做循环读取,仅调用一次 recv(4) 获取长度头、再调用一次 recv(taille_image),极大概率只收到部分图像数据,导致 BytesIO 初始化失败或 PIL.Image.open() 报错(如 OSError: broken data stream 或 cannot identify image file)。

✅ 正确做法:使用 makefile() 实现阻塞式精确读取

Python 的 socket.makefile() 方法可将 socket 封装为类文件对象,支持语义明确的 .read(n) 操作:它会持续阻塞并内部循环调用 recv(),直到成功读取指定字节数(或遇到 EOF/错误)。这是处理定长协议头 + 变长载荷(如图像)的推荐方式。

以下是精简、健壮、生产可用的服务端与客户端实现:

社研通
社研通

文科研究生的学术加速器

下载

? 服务端(server.py)

import socket

HOST = 'localhost'
PORT = 50000

with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
    sock.bind((HOST, PORT))
    sock.listen()
    print(f"Server listening on {HOST}:{PORT}...")

    while True:
        client, addr = sock.accept()
        print(f"[+] {addr}: connected")
        try:
            # 读取待发送的图像(二进制)
            with open('example.jpg', 'rb') as f:
                image_data = f.read()

            # 发送 4 字节大端整数表示图像长度
            length_bytes = len(image_data).to_bytes(4, byteorder='big')
            client.sendall(length_bytes)  # sendall 确保全部发出
            client.sendall(image_data)     # 同上
            print(f"[+] Sent {len(image_data)} bytes to {addr}")

        except Exception as e:
            print(f"[-] Error during transmission to {addr}: {e}")
        finally:
            client.close()
            print(f"[+] {addr}: disconnected")

? 客户端(client.py)

import socket
import io
from PIL import Image

HOST = 'localhost'
PORT = 50000

with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock:
    sock.connect((HOST, PORT))

    # 关键:用 makefile('rb') 包装 socket,获得可靠的 .read(n)
    with sock.makefile('rb') as infile:
        # 1. 读取 4 字节长度头
        header = infile.read(4)
        if len(header) != 4:
            raise ConnectionError("Failed to receive full length header")

        image_length = int.from_bytes(header, byteorder='big')
        print(f"[i] Expected image size: {image_length} bytes")

        # 2. 精确读取 image_length 字节图像数据
        image_data = infile.read(image_length)
        if len(image_data) != image_length:
            raise RuntimeError(f"Incomplete image received: {len(image_data)}/{image_length} bytes")

        # 3. 解析并显示图像
        img = Image.open(io.BytesIO(image_data))
        img.show()
        print(f"[+] Successfully loaded and displayed image ({img.format}, {img.size})")

⚠️ 关键注意事项

  • 不要混用文本与二进制协议:原代码中服务端尝试发送 JSON 或图像,客户端却未约定消息类型标识(如首字节标记),极易因协议歧义导致解析失败。单一用途连接(如本例专传图像)是最简可靠的起点。
  • 避免裸 recv() + 单次调用:recv(1024) 或 recv(n) 均不保证收满,必须手动循环或借助 makefile().read(n) / struct.unpack() 配合循环读取。
  • 始终校验数据完整性:服务端发多少,客户端必须收多少。对比 len(image_data) 与预期长度是调试截断问题的黄金准则。
  • 资源管理用 with 语句:自动关闭 socket 和文件,防止泄漏。
  • 异常处理需具体化:避免空 except:,应捕获特定异常(如 ConnectionError, RuntimeError)并提供上下文日志。

✅ 总结

图像网络传输的本质是可靠字节流交付。Socket 本身只提供字节管道,应用层需自行定义协议(如“4字节长度 + N字节图像”)并实现对应收发逻辑。socket.makefile('rb').read(n) 是 Python 中最简洁、最符合直觉的解决方案,它将底层非确定性 recv() 封装为确定性读取,让开发者专注业务逻辑而非缓冲细节。掌握此模式,即可扩展支持多图、带元数据(如格式、尺寸)、甚至视频帧流等更复杂场景。

立即学习Python免费学习笔记(深入)”;

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

WorkBuddy
WorkBuddy

腾讯云推出的AI原生桌面智能体工作台

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
json数据格式
json数据格式

JSON是一种轻量级的数据交换格式。本专题为大家带来json数据格式相关文章,帮助大家解决问题。

457

2023.08.07

json是什么
json是什么

JSON是一种轻量级的数据交换格式,具有简洁、易读、跨平台和语言的特点,JSON数据是通过键值对的方式进行组织,其中键是字符串,值可以是字符串、数值、布尔值、数组、对象或者null,在Web开发、数据交换和配置文件等方面得到广泛应用。本专题为大家提供json相关的文章、下载、课程内容,供大家免费下载体验。

549

2023.08.23

jquery怎么操作json
jquery怎么操作json

操作的方法有:1、“$.parseJSON(jsonString)”2、“$.getJSON(url, data, success)”;3、“$.each(obj, callback)”;4、“$.ajax()”。更多jquery怎么操作json的详细内容,可以访问本专题下面的文章。

337

2023.10.13

go语言处理json数据方法
go语言处理json数据方法

本专题整合了go语言中处理json数据方法,阅读专题下面的文章了解更多详细内容。

83

2025.09.10

TypeScript类型系统进阶与大型前端项目实践
TypeScript类型系统进阶与大型前端项目实践

本专题围绕 TypeScript 在大型前端项目中的应用展开,深入讲解类型系统设计与工程化开发方法。内容包括泛型与高级类型、类型推断机制、声明文件编写、模块化结构设计以及代码规范管理。通过真实项目案例分析,帮助开发者构建类型安全、结构清晰、易维护的前端工程体系,提高团队协作效率与代码质量。

90

2026.03.13

Python异步编程与Asyncio高并发应用实践
Python异步编程与Asyncio高并发应用实践

本专题围绕 Python 异步编程模型展开,深入讲解 Asyncio 框架的核心原理与应用实践。内容包括事件循环机制、协程任务调度、异步 IO 处理以及并发任务管理策略。通过构建高并发网络请求与异步数据处理案例,帮助开发者掌握 Python 在高并发场景中的高效开发方法,并提升系统资源利用率与整体运行性能。

136

2026.03.12

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

377

2026.03.11

Go高并发任务调度与Goroutine池化实践
Go高并发任务调度与Goroutine池化实践

本专题围绕 Go 语言在高并发任务处理场景中的实践展开,系统讲解 Goroutine 调度模型、Channel 通信机制以及并发控制策略。内容包括任务队列设计、Goroutine 池化管理、资源限制控制以及并发任务的性能优化方法。通过实际案例演示,帮助开发者构建稳定高效的 Go 并发任务处理系统,提高系统在高负载环境下的处理能力与稳定性。

64

2026.03.10

Kotlin Android模块化架构与组件化开发实践
Kotlin Android模块化架构与组件化开发实践

本专题围绕 Kotlin 在 Android 应用开发中的架构实践展开,重点讲解模块化设计与组件化开发的实现思路。内容包括项目模块拆分策略、公共组件封装、依赖管理优化、路由通信机制以及大型项目的工程化管理方法。通过真实项目案例分析,帮助开发者构建结构清晰、易扩展且维护成本低的 Android 应用架构体系,提升团队协作效率与项目迭代速度。

111

2026.03.09

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
最新Python教程 从入门到精通
最新Python教程 从入门到精通

共4课时 | 22.5万人学习

Django 教程
Django 教程

共28课时 | 5.1万人学习

SciPy 教程
SciPy 教程

共10课时 | 2万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号