python設(shè)計(jì)tcp數(shù)據(jù)包協(xié)議類的例子
一. 問題描述
在tcp編程中,最需要解決的就是粘包分包問題。所以,我們需要在每個(gè)數(shù)據(jù)包前面加上數(shù)據(jù)包的長度用以分割粘連的包。
二. 包結(jié)構(gòu)的設(shè)計(jì)
包的組成:包長度+數(shù)據(jù)域
包長度:用4個(gè)字節(jié)存儲數(shù)據(jù)域長度,數(shù)據(jù)域長度即為其所占字節(jié)數(shù)
數(shù)據(jù)域:由若干個(gè)變量組成,如果是定長變量則不用加變量長度
定長變量:我們?nèi)藶橐?guī)定,傳輸中的int為4字節(jié)定長變量
變長變量:那就是字符串啦
文字難理解,那我就畫個(gè)圖吧:

上圖的第一行是數(shù)據(jù)包的一個(gè)總體結(jié)構(gòu)
第二行是數(shù)據(jù)域內(nèi)部的一個(gè)結(jié)構(gòu)(數(shù)據(jù)域的變量數(shù)量和位置都是我們自己定的,上圖只是舉一個(gè)例子而已)
第三行是具體變量的結(jié)構(gòu)
如果不太清楚這個(gè)結(jié)構(gòu),不要緊,我們來舉一個(gè)具體的例子
比如我們現(xiàn)在創(chuàng)建一個(gè)數(shù)據(jù)域是這樣的數(shù)據(jù)包:
數(shù)據(jù)域:666,"你好啊","hello",888
這個(gè)數(shù)據(jù)域一共存儲了四個(gè)變量,開頭和結(jié)尾是兩個(gè)整型變量,中間是兩個(gè)字符串變量。然后我們對這個(gè)數(shù)據(jù)域構(gòu)建出來的數(shù)據(jù)包是這個(gè)樣子的:

這下搞明白了吧,那下面就看看怎么用python封裝一個(gè)類實(shí)現(xiàn)上述結(jié)構(gòu)的數(shù)據(jù)包的組裝。
三. 代碼實(shí)現(xiàn)
class Protocol:
"""
規(guī)定:
數(shù)據(jù)包頭部占4字節(jié)
整型占4字節(jié)
字符串長度位占2字節(jié)
字符串不定長
"""
def __init__(self, bs=None):
"""
如果bs為None則代表需要?jiǎng)?chuàng)建一個(gè)數(shù)據(jù)包
否則代表需要解析一個(gè)數(shù)據(jù)包
"""
if bs:
self.bs = bytearray(bs)
else:
self.bs = bytearray(0)
def get_int32(self):
try:
ret = self.bs[:4]
self.bs = self.bs[4:]
return int.from_bytes(ret, byteorder='little')
except:
raise Exception("數(shù)據(jù)異常!")
def get_str(self):
try:
# 拿到字符串字節(jié)長度(字符串長度位2字節(jié))
length = int.from_bytes(self.bs[:2], byteorder='little')
# 再拿字符串
ret = self.bs[2:length + 2]
# 刪掉取出來的部分
self.bs = self.bs[2 + length:]
return ret.decode(encoding='utf8')
except:
raise Exception("數(shù)據(jù)異常!")
def add_int32(self, val):
bytes_val = bytearray(val.to_bytes(4, byteorder='little'))
self.bs += bytes_val
def add_str(self, val):
bytes_val = bytearray(val.encode(encoding='utf8'))
bytes_length = bytearray(len(bytes_val).to_bytes(2, byteorder='little'))
self.bs += (bytes_length + bytes_val)
def get_pck_not_head(self):
return self.bs
def get_pck_has_head(self):
bytes_pck_length = bytearray(len(self.bs).to_bytes(4, byteorder='little'))
return bytes_pck_length + self.bs
if __name__ == '__main__':
p = Protocol()
p.add_int32(666)
p.add_str("你好啊")
p.add_str("hello")
p.add_int32(888)
r = Protocol(p.get_pck_not_head())
print(r.get_int32())
print(r.get_str())
print(r.get_str())
print(r.get_int32())
代碼比較簡單,也不夠嚴(yán)謹(jǐn)。大家可以按照自己的需求加以修改。
以上這篇python設(shè)計(jì)tcp數(shù)據(jù)包協(xié)議類的例子就是小編分享給大家的全部內(nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
python中利用隊(duì)列asyncio.Queue進(jìn)行通訊詳解
asyncio是Python 3.4版本引入的標(biāo)準(zhǔn)庫,直接內(nèi)置了對異步IO的支持。 下面這篇文章主要給大家介紹了關(guān)于python中利用隊(duì)列asyncio.Queue進(jìn)行通訊的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì),需要的朋友可以參考下。2017-09-09
基于Python實(shí)現(xiàn)簡單的人臉識別系統(tǒng)
這篇文章主要介紹了如何通過Python實(shí)現(xiàn)一個(gè)簡單的人臉識別系統(tǒng),文中的示例代碼講解詳細(xì),對我們學(xué)習(xí)Python有一定的幫助,感興趣的可以跟隨小編一起試一試2022-01-01
python Tcp協(xié)議發(fā)送和接收信息的例子
今天小編就為大家分享一篇python Tcp協(xié)議發(fā)送和接收信息的例子,具有很好的參考價(jià)值,希望對大家有所幫助。一起跟隨小編過來看看吧2019-07-07
Linux下python與C++使用dlib實(shí)現(xiàn)人臉檢測
這篇文章主要為大家詳細(xì)介紹了Linux下python與C++使用dlib實(shí)現(xiàn)人臉檢測,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2018-06-06
Python中的random函數(shù)實(shí)例詳解
random模塊提供生成偽隨機(jī)數(shù)的函數(shù),在使用時(shí)需要導(dǎo)入random模塊,這篇文章主要介紹了Python中的random函數(shù),本文通過實(shí)例代碼給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2023-02-02
一個(gè)Python優(yōu)雅的數(shù)據(jù)分塊方法詳解
在做需求過程中有一個(gè)對大量數(shù)據(jù)分塊處理的場景,具體來說就是幾十萬量級的數(shù)據(jù),分批處理,每次處理100個(gè)。這時(shí)就需要一個(gè)分塊功能的代碼。本文為大家分享了一個(gè)Python中優(yōu)雅的數(shù)據(jù)分塊方法,需要的可以參考一下2022-05-05

