欧美三区_成人在线免费观看视频_欧美极品少妇xxxxⅹ免费视频_a级毛片免费播放_鲁一鲁中文字幕久久_亚洲一级特黄

python粘包問(wèn)題及socket套接字編程詳解

系統(tǒng) 1617 0

粘包問(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ì)您有幫助就好】

您的支持是博主寫作最大的動(dòng)力,如果您喜歡我的文章,感覺(jué)我的文章對(duì)您有幫助,請(qǐng)用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長(zhǎng)會(huì)非常 感謝您的哦!!!

發(fā)表我的評(píng)論
最新評(píng)論 總共0條評(píng)論
主站蜘蛛池模板: 久久成人综合 | 君岛美绪一区二区三区 | 日韩av免费看 | 91国内精品久久久久怡红院 | 亚洲第一视频网站 | 欧美日韩一区二区中文字幕 | 久久青| 日韩在线不卡一区 | 国产三级在线 | 国产高清一区二区 | 久久第四色 | 亚洲一区播放 | 一级片在线免费 | 中文字幕亚洲图片 | 秋霞91| 国产成人在线视频 | 欧美亚洲另类视频 | 日韩一级片在线免费观看 | 国产午夜精品一区二区三区嫩草 | 国产亚洲精品久久久久久老妇小说 | 都市妖奇谈 电视剧 | 国产一区中文字幕 | 国产高潮久久精品AV无码 | 亚洲毛片 | 国产成人精品一区二区三区四区 | 色精品 | 日本黄页网站免费 | 久久精品国产亚洲麻豆 | 狠狠狠狠狠狠 | 99精品在线观看 | 免费日韩av | 一区二区中文字幕 | 亚洲欧美日韩综合一区久久 | 亚洲一区二区中文字幕 | 国产免费小视频在线观看 | 久久一日本道色综合久久 | 国产99久久精品一区二区永久免费 | 看全色黄大色黄大片色黄看的 | 图片综合区 | 成人1区2区 | 男生插女生视频免费 |