怎么在Python中使用socket 套接字實(shí)現(xiàn)通信

這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)碛嘘P(guān)怎么在Python中使用socket 套接字實(shí)現(xiàn)通信，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

Python主要用來做什么

Python主要應(yīng)用于：1、Web開發(fā)；2、數(shù)據(jù)科學(xué)研究；3、網(wǎng)絡(luò)爬蟲；4、嵌入式應(yīng)用開發(fā)；5、游戲開發(fā)；6、桌面應(yīng)用開發(fā)。

1. socket 在操作系統(tǒng)中它是處于應(yīng)用層與傳輸層的抽象層,它是一組操作起來非常簡(jiǎn)單的接口(接收數(shù)據(jù)的),此接口接受數(shù)據(jù)之后交個(gè)操作系統(tǒng)

那么為什么?直接給操作系統(tǒng)不是更方便嗎?那么你就想錯(cuò)了

因?yàn)椴僮飨到y(tǒng)的接口遠(yuǎn)比我們想象的要丑陋復(fù)雜,使用操作系統(tǒng)交換數(shù)據(jù),非誠(chéng)繁瑣,,開發(fā)者們只能想辦法讓一個(gè)中間人和他們打交道,來簡(jiǎn)單的實(shí)現(xiàn)數(shù)據(jù)交換,那么就是socket套接字.它的作用就是:與操作系統(tǒng)之間數(shù)據(jù)交換將這些繁瑣的操作,進(jìn)行高度化封裝,和簡(jiǎn)化,

2.我們能夠用它實(shí)現(xiàn)簡(jiǎn)單的通信

在Python中有一個(gè)簡(jiǎn)單的內(nèi)置socket 模塊我們可以用它實(shí)現(xiàn)簡(jiǎn)單的基于TCP協(xié)議的通信

 #基于切換連接的循環(huán)通信
 import socket #首先我們?cè)谖募袑?dǎo)入socket 模塊
 phone = socket.socket() #實(shí)例化一個(gè)對(duì)象
 phone.bind(('127.0.01',8765))#bind是存放ip地址的(這里存放的是本地的IP地址)
 phone.listen(5)#可以設(shè)置連接的個(gè)數(shù),
 while 1:#循環(huán)等待連接
  conn,adds = phone.accept()
  while 1:#要循環(huán)聊天我們要重復(fù)接收發(fā)送
   try: #異常處理
    receives_commands = conn.recv(1024) #接收命令請(qǐng)求,最多接收1024字節(jié)當(dāng)然你也可以調(diào)整
    receivse_commands = receives_commands.decode('utf-8')#網(wǎng)絡(luò)傳輸是以字節(jié)的形勢(shì)的所以我們要進(jìn)行解碼
    print(f'來自客戶端的消息{receives_commands}') #打印消息
    if receives_commands.upper(0 == 'Q':break #正常結(jié)束
    dispatch_orders = inport('請(qǐng)輸入:').strip().encode('utf-8')
    conn.send(dispatch_orders)
   except ConnectionResetError:#客戶端異常結(jié)束
    print('客戶端終端')
    break
  conn.close() #關(guān)閉連接
 phone.close#關(guān)閉服務(wù)端
 #客戶端
 import socket
 phone = socket.socket()
 phone.connect(('127.0.01',8765))  #連接服務(wù)端地址   
 while 1:     
  dispatch_orders = inport('請(qǐng)輸入:').strip().encode('utf-8')#發(fā)送請(qǐng)求
  if not dispatch_orders:print('不能為空')#不能為空
  phone.send(dispatch_orders)  #發(fā)送      
  if dispatch_orders.upper() ==b'Q':#正常退出
   break
  receives_commands = phone.recv(1024)#接收服務(wù)端的回執(zhí)
  receives_commands = receives_commands.decode('utf-8')#解碼
  print(f'來自客戶端的消息{receives_commands}') #打印        
 phone.close()#關(guān)閉客戶端

那么我們就通過socket實(shí)現(xiàn)了一個(gè)簡(jiǎn)單的通信鏈接循環(huán)

其中我們需要注意的是:

1.阻塞 accept 和recv 當(dāng)服務(wù)器和客戶端都屬于同種類阻塞時(shí),那么誰都是同步接受或同步發(fā)送的狀態(tài)那么是處于靜止的,這樣是不合理的(就是bug)

2.當(dāng)我們?cè)O(shè)計(jì)時(shí)我們需要知道發(fā)送不能為空,不然服務(wù)端是接收不到消息的所以我們?cè)O(shè)置一個(gè)判斷
有時(shí)我們會(huì)發(fā)現(xiàn)當(dāng)我們接受的超過1024字節(jié)會(huì)發(fā)生什么?

那么下面我們就來將回答下這個(gè)問題:

下面我們引入一個(gè)操作系統(tǒng)的模塊

Python中 subprocess 模塊就是用來和cmd 命令行進(jìn)行交流的模塊

 obj = subprocess.Popen('dir',#實(shí)例化對(duì)象括號(hào)內(nèi)第一個(gè)參數(shù)就是我們的cmd命令行的命令,這里我們寫的是dir顯示文件夾中內(nèi)容
         shell=True,
         stdout=subprocess.PIPE,
         stderr=subprocess.PIPE,
         )
   print(obj.stdout.read().decode('gbk')) # 正確命令
   print(obj.stderr.read().decode('gbk')) # 錯(cuò)誤命令

那么我們?cè)谶@個(gè)基礎(chǔ)上建立一個(gè)服務(wù)端響應(yīng)客戶端命令的機(jī)制

import socket
import subprocess
phone = socket.socket()
phone.bind(('127.0.01',8695))
phone.listen(5)
while 1:
 conn,adds = phone.accept()
 while 1:
  try:
   receives_commands = conn.recv(1024)
   if receiver_commands ==b'Q':break 
   #obj = subprocess.Popen(Receiving_instructiors,
         # shell= True,
       #stdout = subprocess.PIPE,
       #stderr = subprocess.PIPE
         )
  obj = subprocess.Popen(receives_commands.decode('utf-8')#動(dòng)態(tài)的傳入命令
       shell = True
       stdout = subprocess.PIPE
       stderr = subprocess.PIPE 
       )
 # print(obj.stdout.read().decode('gbk')) # 正確命令
 # print(obj.stderr.read().decode('gbk')) # 錯(cuò)誤命令
  ret = obj.stodut.read()+obj.stderr.read()#將產(chǎn)生的內(nèi)容進(jìn)行拼接
  conn.send(ret)
 except ConnectionResetError:
   print('客戶端終端')
   break 
 conn.close()
phone.close()
import socket
phone = socket.socket()
phone.connect(('127.0.01',8695))
while 1:
 dispatch_orders = inport('請(qǐng)輸入命令:').strip().encode('utf-8')
 if not dispatch_orders:print('輸入不能為空')
 phone.send(dispatch_orders)
 if dispatch_orders.upper() ==b'Q':break
 receives_commands = phone.recv(1024)
 receives_commands = receives_commands.decode('utf-8')
 print(f'來自客戶端的消息{receives_commands}')
phone.close()

上述就是小編為大家分享的怎么在Python中使用socket 套接字實(shí)現(xiàn)通信了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道。