粘包問題
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()
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號聯系： 360901061
您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點擊下面給點支持吧，站長非常感激您！手機微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對您有幫助就好】元
