粘包問(wèn)題
TCP協(xié)議在傳輸過(guò)程中會(huì)出現(xiàn)數(shù)據(jù)粘包問(wèn)題
講一下TCP和UDP的區(qū)別,都是傳數(shù)據(jù)的協(xié)議,沒(méi)有好壞之說(shuō),只是不同的應(yīng)用需求可能會(huì)更好選擇哪一個(gè)協(xié)議
TCP:適合傳輸數(shù)量大 ,需要建立連接,會(huì)出現(xiàn)粘包問(wèn)題,粘包問(wèn)題可以解決,確定傳入的長(zhǎng)度,接收同樣長(zhǎng)度就可以保證一次性傳輸完
UDP: 適合傳輸數(shù)據(jù)量小,沒(méi)有粘包,不需要連接,一次性傳輸,下一次就是新的數(shù)據(jù),弊端就是數(shù)據(jù)丟失,不安全
QQ是用什么協(xié)議呢?按理應(yīng)該可以用UDP協(xié)議,但是實(shí)際用的是TCP協(xié)議,這是歷史遺留問(wèn)題,可還記得我們輸入QQ一次性輸入的內(nèi)容字?jǐn)?shù)有限制嗎?就是規(guī)定了發(fā)送與接收的數(shù)據(jù)長(zhǎng)度是一樣的.
形成粘包的原因
1.兩個(gè)數(shù)據(jù)非常小,然后間隔時(shí)間又短
2.數(shù)據(jù)太大,一次取不完,下一次還會(huì)取這個(gè)大數(shù)據(jù)
解決粘包問(wèn)題
==在傳數(shù)據(jù)之前,傳一個(gè)數(shù)據(jù)的大小,數(shù)據(jù)的大小必須得定長(zhǎng)==
# TCP 解決粘包問(wèn)題 附帶處理了一下
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 無(wú)連接
# 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無(wú)連接,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()
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號(hào)聯(lián)系： 360901061
您的支持是博主寫作最大的動(dòng)力，如果您喜歡我的文章，感覺(jué)我的文章對(duì)您有幫助，請(qǐng)用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點(diǎn)擊下面給點(diǎn)支持吧，站長(zhǎng)非常感激您！手機(jī)微信長(zhǎng)按不能支付解決辦法：請(qǐng)將微信支付二維碼保存到相冊(cè)，切換到微信，然后點(diǎn)擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對(duì)您有幫助就好】元
