python 文件上传之---断点续传

server.py文件内容如下

import socket
import os
import json
import hashlibsk = socket.socket()
sk.bind(('127.0.0.1', 8000))
sk.listen(5)
conn, addr = sk.accept()while True:# 接受客户端发送的数据,看是否存在存在md5文件名称recive_msg = json.loads(conn.recv(1024).decode('utf8'))# md5文件名md5_file_name = recive_msg['file_md5_value']# 文件大小file_total_size = recive_msg['file_total_size']# 原始文件大小origin_file_name = recive_msg['origin_file_name']# 判断文件是否存在,存在的话续传.否则从0开始传is_exists = os.path.exists('./upload/' + md5_file_name)if not is_exists:# 从0开始上传conn.sendall(json.dumps({'code': 1001, 'msg': '从0开始上传'}).encode('utf8'))# 接受从客户端传来的数据recive_size = 0f = open('./upload/' + md5_file_name, 'wb')while recive_size < file_total_size:data = conn.recv(1024)f.write(data)# 主动将内存中的数据刷到到文件中去f.flush()recive_size += len(data)f.close()# 上传完毕后,修改文件的文件名为原始文件名if os.path.getsize('./upload/' + md5_file_name) == file_total_size:os.rename('./upload/' + md5_file_name, './upload/' + origin_file_name)else:# 断点续传, （先把已经接收到的文件的大小发送给客户端）# 已接收到的大小has_recive_size = os.path.getsize('./upload/' + md5_file_name)conn.sendall(json.dumps({'code': 1002, 'msg': '断点续传', 'has_recive_size': has_recive_size}).encode('utf8'))recive_size = has_recive_sizef = open('./upload/' + md5_file_name, 'ab')while recive_size < file_total_size:data = conn.recv(1024)f.write(data)# 主动将内存中的数据刷到到文件中去f.flush()recive_size += len(data)f.close()# 上传完毕后,修改文件的文件名为原始文件名if os.path.getsize('./upload/' + md5_file_name) == file_total_size:os.rename('./upload/' + md5_file_name, './upload/' + origin_file_name)break
conn.close()
sk.close()

client.py文件内容如下:

import socket
import os
import hashlib
import jsonsk = socket.socket()
sk.connect(('127.0.0.1', 8000))md5 = hashlib.md5()
# 上传文件前先检查文件的md5值,如果服务端存在就续传,否则从0开始上传
# 临时文件的名称是md5值,上传成功后修改文件名称为真实文件名称
while True:file_name = input('请输入需要上传的文件的名称:').strip()# 获取文件的md5值with open(file_name, 'rb') as f:for line in f:md5.update(line)md5_value = md5.hexdigest()# 获取文件的总大小total_size = os.path.getsize(file_name)# 组合发送的数据dic = {'file_md5_value': md5_value, 'file_total_size': total_size, 'origin_file_name': file_name}dic_str_bytes = json.dumps(dic).encode('utf8')# 发送数据sk.sendall(dic_str_bytes)# 判断code值,是否从0开始上传has_code_msg = json.loads(sk.recv(1024).decode('utf8'))code = has_code_msg['code']if code == 1001:# 从0开始上传try:f = open(file_name, 'rb')upload_size = 0while upload_size < total_size:data = f.read(1024)sk.sendall(data)upload_size += len(data)# break # 测试断点finally:f.close()else:# 断点续传# 先获取已经上传过的大小has_send_size = has_code_msg['has_recive_size']try:f = open(file_name, 'rb')upload_size = has_send_sizef.seek(has_send_size)while upload_size < total_size:data = f.read(1024)sk.sendall(data)upload_size += len(data)finally:f.close()

目录结构如下:

python 文件上传之---断点续传相关推荐

vue 文件及描述信息一起上传_用Vue实现一个大文件上传和断点续传
前言这段时间面试官都挺忙的,频频出现在博客文章标题,虽然我不是特别想蹭热度,但是实在想不到好的标题了-.-,蹭蹭就蹭蹭 :) 事实上我在面试的时候确实被问到了这个问题,而且是一道在线 coding ...
java面试上传文件_字节跳动面试官，我也实现了大文件上传和断点续传
前言前几天看到一个文章,感触很深作者从0实现了大文件的切片上传,断点续传,秒传,暂停等功能,深入浅出的把这个面试题进行了全面的剖析彩虹屁不多吹,我决定蹭蹭热点,录录视频,把作者完整写代码的过程加 ...
esp8266 刷 MicroPython固件,并使用MicroPython File Uploader python文件上传工具上传python文件
1.使用模块esp8266 2.进入固件官网:https://micropython.org/download/esp8266/ 3.将下载的esp8266-20220618-v1.19.1.bin放 ...
nodejs文件服务器断点续传,基于Nodejs的大文件上传之断点续传
接着<扒一扒Nodejs formidable的onPart>和<也说文件上传之兼容IE789的进度条---丢掉flash>:前面已完成兼容IE789的大文件上传:无flash ...
fastdfs redis java,大文件上传_断点续传_文件分片传输_fastdfs_前后端一站式解决方案...
大文件上传,断点续传,秒传,fastdfs 项目介绍实现h5与fastdfs之间的断点续传,大文件上传,秒传软件架构软件架构说明 webuploader+springboot+redis+fas ...
python 文件上传下载,python实现上传下载文件功能
最近刚学python,遇到上传下载文件功能需求,记录下! django web项目,前端上传控件用的是uploadify. 文件上传 - 后台view 的 Python代码如下: @csrf_exem ...
基于js管理大文件上传以及断点续传
大厂技术高级前端 Node进阶点击上方程序员成长指北,关注公众号回复1,加入高级Node交流群前言前端小伙伴们平常在开发过程中文件上传是经常遇到的一个问题,也许你能够实现相关的功能,但 ...
超大文件上传和断点续传的实现
之前仿造uploadify写了一个HTML5版的文件上传插件,没看过的朋友可以点此先看一下~得到了不少朋友的好评,我自己也用在了项目中,不论是用户头像上传,还是各种媒体文件的上传,以及各种个性的业务需 ...
VC++ FTP文件上传（断点续传）
#include <WinInet.h> #pragma comment(lib, "WinInet.lib") HINTERNET hInternet, hConne ...

python 文件上传之---断点续传

server.py文件内容如下

client.py文件内容如下:

目录结构如下:

python 文件上传之---断点续传相关推荐

最新文章

热门文章