Python中的Socket 與 ScoketServer 通信及遇到問題解決方法
更新時間：2019年04月01日 10:40:42 作者：東小東
Socket有一個緩沖區(qū)，緩沖區(qū)是一個流，先進先出，發(fā)送和取出的可自定義大小的，如果取出的數據未取完緩沖區(qū)，則可能存在數據怠慢。本文通過實例代碼給大家介紹Python中的Socket 與 ScoketServer 通信及遇到問題解決方法 ，需要的朋友參考下吧
Socket有一個緩沖區(qū)，緩沖區(qū)是一個流，先進先出，發(fā)送和取出的可自定義大小的，如果取出的數據未取完緩沖區(qū)，則可能存在數據怠慢。其中【recv(1024)】表示從緩沖區(qū)里取最大為1024個字節(jié)，但實際取值大小是不確定的，推薦其值小于等于8192。
黏包問題：
Socket發(fā)送兩條連續(xù)數據時，可能最終會拼接成一條進行發(fā)送
解決方法一：
兩條數據間進行延時發(fā)送，如【tiem.sleep(0.5) #延時0.5s】
解決方法二：
每次發(fā)送后等待對方確認接收信息數據，發(fā)送一條后就立即接收等待
解決方法三：
設定接收數據大小，發(fā)送端每次發(fā)送需要發(fā)送的數據的數據大小，接收端通過設置【recv(xx)】只接收確定的大小
Socket基本使用:
簡單的服務器：
import socket
sser=socket.socket()#得到socket對象
sser.bind(("0.0.0.0",2699))#建立監(jiān)聽
sser.listen(3)
print("等等客戶端連接")
conn,addr=sser.accept() #等待連接，會一直處于阻塞，返回連接對象和對方地址
print("有客戶端已經連接,IP地址和端口為：",addr)
#接收數據，會一直阻塞，建議低于8192
#使用連接對象操作
rdata=conn.recv(1024)
print(rdata.decode("gbk"))
conn.send("服務器返回，收到數據".encode("gbk"))#發(fā)送數據，使用連接對象操作
#關閉連接
sser.close()
簡單的客戶端：
import socket
sclient=socket.socket()#得到socket對象
#連接服務器
#失敗會報錯：ConnectionRefusedError
sclient.connect(("192.168.1.135",2699))
sclient.send("東小東".encode("gbk"))#發(fā)送數據
#接收數據，會一直阻塞，建議低于8192
rdata=sclient.recv(1024)
print(rdata.decode("gbk"))
#關閉連接
sclient.close()
Soket進階：
服務器進階：
實現(xiàn)客戶循環(huán)連接及數據循環(huán)收發(fā)和判斷客戶端是否斷開
import socket
sser=socket.socket()#得到socket對象
sser.bind(("0.0.0.0",2699))#建立監(jiān)聽
sser.listen(3)
while True:
print("等等客戶端連接")
conn,addr=sser.accept() #等待連接，會一直處于阻塞，返回連接對象和對方地址
print("有客戶端已經連接,IP地址和端口為：",addr)
conn.send(("服務器歡迎你：%s\r\n"%(str(addr))).encode("gbk")) # 發(fā)送數據，使用連接對象操作
while True:
#接收數據，會一直阻塞
#使用連接對象操作
rdata=conn.recv(1024)
if not rdata: break #判斷客戶端是否斷開，斷開則收到空數據
print(rdata.decode("gbk"))
conn.send("服務器返回，收到數據\r\n".encode("gbk"))#發(fā)送數據，使用連接對象操作
#關閉連接
sser.close()
客戶端進階：
實現(xiàn)循環(huán)收發(fā)和判斷服務器是否斷開
import socket
sclient=socket.socket()#得到socket對象
#連接服務器
#失敗會報錯：ConnectionRefusedError
sclient.connect(("192.168.1.135",2699))
while True:
#接收數據，會一直阻塞
rdata=sclient.recv(1024)
if not rdata: break # 判斷服務器是否斷開，斷開則收到空數據
print(rdata.decode("gbk"))
sclient.send(("客戶端收到數據:%s\r\n"%rdata.decode("gbk")).encode("gbk")) # 發(fā)送數據
#關閉連接
sclient.close()
注意：
發(fā)送數據不可發(fā)送空字符，否則會卡住，解決方法為判斷輸入的是否為空值，空值則進行數據發(fā)送
strx=input("輸入：").strip()#得到控制臺輸入值
if(len(strx)==0):continue #如果為空字符，則跳出本次循環(huán)
print(strx) #打印
sclient.send(strx.encode("gbk")) # 發(fā)送數據
發(fā)送大數據：
先發(fā)送總體數據大小，socket另一端判斷實際接收的數據大小與總數據大小進行比較，循環(huán)recv()進行數據接收
簡單的ssh實現(xiàn)：
服務端：
import os
import socket
sser=socket.socket()#得到socket對象
sser.bind(("0.0.0.0",2697))#建立監(jiān)聽
sser.listen(3)
while True:
print("等等客戶端連接")
conn,addr=sser.accept() #等待連接，會一直處于阻塞，返回連接對象和對方地址
print("有客戶端已經連接,IP地址和端口為：",addr)
conn.send(("服務器歡迎你：%s\r\n"%(str(addr))).encode("gbk")) # 發(fā)送數據，使用連接對象操作
while True:
#接收數據，會一直阻塞
rdata=conn.recv(1024)
if not rdata: break #判斷客戶端是否斷開，斷開則收到空數據
sendtox=os.popen(rdata.decode("gbk")).read() #執(zhí)行命令
conn.send(str(len(sendtox)).encode("gbk")) #發(fā)送執(zhí)行命令的結果長度
#如果長度大于0 則發(fā)送命令結果數據
if len(sendtox)>0:
if conn.recv(10).decode("gbk")=="1":
conn.sendall(sendtox.encode("gbk"))#發(fā)送最終數據
#關閉連接
sser.close()
客戶端：
import socket
sclient=socket.socket()#得到socket對象
#連接服務器
#失敗會報錯：ConnectionRefusedError
sclient.connect(("192.168.43.21",2697))
# 接收數據，會一直阻塞
rdata = sclient.recv(1024)
print(rdata.decode("gbk"))
while True:
strx = input("請輸入命令：").strip() # 得到控制臺輸入值
if (len(strx) == 0): continue # 如果為空字符，則跳出本次循環(huán)
sclient.send(strx.encode("gbk")) # 發(fā)送數據
rdata = sclient.recv(10)
if not rdata: break # 判斷服務器是否斷開，斷開則收到空數據
#判斷命令是否執(zhí)行成功，0為失敗
dataall=int(rdata.decode("gbk"))
if dataall==0:
continue
sclient.send("1".encode("gbk")) # 發(fā)送確認接收數據命令
#循環(huán)接收數據
datanew=0
while dataall !=datanew:
rdata=sclient.recv(1024).decode("gbk")
datanew+=len(rdata)
print(rdata)
#關閉連接
sclient.close()
發(fā)送文件：
發(fā)送文件，使用read()讀取文件數據后，可循環(huán)調用send（）發(fā)送數據，或者使用sendall()一次性發(fā)送所有數據，socket另一端接收可循環(huán)recv()進行數據接收，且每次接收的數據大小是不確定的。文件傳輸需要驗證發(fā)送和接受的數據是否完全一致，可以通過數據大小加md5雙重驗證，發(fā)送端：md5在每次發(fā)送一條數據時進行update（），在數據發(fā)送完成后再發(fā)送md5值；接受端：md5在每次接收到一條數據后進行update(),在文件接收完成后再接收發(fā)送端發(fā)送的md5值，將兩值進行比較，相同則表示傳輸無丟包，但加入md5校驗，將會影響傳輸速率。
發(fā)送文件數據：先發(fā)送總體數據大小，socket另一端判斷實際接收的數據大小與總數據大小進行比較，循環(huán)recv()進行數據接收
示例：客戶端發(fā)送文件名，服務器判斷文件是否存在，如果不存在或者是空文件則不進行傳輸，服務器進行文件發(fā)送，客戶端實現(xiàn)文件接收
服務器
import os
import socket
sser=socket.socket()#得到socket對象
sser.bind(("0.0.0.0",2697))#建立監(jiān)聽
sser.listen(3)
while True:
print("等等客戶端連接")
conn,addr=sser.accept() #等待連接，會一直處于阻塞，返回連接對象和對方地址
print("有客戶端已經連接,IP地址和端口為：",addr)
conn.send(("服務器歡迎你：%s\r\n"%(str(addr))).encode("gbk")) # 發(fā)送數據，使用連接對象操作
while True:
#接收數據，會一直阻塞
rdata=conn.recv(1024)
if not rdata: break #判斷客戶端是否斷開，斷開則收到空數據
filesize=0
filenamex=rdata.decode("gbk")
if os.path.isfile(filenamex): #判斷是否是文件
filesize=os.stat(filenamex).st_size #得到文件大小
conn.send(str(filesize).encode("gbk")) #不是文件則發(fā)送0，是文件則是實際大小
#如果文件大小大于0 則發(fā)送文件
if filesize>0:
if conn.recv(10).decode("gbk")=="1": #等待確認接收命令
#一行一行發(fā)送數據
f=open(filenamex,"rb")
for linex in f:
conn.sendall(linex)#發(fā)送最終數據
#關閉連接
sser.close()
客戶端
import socket
sclient=socket.socket()#得到socket對象
#連接服務器
#失敗會報錯：ConnectionRefusedError
sclient.connect(("192.168.43.21",2697))
# 接收數據，會一直阻塞
rdata = sclient.recv(1024)
print(rdata.decode("gbk"))
while True:
filenamex = input("請輸入文件名：").strip() # 得到控制臺輸入值
if (len(filenamex) == 0): continue # 如果為空字符，則跳出本次循環(huán)
sclient.send(filenamex.encode("gbk")) # 發(fā)送數據
rdata = sclient.recv(10)
if not rdata: break # 判斷服務器是否斷開，斷開則收到空數據
#判斷命令是否執(zhí)行成功，0為失敗
dataall=int(rdata.decode("gbk"))
if dataall==0:
print("文件不存在或者為空")
continue
sclient.send("1".encode("gbk")) # 發(fā)送確認接收數據命令
#打開文件
f=open(filenamex,"wb")
#循環(huán)接收數據
datanew=0
while dataall !=datanew:
rdata=sclient.recv(1024)
datanew+=len(rdata)
f.write(rdata)
print("文件（%s)接收完畢"%filenamex)
f.close() #關閉文件
#關閉連接
sclient.close()
ScoketServer
服務端實現(xiàn)多并發(fā)效果，可以同時接入多個客戶端
import socketserver
#建立一個類，必須繼承 socketserver.BaseRequestHandler 類
class DongSocket(socketserver.BaseRequestHandler):
#必須重寫handle方法
def handle(self):
print("建立新連接，對方地址為：{}".format(self.client_address))
while True:
try:
self.datax=self.request.recv(1024).decode("gbk") #接收數據
print("接收的數據為：%s"%self.datax)
self.request.send(("服務器返回數據：%s"%self.datax).encode("gbk"))
except Exception as e:
print("斷開，再見：{}".format(self.client_address))
break
#參數：（（"ip",端口），自定義類）
#ss=socketserver.TCPServer(("0.0.0.0",2351),DongSocket) #與之前的socket服務器效果一致，同時只能連接一個客戶端
ss=socketserver.ThreadingTCPServer(("0.0.0.0",2351),DongSocket) #同時可以連接多個客戶端，多并發(fā)
ss.serve_forever()
總結
以上所述是小編給大家介紹的Python中的Socket 與 ScoketServer 通信及遇到問題解決方法 ，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對腳本之家網站的支持！
您可能感興趣的文章:
- Python Socketserver實現(xiàn)FTP文件上傳下載代碼實例
- ERROR 2002 (HY000): Can''t connect to local MySQL server through socket ''/tmp/mysql.sock''
- python SocketServer源碼深入解讀
- Java網絡通信中ServerSocket的設計優(yōu)化方案
- python利用socketserver實現(xiàn)并發(fā)套接字功能
- Python探索之SocketServer詳解
- 基于python socketserver框架全面解析
- [Java]詳解Socket和ServerSocket學習筆記
- ServerSocket默認邦定IP實現(xiàn)過程詳解
相關文章
Python?nonlocal關鍵字?與?global?關鍵字解析
這篇文章主要介紹了Python?nonlocal關鍵字?與?global?關鍵字解析，nonlocal關鍵字用來在函數或其他作用域中使用外層變量，global關鍵字用來在函數或其他局部作用域中使用全局變量，更多香瓜內容需要的小伙伴可以參考一下2022-03-03
本文通過實例代碼給大家介紹了python 處理微信對賬單數據,代碼簡單易懂，非常不錯，具有一定的參考借鑒價值，需要的朋友可以參考下2019-07-07
今天小編就為大家分享一篇關于Python用5行代碼寫一個自定義簡單二維碼的文章，小編覺得內容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧2018-10-10
這篇文章主要為大家介紹了python數字圖像處理之基本圖形的繪制，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-06-06
詳解Python中__new__和__init__的區(qū)別與聯(lián)系
在Python中,每個對象都有兩個特殊的方法：__new__和__init__,本文將詳細介紹這兩個方法的不同之處以及它們之間的聯(lián)系,具有一定的參考價值,感興趣的可以了解一下2023-12-12
這篇文章主要介紹了舉例詳解Python中threading模塊的幾個常用方法,threading模塊用來創(chuàng)建和操作線程,是Python學習當中的重要知識,需要的朋友可以參考下2015-06-06
本文主要介紹了深入理解python中的ThreadLocal，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2023-03-03
這篇文章主要介紹了Python常見反爬蟲機制解決方案,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-06-06
這篇文章主要介紹了Python 如何操作 SQLite 數據庫，幫助大家更好的理解和學習，感興趣的朋友可以了解下2020-08-08
這篇文章主要介紹了python 協(xié)程 gevent原理與用法,結合實例形式分析了Python協(xié)程gevent相關概念、原理、安裝及使用操作技巧,需要的朋友可以參考下2019-11-11