如何在Python中解決Socket與ScoketServer的通信問題

這篇文章主要介紹了如何在Python中解決Socket與ScoketServer的通信問題，億速云小編覺得不錯，現在分享給大家，也給大家做個參考，一起跟隨億速云小編來看看吧！

Python主要用來做什么

Python主要應用于：1、Web開發；2、數據科學研究；3、網絡爬蟲；4、嵌入式應用開發；5、游戲開發；6、桌面應用開發。

Socket有一個緩沖區，緩沖區是一個流，先進先出，發送和取出的可自定義大小的，如果取出的數據未取完緩沖區，則可能存在數據怠慢。其中【recv(1024)】表示從緩沖區里取最大為1024個字節，但實際取值大小是不確定的，推薦其值小于等于8192。

黏包問題：

Socket發送兩條連續數據時，可能最終會拼接成一條進行發送

解決方法一：

兩條數據間進行延時發送，如【tiem.sleep(0.5) #延時0.5s】

解決方法二：

每次發送后等待對方確認接收信息數據，發送一條后就立即接收等待

解決方法三：

設定接收數據大小，發送端每次發送需要發送的數據的數據大小，接收端通過設置【recv(xx)】只接收確定的大小

Socket基本使用:

簡單的服務器：

import socket
sser=socket.socket()#得到socket對象
sser.bind(("0.0.0.0",2699))#建立監聽
sser.listen(3)
print("等等客戶端連接")
conn,addr=sser.accept() #等待連接，會一直處于阻塞，返回連接對象和對方地址
print("有客戶端已經連接,IP地址和端口為：",addr)
#接收數據，會一直阻塞，建議低于8192
#使用連接對象操作
rdata=conn.recv(1024)
print(rdata.decode("gbk"))
conn.send("服務器返回，收到數據".encode("gbk"))#發送數據，使用連接對象操作
#關閉連接
sser.close()

簡單的客戶端：

import socket
sclient=socket.socket()#得到socket對象
#連接服務器
#失敗會報錯：ConnectionRefusedError
sclient.connect(("192.168.1.135",2699))
sclient.send("東小東".encode("gbk"))#發送數據
#接收數據，會一直阻塞，建議低于8192
rdata=sclient.recv(1024)
print(rdata.decode("gbk"))
#關閉連接
sclient.close()

Soket進階：

服務器進階：

實現客戶循環連接及數據循環收發和判斷客戶端是否斷開

import socket
sser=socket.socket()#得到socket對象
sser.bind(("0.0.0.0",2699))#建立監聽
sser.listen(3)
while True:
  print("等等客戶端連接")
  conn,addr=sser.accept() #等待連接，會一直處于阻塞，返回連接對象和對方地址
  print("有客戶端已經連接,IP地址和端口為：",addr)
  conn.send(("服務器歡迎你：%s\r\n"%(str(addr))).encode("gbk")) # 發送數據，使用連接對象操作
  while True:
    #接收數據，會一直阻塞
    #使用連接對象操作
    rdata=conn.recv(1024)
    if not rdata: break #判斷客戶端是否斷開，斷開則收到空數據
    print(rdata.decode("gbk"))
    conn.send("服務器返回，收到數據\r\n".encode("gbk"))#發送數據，使用連接對象操作
#關閉連接
sser.close()

客戶端進階：

實現循環收發和判斷服務器是否斷開

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")) # 發送數據
#關閉連接
sclient.close()

注意：

發送數據不可發送空字符，否則會卡住，解決方法為判斷輸入的是否為空值，空值則進行數據發送

strx=input("輸入：").strip()#得到控制臺輸入值
if(len(strx)==0):continue #如果為空字符，則跳出本次循環
print(strx) #打印
sclient.send(strx.encode("gbk")) # 發送數據

發送大數據：

先發送總體數據大小，socket另一端判斷實際接收的數據大小與總數據大小進行比較，循環recv()進行數據接收

 簡單的ssh實現：

服務端：

