快捷導(dǎo)航

Python socket連接中的粘包、精確傳輸問(wèn)題實(shí)例分析

更新時(shí)間：2020年03月24日 09:34:36 作者：隨風(fēng)行云

這篇文章主要介紹了Python socket連接中的粘包、精確傳輸問(wèn)題,結(jié)合實(shí)例形式分析了Python socket連接中的粘包、精確傳輸相關(guān)問(wèn)題原因、解決方案與操作注意事項(xiàng),需要的朋友可以參考下

本文實(shí)例講述了Python socket連接中的粘包、精確傳輸問(wèn)題。分享給大家供大家參考，具體如下：

粘包：

發(fā)生原因：

當(dāng)調(diào)用send的時(shí)候，數(shù)據(jù)并不是即時(shí)發(fā)給客戶(hù)端的。而是放到了系統(tǒng)的socket發(fā)送緩沖區(qū)里，等緩沖區(qū)滿(mǎn)了、或者數(shù)據(jù)等待超時(shí)了，數(shù)據(jù)才會(huì)發(fā)送，所以有時(shí)候發(fā)送太快的話(huà)，前一份數(shù)據(jù)還沒(méi)有傳給客戶(hù)端，那么這份數(shù)據(jù)和上一份數(shù)據(jù)一起發(fā)給客戶(hù)端的時(shí)候就會(huì)造成“粘包” 。

解決方案：

解決根源的思想是避免不同段的數(shù)據(jù)一起發(fā)送。

方案1：前一段數(shù)據(jù)send完后，等待一段時(shí)間再send第二段數(shù)據(jù)。缺點(diǎn)：時(shí)間效率低，而且也無(wú)法完全避免問(wèn)題【因?yàn)椴磺宄撛O(shè)置多少時(shí)間才能保證前一份數(shù)據(jù)已經(jīng)發(fā)送】
方案2：握手機(jī)制：前一段數(shù)據(jù)send完后，嘗試recv，等待客戶(hù)端回應(yīng)，確認(rèn)第一段數(shù)據(jù)發(fā)送完后，再send第二段數(shù)據(jù)。完美方案？

方案二的演示：

服務(wù)端【發(fā)送方】代碼：

import socket

server=socket.socket()
server.bind(("localhost",1234))
server.listen()

while True:
  print("正在等待。。。")
  conn,addr=server.accept()
  while True:
    try:
      conn.send(b"first info")
      ack=conn.recv(1024) #接收客戶(hù)端確認(rèn)
      print(ack)
      conn.send(b"second info")
    except ConnectionResetError as e:
      print(e)
      break

server.close()

客戶(hù)端【接收方】代碼：

import socket

client=socket.socket()

client.connect(("localhost",1234))

data=client.recv(1024)
print(data.decode())
client.send(b"ack")#發(fā)送確認(rèn)
data=client.recv(1024)
print(data.decode())
client.close()

不精確傳輸問(wèn)題：

發(fā)生原因：

由于數(shù)據(jù)太大，發(fā)送方一次send不完，而接收方只recv一次，使得影響了后面數(shù)據(jù)的傳輸

解決方案：

解決根源的思想是改變r(jià)ecv的次數(shù)。

方案：將數(shù)據(jù)的大小發(fā)給接收方，讓接收方來(lái)決定recv的次數(shù)

方案實(shí)現(xiàn)代碼【以解決長(zhǎng)數(shù)據(jù)shell命令傳輸為例】：

服務(wù)端【發(fā)送方】：

import socket,os

server=socket.socket()
server.bind(("localhost",1234))
server.listen()
while True:
  print("正在等待...")
  conn,addr=server.accept()
  print("連接成功!")
  while True:
    try:
      cmd=conn.recv(1024)
      data=os.popen(cmd.decode()).read()
      # print(data)
      cmd_len=len(data.encode())
      print(cmd_len)
      #發(fā)現(xiàn)這里如果cmd_len為0會(huì)導(dǎo)致異常，有些是沒(méi)有返回值的command
      if cmd_len==0:
        data="command has nothing return"
        cmd_len=len(data.encode())
      ##因?yàn)檫@里前面沒(méi)有發(fā)送操作，所以不用擔(dān)心粘包，如果有則要考慮處理
      conn.send(str(cmd_len).encode())#因?yàn)閘en結(jié)果是int，所以還要轉(zhuǎn)換
      #這里要處理粘包
      ack=conn.recv(1024)
      conn.send(data.encode())
    except ConnectionResetError as e:
      print(e)
      break

server.close()

客戶(hù)端【接收方】：

import socket

client=socket.socket()
client.connect(("localhost",1234))
while True:

  cmd = input(">>:")
  client.send(cmd.encode())
  data_len=client.recv(1024)
  data_len=int(data_len.decode())
  print(data_len)
  recv_len=0
  client.send(b'ack')
  total_data=b''
  while recv_len<data_len:
    data=client.recv(1024)
    recv_len+=len(data)
    total_data+=data
  print(total_data.decode())
client.close()