1.socket黏包問(wèn)題原理

黏包：指數(shù)據(jù)與數(shù)據(jù)之間沒(méi)有明確的分界線，導(dǎo)致不能正確的讀取數(shù)據(jù)。

應(yīng)用數(shù)據(jù)想要發(fā)送數(shù)據(jù)就必須將數(shù)據(jù)交給操作系統(tǒng)，而操作系統(tǒng)需要同時(shí)為所有的應(yīng)用程序提供數(shù)據(jù)傳輸服務(wù)，就意味著不可能馬上將應(yīng)用數(shù)據(jù)發(fā)送，就需要為程序提供一個(gè)緩沖區(qū)，用于臨時(shí)存放數(shù)據(jù)。

當(dāng)發(fā)送數(shù)據(jù)很快，有兩條數(shù)據(jù)都在緩沖區(qū)時(shí)，操作系統(tǒng)可能將兩個(gè)數(shù)據(jù)發(fā)給接收方，數(shù)據(jù)之間沒(méi)有分界線，接收方會(huì)誤認(rèn)為是一條數(shù)據(jù)。

2.UDP協(xié)議

UDP在收發(fā)數(shù)據(jù)時(shí)是基于數(shù)據(jù)包的，即一個(gè)包一個(gè)包的發(fā)送，包與包之間有明確的分界，到達(dá)對(duì)方緩沖區(qū)后也是獨(dú)立數(shù)據(jù)包。這種方式存在的問(wèn)題：

①發(fā)送數(shù)據(jù)的長(zhǎng)度每個(gè)操作系統(tǒng)會(huì)有不同的限制，數(shù)據(jù)超過(guò)限制則無(wú)法發(fā)送；

②接收方接收數(shù)據(jù)時(shí)，如果應(yīng)用程序提供的緩存容量小于數(shù)據(jù)包的長(zhǎng)度，則會(huì)造成數(shù)據(jù)的丟失，而緩沖區(qū)大小不可能無(wú)限大。

這意味著UDP不會(huì)出現(xiàn)黏包問(wèn)題，但會(huì)丟失數(shù)據(jù)，不可靠。

3.TCP協(xié)議

TCP增加了一套校驗(yàn)規(guī)則來(lái)保證數(shù)據(jù)的完整性，會(huì)將超過(guò)TCP包最大長(zhǎng)度的數(shù)據(jù)拆分為多個(gè)TCP包，并在傳輸數(shù)據(jù)時(shí)為每一個(gè)TCP數(shù)據(jù)包指定一個(gè)順序號(hào)，接收方在收到TCP數(shù)據(jù)包后按照順序?qū)?shù)據(jù)包進(jìn)行重組，重組后的數(shù)據(jù)全都是二進(jìn)制數(shù)據(jù)，且每次收到的二進(jìn)制數(shù)據(jù)之間沒(méi)有明顯的分界。基于這種工作機(jī)制，TCP在三種情況下發(fā)生黏包問(wèn)題：

①當(dāng)單個(gè)數(shù)據(jù)包較小時(shí)，接收方可能一次性讀取了多個(gè)包的數(shù)據(jù)；

②當(dāng)整體數(shù)據(jù)較大時(shí)，接收方可能一次性僅讀取了一個(gè)包的一部分內(nèi)容；

③另外TCP協(xié)議為提高效率，增加了一種優(yōu)化機(jī)制，會(huì)將數(shù)據(jù)小且發(fā)送間隔短的數(shù)據(jù)合并發(fā)送，該機(jī)制也會(huì)導(dǎo)致發(fā)送方將兩個(gè)數(shù)據(jù)包粘在一起發(fā)送。

也就是說(shuō)，TCP傳輸數(shù)據(jù)是可靠的，但是會(huì)黏包。

4.發(fā)送方出現(xiàn)的黏包

服務(wù)器端：

from socket import *
server_socket = socket(AF_INET,SOCK_STREAM)
server_socket.bind(('',8080))
server_socket.listen(5)
?
new_socket,client_addr = server_socket.accept()
?
data1 = new_socket.recv(1024)
data2 = new_socket.recv(1024)
print("收到的第一條數(shù)據(jù)：",data1)
print("收到的第二條數(shù)據(jù)：",data2)
?
new_socket.close()
server_socket.close()

客戶端：

from socket import *
?
client_socket = socket(AF_INET,SOCK_STREAM)
client_socket.connect(('10.175.193.126',8080))
client_socket.send('hello'.encode('utf-8'))
client_socket.send('word'.encode('utf-8'))
client_socket.close()

服務(wù)器端接收到的數(shù)據(jù)：

由于客戶端兩條數(shù)據(jù)發(fā)送間隔太短且數(shù)據(jù)包太小，被服務(wù)器端誤認(rèn)為是一條數(shù)據(jù)。

5. 接收方出現(xiàn)的黏包

服務(wù)器端：

from socket import *
import time
?
server_socket = socket(AF_INET,SOCK_STREAM)
server_socket.bind(('',8080))
server_socket.listen(5)
?
new_socket,client_addr = server_socket.accept()
print("連接成功！",client_addr)
?
data1 = new_socket.recv(3) #每次只接收三個(gè)字節(jié)，接收不完整
time.sleep(6)
print("收到的第一條數(shù)據(jù)：",data1)
?
data2 = new_socket.recv(10)
#接收第一次未接收的數(shù)據(jù)，若有空間，會(huì)繼續(xù)接收新數(shù)據(jù)
print("收到的第二條數(shù)據(jù)：",data2)
?
new_socket.close()
server_socket.close()

客戶端：

from socket import *
#通過(guò)time模塊使客戶端發(fā)送多個(gè)數(shù)據(jù)包時(shí)，時(shí)間間隔變長(zhǎng)
import time
?
client_socket = socket(AF_INET,SOCK_STREAM)
client_socket.connect(('10.175.193.126',8080))
client_socket.send('hello'.encode('utf-8'))
time.sleep(5) #讓當(dāng)前線程休眠5秒
client_socket.send('word'.encode('utf-8'))
?
client_socket.close()

服務(wù)器端接收到的數(shù)據(jù)：

6.黏包的成因

①服務(wù)器端出現(xiàn)黏包：接收方不知道消息之間的界限，不知道一個(gè)消息要提取多少字節(jié)的數(shù)據(jù)造成的；

②客戶端出現(xiàn)黏包：TCP在發(fā)送數(shù)據(jù)少且間隔時(shí)間短的數(shù)據(jù)包時(shí)，會(huì)將幾條合并一起發(fā)送。

到此這篇關(guān)于Python數(shù)據(jù)傳輸黏包問(wèn)題的文章就介紹到這了,更多相關(guān)Python數(shù)據(jù)傳輸黏包內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論