import os
import socket
sser=socket.socket()#得到socket對象
sser.bind(("0.0.0.0",2697))#建立監聽
sser.listen(3)
while True:
  print("等等客戶端連接")
  conn,addr=sser.accept() #等待連接，會一直處于阻塞，返回連接對象和對方地址
  print("有客戶端已經連接,IP地址和端口為：",addr)
  conn.send(("服務器歡迎你：%s\r\n"%(str(addr))).encode("gbk")) # 發送數據，使用連接對象操作
  while True:
    #接收數據，會一直阻塞
    rdata=conn.recv(1024)
    if not rdata: break #判斷客戶端是否斷開，斷開則收到空數據
    sendtox=os.popen(rdata.decode("gbk")).read() #執行命令
    conn.send(str(len(sendtox)).encode("gbk")) #發送執行命令的結果長度
    #如果長度大于0 則發送命令結果數據
    if len(sendtox)>0:
    if conn.recv(10).decode("gbk")=="1":
     conn.sendall(sendtox.encode("gbk"))#發送最終數據
#關閉連接
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 # 如果為空字符，則跳出本次循環
 sclient.send(strx.encode("gbk")) # 發送數據
 rdata = sclient.recv(10)
 if not rdata: break # 判斷服務器是否斷開，斷開則收到空數據
 #判斷命令是否執行成功，0為失敗
 dataall=int(rdata.decode("gbk"))
 if dataall==0:
  continue
 sclient.send("1".encode("gbk")) # 發送確認接收數據命令
 #循環接收數據
 datanew=0
 while dataall !=datanew:
  rdata=sclient.recv(1024).decode("gbk")
  datanew+=len(rdata)
  print(rdata)
#關閉連接
sclient.close()

發送文件：

發送文件，使用read()讀取文件數據后，可循環調用send（）發送數據，或者使用sendall()一次性發送所有數據，socket另一端接收可循環recv()進行數據接收，且每次接收的數據大小是不確定的。文件傳輸需要驗證發送和接受的數據是否完全一致，可以通過數據大小加md5雙重驗證，發送端：md5在每次發送一條數據時進行update（），在數據發送完成后再發送md5值；接受端：md5在每次接收到一條數據后進行update(),在文件接收完成后再接收發送端發送的md5值，將兩值進行比較，相同則表示傳輸無丟包，但加入md5校驗，將會影響傳輸速率。

發送文件數據：先發送總體數據大小，socket另一端判斷實際接收的數據大小與總數據大小進行比較，循環recv()進行數據接收

示例：客戶端發送文件名，服務器判斷文件是否存在，如果不存在或者是空文件則不進行傳輸，服務器進行文件發送，客戶端實現文件接收

服務器

import os
import socket
sser=socket.socket()#得到socket對象
sser.bind(("0.0.0.0",2697))#建立監聽
sser.listen(3)
while True:
  print("等等客戶端連接")
  conn,addr=sser.accept() #等待連接，會一直處于阻塞，返回連接對象和對方地址
  print("有客戶端已經連接,IP地址和端口為：",addr)
  conn.send(("服務器歡迎你：%s\r\n"%(str(addr))).encode("gbk")) # 發送數據，使用連接對象操作
  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")) #不是文件則發送0，是文件則是實際大小
    #如果文件大小大于0 則發送文件
    if filesize>0:
    if conn.recv(10).decode("gbk")=="1": #等待確認接收命令
     #一行一行發送數據
     f=open(filenamex,"rb")
     for linex in f:
      conn.sendall(linex)#發送最終數據
#關閉連接
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 # 如果為空字符，則跳出本次循環
 sclient.send(filenamex.encode("gbk")) # 發送數據
 rdata = sclient.recv(10)
 if not rdata: break # 判斷服務器是否斷開，斷開則收到空數據
 #判斷命令是否執行成功，0為失敗
 dataall=int(rdata.decode("gbk"))
 if dataall==0:
  print("文件不存在或者為空")
  continue
 sclient.send("1".encode("gbk")) # 發送確認接收數據命令
 #打開文件
 f=open(filenamex,"wb")
 #循環接收數據
 datanew=0
 while dataall !=datanew:
  rdata=sclient.recv(1024)
  datanew+=len(rdata)
  f.write(rdata)
 print("文件（%s)接收完畢"%filenamex)
 f.close() #關閉文件
#關閉連接
sclient.close()

ScoketServer

服務端實現多并發效果，可以同時接入多個客戶端

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) #同時可以連接多個客戶端，多并發
ss.serve_forever()

以上就是億速云小編為大家收集整理的如何在Python中解決Socket與ScoketServer的通信問題，如何覺得億速云網站的內容還不錯，歡迎將億速云網站推薦給身邊好友。