為什么會出現黏包現象：

首先只有在TCP協議中才會出現黏包現象，是因為TCP協議是面向流的協議，在發送的數據傳輸的過程中還有緩存機制來避免數據丟失，因此，在連續發送小數據的時候，以及接收大小不符的時候容易出現黏包現象。本質還是因為我們在接收數據的時候不知道發送的數據的長短。

解決黏包問題

在傳輸大量數據之前首先告訴接收端要發送的數據大小，如果想更漂亮的解決問題，可以通過struct模塊來定制協議。

struct模塊：

功能：可以把一個類型，如數字，轉成固定長度的bytes。

import structret = struct.pack(’i’,456872783) #’i’代表int，就是即將要把一共數字轉換成固定長度（4個字節）的bystes類型print(ret)num = struct.unpack(’i’,ret) #轉換回來，返回一個元組print(num[0]) #提前元組中的值得到4096

解決黏包問題：

服務端：

import structimport socketsk = socket.socket()sk.bind((’127.0.0.1’,8080))sk.listen()conn,addr = sk.accept()while True: cmd = input(’>>>’) if cmd == ’q’: #當輸入‘q’時，結束，并向客戶端發送一個’q’。 conn.send(b’q’) break conn.send(cmd.encode(’gbk’)) #將輸入的cmd命令發送給客戶端 num = conn.recv(4) #接收字節信息（返回的消息長度信息）。 num = struct.unpack(’i’,num)[0] #將接收的字節碼轉化為原來的類型并放在一個元組里面，后面加[0]是提前出元組中的值。 res = conn.recv(int(num)).decode(’gbk’) #接收長度為num 的消息。 print(res) #打印conn.close()sk.close()

客戶端：

import structimport socketimport subprocesssk = socket.socket()sk.connect((’127.0.0.1’,8080))while True: cmd = sk.recv(1024).decode(’gbk’) #接收服務端發送來的cmd命令 if cmd == ’q’: #當接收到‘q’時，結束。 break # 在客戶端執行接收到的cmd命令。并將正確的消息和錯誤的消息分別放入stdout和stderr管道。 res = subprocess.Popen(cmd,shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE) std_out = res.stdout.read() #讀取管道內正確的消息 std_err = res.stderr.read() #讀取管道內錯誤的消息 len_num = len(std_out)+len(std_err) #計算正確和錯誤消息的總長度 num_by = struct.pack(’i’,len_num) #將消息總長度轉換成長度為4的字節碼 sk.send(num_by) #發送消息長度信息 sk.send(std_out) #發送正確消息 sk.send(std_err) #發送錯誤消息sk.close()

以上就是python 用struct模塊解決黏包問題的詳細內容，更多關于python struct模塊的資料請關注好吧啦網其它相關文章！