快捷導(dǎo)航

python粘包問題及socket套接字編程詳解

更新時(shí)間：2019年06月29日 14:31:02 作者：格格小丫頭

這篇文章主要介紹了python粘包問題及socket套接字編程詳解,之所以出現(xiàn)粘包，是因?yàn)閮蓚€(gè)數(shù)據(jù)非常小,然后間隔時(shí)間又短，或數(shù)據(jù)太大,一次取不完,下一次還會(huì)取這個(gè)大數(shù)據(jù),需要的朋友可以參考下

粘包問題

TCP協(xié)議在傳輸過程中會(huì)出現(xiàn)數(shù)據(jù)粘包問題

講一下TCP和UDP的區(qū)別,都是傳數(shù)據(jù)的協(xié)議,沒有好壞之說,只是不同的應(yīng)用需求可能會(huì)更好選擇哪一個(gè)協(xié)議

TCP:適合傳輸數(shù)量大 ,需要建立連接,會(huì)出現(xiàn)粘包問題,粘包問題可以解決,確定傳入的長度,接收同樣長度就可以保證一次性傳輸完

UDP: 適合傳輸數(shù)據(jù)量小,沒有粘包,不需要連接,一次性傳輸,下一次就是新的數(shù)據(jù),弊端就是數(shù)據(jù)丟失,不安全

QQ是用什么協(xié)議呢?按理應(yīng)該可以用UDP協(xié)議,但是實(shí)際用的是TCP協(xié)議,這是歷史遺留問題,可還記得我們輸入QQ一次性輸入的內(nèi)容字?jǐn)?shù)有限制嗎?就是規(guī)定了發(fā)送與接收的數(shù)據(jù)長度是一樣的.

形成粘包的原因

1.兩個(gè)數(shù)據(jù)非常小,然后間隔時(shí)間又短

2.數(shù)據(jù)太大,一次取不完,下一次還會(huì)取這個(gè)大數(shù)據(jù)

解決粘包問題

==在傳數(shù)據(jù)之前,傳一個(gè)數(shù)據(jù)的大小,數(shù)據(jù)的大小必須得定長==

# TCP 解決粘包問題 附帶處理了一下
import socket
import struct
import subprocess
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind(('127.0.0.1', 8000))
server.listen(5)
print('start...')
# 連接循環(huán)
while True:
conn, client_address = server.accept()
print(client_address)
# 通信循環(huán)
while True:
try:
cmd = conn.recv(1024)
print(cmd)
pipeline = subprocess.Popen(cmd.decode('utf8'),
shell=True,
stderr=subprocess.PIPE,
stdout=subprocess.PIPE)
stdout = pipeline.stdout.read()
stderr = pipeline.stderr.read()
count_len = len(stdout) + len(stderr)
guding_bytes = struct.pack('i', count_len)
conn.send(guding_bytes) # 4
conn.send(stderr + stdout)
except ConnectionResetError: # 連接循環(huán)時(shí)出現(xiàn)的中斷
break
conn.close()

# 客戶端
mport struct
from socket import *
client = socket(AF_INET, SOCK_STREAM)
client.connect(('127.0.0.1', 8000))
while True:
# cmd = input('please enter your cmd you want:')
cmd = 'dir'
client.send(cmd.encode('utf8'))
guding_bytes = client.recv(4)
count_len = struct.unpack('i', guding_bytes)[0]
data = client.recv(count_len)
print(data.decode('gbk'))

基于UDP協(xié)議的socket套接字編程

UDP 無連接

# UDP服務(wù)端
import socket
server = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
server.bind(('127.0.0.1', 8000))
print('start...')
while True:
data, client_addr = server.recvfrom(1024)
print(client_addr)
print(data)
server.sendto(data.upper(), client_addr)

# UDP客戶端
import socket
client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
while True:
msg = input('please enter your msg:')
client.sendto(msg.encode('utf8'), ('127.0.0.1', 8000))
data = client.recvfrom(1024)
print(data)

和TCP是差不多的,調(diào)用的功能是一樣的,只是方法名的具體表示方法不一樣,因?yàn)閁DP無連接,UDP的sendto和TCP的send ,就是UDP的sendto要直接指到地址的

基于socketserver實(shí)現(xiàn)并發(fā)的socket套接字編程

讓服務(wù)端同時(shí)和多個(gè)客戶端進(jìn)行連接,以前我們寫的是一個(gè)警局有五部電話只有一個(gè)人,現(xiàn)在寫的五部電話五個(gè)人

# 同一時(shí)刻有多個(gè)人在接聽
import socketserver
import subprocess 
import struct
class MyHandler(socketserver.BaseRequestHandler):
# 通信循環(huán)
def handle(self):
while True:
try:
cmd = self.request.recv(1024)
print(cmd)
pipeline = subprocess.Popen(cmd.decode('utf8'),
shell = True,
stderr = subprocess.PIPE,
stdout = subprocess.PIPE)
stdout = pipeline.stdout.read()
stderr = pipeline.stderr.read()
count_len = len(stderr) + len(stdout)
guding_bytes = struct.pack('i', count_len)
self.request.send(guding_bytes) # 4
self.request.send(stderr + stdout)
except ConnectionResetError:
break
# 使用socketserver的連接循環(huán)(并發(fā)),但是使用了自己的通信循環(huán)
# myhandler = MyHandler()
if __name__ == '__main__':
server = socketserver.ThreadingTCPServer(('127.0.0.1', 8000), MyHandler, bind_and_activate=True)
print('start...')
server.serve_forever()

以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: