怎么在Python中使用socket實(shí)現(xiàn)一個(gè)通信功能

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

常用的地址家族

• AF_UNIX：基于文件，實(shí)現(xiàn)同一主機(jī)不同進(jìn)程之間的通信

• AF_INET：基于網(wǎng)絡(luò)，適用于IPv4

• AF_INET6：基于網(wǎng)絡(luò)，使用于IPv6

常見的連接類型

• SOCK_STREAM：即TCP/IP。面向連接的套接字，通信之前必須建立可靠的連接。面向連接的套接字提供序列化的、可靠的和不重復(fù)的數(shù)據(jù)交付，而沒有記錄邊界。

• SOCK_DGRAM：即UDP。面向非連接的套接字，通信之前無(wú)需建立連接。在數(shù)據(jù)傳輸過(guò)程中無(wú)法保證數(shù)據(jù)的有序性、可靠性和重復(fù)性。然而數(shù)據(jù)報(bào)確實(shí)保存了記錄邊界，意味著數(shù)據(jù)是以整體發(fā)送的，而非事先切割多個(gè)片段。

socket通信

• server端

import socket
server = socket.socket()  # 默認(rèn)是AF_INET、SOCK_STREAM
server.bind(("localhost",6868))   # 將主機(jī)號(hào)與端口綁定到套接字
server.listen()   # 設(shè)置并啟動(dòng)TCP監(jiān)聽器
while True:
  conn,addr = server.accept()   # 被動(dòng)接受TCP連接，一直等待連接到達(dá)
  while True:
    data = conn.recv(1024)   # 接收TCP消息，并制定最大長(zhǎng)度
    if not data:
      print("連接已斷開")
      break
    conn.send(data.upper())  # 將接收到的數(shù)據(jù)轉(zhuǎn)為大寫在發(fā)回給它
server.close()

• client端

import socket
client = socket.socket()  # 默認(rèn)是AF_INET、SOCK_STREAM
client.connect(("localhost",6868))
while True:
  s = input(">>")
  client.send(s.encode("utf-8"))
  data = client.recv(1024)
client.close()

執(zhí)行結(jié)果:

socketserver模塊

使用socketserver實(shí)現(xiàn)多并發(fā)

import socketserver
class MyServer(socketserver.BaseRequestHandler):
  def handle(self):
    while True:
      self.data = self.request.recv(1024)
      if not self.data:
        print("%s客戶端連接已斷開"%self.client_address)
        break
      self.request.sendall(self.data.upper())
if __name__ == "__main__":
  server = socketserver.ThreadingTCPServer(("localhost",6969),MyServer)  # 開啟一個(gè)線程
  server.serve_forever()

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