我正在尝试解码通过 TCP 连接收到的数据。数据包很小,不超过100字节。然而,当它们很多时,我会收到一些连接在一起的数据包。有没有办法防止这种情况。我正在使用Python
我尝试分离数据包,我的来源如下。数据包以STX字节开始,以ETX字节结束,STX后面的字节是数据包长度,(数据包长度小于5无效)校验和是ETX之前的最后一个字节
def decode(data):
while True:
start = data.find(STX)
if start == -1: #no stx in message
pkt = ''
data = ''
break
#stx found , next byte is the length
pktlen = ord(data[1])
#check message ends in ETX (pktken -1) or checksum invalid
if pktlen < 5 or data[pktlen-1] != ETX or checksum_valid(data[start:pktlen]) == False:
print "Invalid Pkt"
data = data[start+1:]
continue
else:
pkt = data[start:pktlen]
data = data[pktlen:]
break
return data , pkt
我这样用
#process reports
try:
data = sock.recv(256)
except: continue
else:
while data:
data, pkt = decode(data)
if pkt:
process(pkt)
此外,如果数据流中有多个数据包,最好将数据包作为列表的集合返回还是只返回第一个数据包
我对python不太熟悉,只会C,这个方法可以吗?任何建议将不胜感激。提前致谢
Thanks
我将创建一个类,负责解码流中的数据包,如下所示:
class PacketDecoder(object):
STX = ...
ETX = ...
def __init__(self):
self._stream = ''
def feed(self, buffer):
self._stream += buffer
def decode(self):
'''
Yields packets from the current stream.
'''
while len(self._stream) > 2:
end = self._stream.find(self.ETX)
if end == -1:
break
packet_len = ord(self._stream[1])
packet = self._stream[:end]
if packet_len >= 5 and check_sum_valid(packet):
yield packet
self._stream = self._stream[end+1:]
然后像这样使用:
decoder = PacketDecoder()
while True:
data = sock.recv(256)
if not data:
# handle lost connection...
decoder.feed(data)
for packet in decoder.decode():
process(packet)
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)