快捷導(dǎo)航

python網(wǎng)絡(luò)編程調(diào)用recv函數(shù)完整接收數(shù)據(jù)的三種方法

更新時(shí)間：2017年03月31日 09:54:58 作者：南宮軒諾

本文主要介紹了python網(wǎng)絡(luò)編程調(diào)用recv函數(shù)完整接收數(shù)據(jù)的三種方法。具有很好的參考價(jià)值，下面跟著小編一起來看下吧

最近在使用python進(jìn)行網(wǎng)絡(luò)編程開發(fā)一個(gè)通用的tcpclient測試小工具。在使用socket進(jìn)行網(wǎng)絡(luò)編程中，如何判定對(duì)端發(fā)送一條報(bào)文是否接收完成，是進(jìn)行socket網(wǎng)絡(luò)開發(fā)必須要考慮的一個(gè)問題。這里，簡要介紹一下判別數(shù)據(jù)接收接收完成常用的三種方法：

1.基礎(chǔ)數(shù)據(jù)接收法：

使用基礎(chǔ)數(shù)據(jù)接收法時(shí)，當(dāng)與服務(wù)socket斷開連接時(shí)，會(huì)接收到空字符串。因此，可以根據(jù)此特點(diǎn)，在程序中加入循環(huán)，一直接收數(shù)據(jù)，直到數(shù)據(jù)發(fā)送端關(guān)閉socket連接。適用場景：客戶端和服務(wù)器的鏈接為短鏈接（即一次socket通訊后連接就會(huì)關(guān)閉）。代碼如下：

import socket,struct,sys,time
Port=22220
#assume a socket disconnect (data returned is empty string) means all data was #done being sent.
def recv_basic(the_socket):
 total_data=[]
 while True:
  data = the_socket.recv(20480) 
  if not data: break
  total_data.append(data)
 return ''.join(total_data)

2.尾標(biāo)識(shí)方法

通過尋找接收的協(xié)議數(shù)據(jù)中的尾標(biāo)識(shí)字符串，獲取完整的數(shù)據(jù)的數(shù)據(jù)報(bào)文。適用場景：接收的協(xié)議數(shù)據(jù)中包含相關(guān)的尾標(biāo)識(shí)。代碼如下：

End='something useable as an end marker'
def recv_end(the_socket):
 total_data=[];data=''
 while True:
   data=the_socket.recv(8192)
   if End in data:
    total_data.append(data[:data.find(End)])
    break
   total_data.append(data)
   if len(total_data)>1:
    #check if end_of_data was split
    last_pair=total_data[-2]+total_data[-1]
    if End in last_pair:
     total_data[-2]=last_pair[:last_pair.find(End)]
     total_data.pop()
     break
 return ''.join(total_data)

3.負(fù)載長度方法

即通過協(xié)議數(shù)據(jù)中的負(fù)載長度值，確定有效報(bào)文的長度，適用場景：協(xié)議數(shù)據(jù)中包含負(fù)載協(xié)議字段。這種方法也是比較常用和通用的一種方法，但是需要一邊接收數(shù)據(jù)一邊解析數(shù)據(jù)。代碼如下：　

def recv_size(the_socket):
 #data length is packed into 4 bytes
 total_len=0;total_data=[];size=sys.maxint
 size_data=sock_data='';recv_size=8192
 while total_len<size:
  sock_data=the_socket.recv(recv_size)
  if not total_data:
   if len(sock_data)>4:
    size_data+=sock_data
    size=struct.unpack('>i', size_data[:4])[0]
    recv_size=size
    if recv_size>524288:recv_size=524288
    total_data.append(size_data[4:])
   else:
    size_data+=sock_data
  else:
   total_data.append(sock_data)
  total_len=sum([len(i) for i in total_data ])
 return ''.join(total_data)

以上就是本文的全部內(nèi)容，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作能帶來一定的幫助，同時(shí)也希望多多支持腳本之家！