本节内容
1、概述
2、代码实现
一、概述
上一篇博客讲到的用MD5来校验还是用的之前解决粘包的方法，就是客户端发送一个请求，等待服务端的确认的这样的一个笨方法。下面我们用另外一种方法：就是客户端已经知道可接收多少数据了，既然客户端已经知道接收多少数据了，那么客户端在接收数据的时候，正好接收已经知道的数据，不就ok了吗？就是说我循环了正好是收到已经知道的那些数据。比如：我要发5M的数据，我正好收到5M的数据，然后就不往下再收了，因为它有可能跟MD5值黏在一块了，本来说是发5M文件，结果你发了5.1M，那么客户端正好收5M的话，那客户端的0.1M是不是就不收了，不收了之后我就把客户端把文件存下来，再来recive一下，下面recive的正好是0.1M。
二、代码实现
说明：其实我们在接收文件时，只有最后一次才会超过接收大小，所以我们从这里下手
2.1、服务端代码
说明：生成md5对象->发送的数据生成MD5值->发送MD5 值
①代码
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
import hashlib
import socket,os
server = socket.socket()
server.bind(("localhost",9999))
server.listen()while True:
conn,addr = server.accept()
print("new conn:",addr)
while True:
print("等待新指令")
data = conn.recv(1024)
if not data:
print("客户端已断开")
break
cmd,filename = data.decode().split()
print(filename)
if os.path.isfile(filename):
m = hashlib.md5() #生成MD5的对象
with open(filename,"rb") as f:
file_size = os.stat(filename).st_size
conn.send( str(file_size).encode() ) #send file size
conn.recv(1024)
for line in f:
m.update(line) #计算md5值
conn.send(line) #发送数据至客户端
print("file md5",m.hexdigest())
conn.send(m.hexdigest().encode()) #生成MD5值并且发送给客户端
print("send done")
server.close() |
②代码改动
2.2、客户端
说明：文件大小-接收大小是否大于1024 ->获取size值->recive(size)->下面再次recive时就是MD5值了
①代码
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
import socket,hashlib
client = socket.socket()
client.connect(("localhost",9999))
while True:
cmd = input(">>>:").strip()
if len(cmd) == 0:continue
if cmd.startswith("get"):
client.send(cmd.encode())
server_respose = client.recv(1024)
print("server response:",server_respose)
client.send("ready to recv file".encode())
file_total_size = int(server_respose.decode())
revived_size = 0
filename = cmd.split()[1]
m = hashlib.md5() #生成MD5对象
with open(filename + ".new","wb") as f:
while revived_size < file_total_size:
if file_total_size - revived_size > 1024: #要收不止一次
size = 1024
else: #最后一次，剩多少收多少
size = file_total_size - revived_size
print("last receive:",size)
data = client.recv(size)
revived_size += len(data)
m.update(data) #计算数据接收的MD5值
f.write(data)
else:
print(file_total_size,revived_size)
new_file_md5 = m.hexdigest() #生成接收数据的MD5值16进制形式
server_file_md5 = client.recv(1024) #接收客户端的MD5值
print("server file md5:",server_file_md5.decode())
print("client file md5:",new_file_md5)
client.close() |
②代码改动
2.3、思路图
2.4、实现的效果图
