溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
粘包問題
TCP協議在傳輸過程中會出現數據粘包問題
講一下TCP和UDP的區別,都是傳數據的協議,沒有好壞之說,只是不同的應用需求可能會更好選擇哪一個協議
TCP:適合傳輸數量大 ,需要建立連接,會出現粘包問題,粘包問題可以解決,確定傳入的長度,接收同樣長度就可以保證一次性傳輸完
UDP: 適合傳輸數據量小,沒有粘包,不需要連接,一次性傳輸,下一次就是新的數據,弊端就是數據丟失,不安全
QQ是用什么協議呢?按理應該可以用UDP協議,但是實際用的是TCP協議,這是歷史遺留問題,可還記得我們輸入QQ一次性輸入的內容字數有限制嗎?就是規定了發送與接收的數據長度是一樣的.
形成粘包的原因
1.兩個數據非常小,然后間隔時間又短
2.數據太大,一次取不完,下一次還會取這個大數據
解決粘包問題
==在傳數據之前,傳一個數據的大小,數據的大小必須得定長==
# 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...')
# 連接循環
while True:
conn, client_address = server.accept()
print(client_address)
# 通信循環
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: # 連接循環時出現的中斷
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協議的socket套接字編程
UDP 無連接
# UDP服務端
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是差不多的,調用的功能是一樣的,只是方法名的具體表示方法不一樣,因為UDP無連接,UDP的sendto和TCP的send ,就是UDP的sendto要直接指到地址的
基于socketserver實現并發的socket套接字編程
讓服務端同時和多個客戶端進行連接,以前我們寫的是一個警局有五部電話只有一個人,現在寫的五部電話五個人
# 同一時刻有多個人在接聽
import socketserver
import subprocess
import struct
class MyHandler(socketserver.BaseRequestHandler):
# 通信循環
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的連接循環(并發),但是使用了自己的通信循環
# myhandler = MyHandler()
if __name__ == '__main__':
server = socketserver.ThreadingTCPServer(('127.0.0.1', 8000), MyHandler, bind_and_activate=True)
print('start...')
server.serve_forever()
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持億速云。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
