白云岛资源网 Design By www.pvray.com
本文实例为大家分享了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()
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。
白云岛资源网 Design By www.pvray.com
广告合作：本站广告合作请联系QQ：858582 申请时备注：广告合作（否则不回）
免责声明：本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除！
免责声明：本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除！
白云岛资源网 Design By www.pvray.com
暂无评论...
《魔兽世界》大逃杀！60人新游玩模式《强袭风暴》3月21日上线
暴雪近日发布了《魔兽世界》10.2.6 更新内容，新游玩模式《强袭风暴》即将于3月21 日在亚服上线，届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。
艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕，并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时，他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中，玩家将会进入一个全新的海盗主题大逃杀式限时活动，其中包含极高的风险和史诗级的奖励。
《强袭风暴》不是普通的战场，作为一个独立于主游戏之外的活动，玩家可以用大逃杀的风格来体验《魔兽世界》，不分职业、不分装备（除了你在赛局中捡到的），光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式，玩家在加入海盗主题的预赛大厅区域前，可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹，《巨龙崛起》和《魔兽世界：巫妖王之怒 经典版》的玩家都可以获得奖励。