python实现ftp文件传输功能
作者:zjtMeng 发布时间:2023-04-21 13:20:16
标签:python,ftp,文件传输
本文实例为大家分享了python实现ftp文件传输的具体代码,供大家参考,具体内容如下
主要步骤可以分为以下几步:
1.读取文件名
2.检测文件是否存在
3.打开文件
4.检测文件大小
5.发送文件大小和 md5值给客户端
6.等客户端确认
7.开始边读边发数据
服务器端代码:
import socket,os,time
import hashlib
server =socket.socket()
server.bind(('0.0.0.0',6666))
server.listen()
print("等待....")
while True:
conn,addr = server.accept()
print("new conn:",conn)
while True:
data = conn.recv(1024)
if not data:
print("client is disconnection")
break
cmd,filename = data.decode().split() #记录指令和文件名
print(filename)
#判断当前目录是否存在该文件,而且必须是文件,而不是目录
if os.path.isfile(filename):
f = open(filename,'rb')
#m = hashlib.md5() # 创建md5
file_size = os.stat(filename).st_size #stat() 可以返回文件的大小值
conn.send((str(file_size)).encode()) # 发送文件大小
conn.recv(1024) #等待返回信息
for line in f:
# m.updata(line)
conn.send(line)
#print("file md5",m.hexdigest()) #打印md5值
f.close()
客户端代码:
# Author: zjt
import socket
client = socket.socket()
client.connect(("0.0.0.0",6666))
while True:
cmd = input(">>>:").strip()
if len(cmd)==0 :continue
if cmd.startswith("get"):
client.send(cmd.encode())
server_response = client.recv(1024)
print("server response: ",server_response)
client.send(b"ready to recv file")
# 开始接收文件
file_total_size = int(server_response.decode())
received_size = 0 # 记录接收文件的大小
filename = cmd.split()[1]
# 因为两个目录一致,接收的文件名不能与原文件相同
f = open(filename+".new","wb")
while received_size < file_total_size:
data = client.recv(1024)
received_size += len(data)
f.write(data)
print("total:",file_total_size," present: ",received_size)
else:
print("file has received done!")
f.close()
client.close()
用80M的文件传输测试,效果如下:
程序升级:
前面的代码还没添加md5进行验证,现在对代码进行升级
服务器端代码:
import socket,os,time
import hashlib
server =socket.socket()
server.bind(('0.0.0.0',8888))
server.listen()
print("等待....")
while True:
conn,addr = server.accept()
print("new conn:",conn)
while True:
data = conn.recv(1024)
if not data:
print("client is disconnection")
break
cmd,filename = data.decode().split() #记录指令和文件名
print(filename)
#判断当前目录是否存在该文件,而且必须是文件,而不是目录
if os.path.isfile(filename):
f = open(filename,'rb')
m = hashlib.md5() # 创建md5
file_size = os.stat(filename).st_size #stat() 可以返回文件的大小值
conn.send((str(file_size)).encode()) # 发送文件大小
conn.recv(1024) #等待返回信息
for line in f:
m.update(line)
conn.send(line)
print("file md5",m.hexdigest()) #打印md5值
f.close()
conn.send(m.hexdigest().encode()) # 发送md5
print("我真的已经发过去了",m.hexdigest().encode())
print("send done")
server.close()
客户端代码:
import socket
import hashlib
client = socket.socket()
client.connect(("0.0.0.0",8888))
while True:
cmd = input(">>>:").strip()
if len(cmd)==0 :continue
if cmd.startswith("get"):
client.send(cmd.encode())
server_response = client.recv(1024)
print("server response: ",server_response)
client.send(b"ready to recv file")
# 开始接收文件
file_total_size = int(server_response.decode())
received_size = 0 # 记录接收文件的大小
filename = cmd.split()[1]
# 因为两个目录一致,接收的文件名不能与原文件相同
f = open(filename+".new","wb")
m = hashlib.md5()
while received_size < file_total_size:
data = client.recv(1024)
received_size += len(data)
m.update(data)
f.write(data)
#print("total:",file_total_size," present: ",received_size)
else:
new_file_md5 = m.hexdigest()
print("client file md5:",new_file_md5)
print("file has received done!")
print("total:",file_total_size," present: ",received_size)
f.close()
sever_file_md5 = client.recv(1024)
print("client file md5:",new_file_md5)
print("server file md5:",sever_file_md5)
client.close()
两个程序在linux 环境下运行,结果如下:
可以看到传输后文件大小变大了一点点,而且md5前后值也不同,说明文件传输发生了改变。
现在讲程序在windows环境下运行,结果如下:
此时可以看到windows上没有问题,文件大小相同,且md5值也一致。
原因分析:
之所以会发生这种情况,是因为在linux上运行时,最后一次传输文件与发送md5值的时候,发生可粘包,导致最后一次接收文件的时候,连同md5的数据一并发送了。而客户端也当作一条接收信息,全部接收了。所以客户端出现没有收到来自服务器端的md5值,多出来的那一点点,就是md5值的大小。
解决方法:
在接收文件的时候,判断当前剩余多少文件需要接收,如果大于1024,就接收1024大小的文件,否则就只接收剩下全部的文件,防止最后一次接收多余的数据。
只需要对客户端代码进行修改,修改后代码如下:
import socket
import hashlib
client = socket.socket()
client.connect(("0.0.0.0",8888))
while True:
cmd = input(">>>:").strip()
if len(cmd)==0 :continue
if cmd.startswith("get"):
client.send(cmd.encode())
server_response = client.recv(1024)
print("server response: ",server_response)
client.send(b"ready to recv file")
# 开始接收文件
file_total_size = int(server_response.decode())
received_size = 0 # 记录接收文件的大小
filename = cmd.split()[1]
f = open(filename+".new","wb")
m = hashlib.md5()
while received_size < file_total_size:
#添加一次判断,使最后一次剩多少就接收多少,避免发生粘包
if file_total_size - received_size > 1024:
size = 1024
else: # 最后一次,剩多少收多少
size = file_total_size - received_size
data = client.recv(size)
received_size += len(data)
m.update(data)
f.write(data)
else:
new_file_md5 = m.hexdigest()
print("client file md5:",new_file_md5)
print("file has received done!")
print("total:",file_total_size," present: ",received_size)
print("下一句关闭文件")
f.close()
print("开始接收md5 ")
sever_file_md5 = client.recv(1024)
print("client file md5:",new_file_md5)
print("server file md5:",sever_file_md5)
client.close()
来源:https://blog.csdn.net/zjt980452483/article/details/79813631
0
投稿
猜你喜欢
- 页面自动刷新代码大全,基本上所有要求自动刷新页面的代码都有,大家可以自由发挥做出完美的页面。 1)10表示间隔10秒刷 ...页面自动刷新代
- 一、我的需求对于这样的一个 csv 表,需要将其(1)将营业部名称和日期和股票代码进行拼接(2)对于除了买入金额不同的的数据需要将它们的买入
- 作者:Lachlan Hunt概要网络是不断的进化的. 新的和有创意的网站每天都在出现, 从各方面都在冲击着HTML的边界. HTML 4来
- Altova 公司的 XMLSPY 是个不可多得的好东西,它几乎可以开发所有的 XML 产品。最近用它来做 Schema
- 程序设计中会经常碰到一种情况,就是事先无法得知用户会需要哪些数据,必须根据用户选择后再从服务器重新提取数据后反馈给用户。比如一简单的情况,用
- 前言这篇文章算是论坛PyTorch Forums关于参数初始化和finetune的总结,也是我在写代码中用的算是“最佳实践”吧。最后希望大家
- choice()方法从一个列表,元组或字符串返回一个随机项。语法以下是choice()方法的语法:choice( seq )注意
- 高级加密标准(英语:Advanced Encryption Standard,缩写:AES),在密码学中又称Rijndael加密法,是美国联
- IE下专属CSS:<![if !IE]><link rel="stylesheet" type=&qu
- Tesseract介绍tesseract是一个挺不错的OCR引擎,目前的问题是最新的中文资料相对较少,过时、不准确的信息偏多。tessera
- 网上async with和async for的中文资料比较少,我把PEP 492中的官方陈述翻译一下。异步上下文管理器”async with
- 编辑距离编辑距离(Edit Distance),又称Levenshtein距离,是指两个字串之间,由一个转成另一个所需的最少编辑操作次数。编
- 矩阵相乘需要前面矩阵的行数与后面矩阵的列数相同方可相乘。第一步,先将前面矩阵的每一行分别与后面矩阵的列相乘,作为结果矩阵的行列;第二步算出结
- 尽管很多 NoSQL 数据库近几年大放异彩,但是像 MySQL 这样的关系型数据库依然是互联网的主流数据库之一,每个学 Python 的都有
- Python的from import *和from import *,它们的功能都是将包引入使用,但是它们是怎么执行的以及为什么使用这种语法
- xmlhttp,IE不支持overrideMimeType()方法,即使是IE7。 // Mozilla/Safari/
- 网站能切换几套CSS风格早已不是什么新鲜事了。大家也都知道怎么去弄。早上发现一个有意思得站点 http://www.leemunroe.co
- settings文件中配置:LOGGING = { 'version':1, 'disabl
- 一般来说,一个真正的、完整的站点是离不开数据库的,因为实际应用中,需要保存的数据很多,而且这些数据之间往往还有关联,利用数据库来管理这些数据
- 本文实例讲述了Python iter()函数用法。分享给大家供大家参考,具体如下:python中的迭代器用起来非常灵巧,不仅可以迭代序列,也