文章目錄

• • • socket的定義
    • 套接字的工作流程
    • socket函數使用
    • • socket函數用法
      • 服務端套接字函數
      • 客戶端套接字函數
      • 公共用途的套接字函數
      • 面向文件的套接字方法
      • 打電話的流程演示
      • • 服務端.py
        • 客戶端.py
    • 基于TCP的套接字
    • 基于UDP的套接字
    • • udp服務端
      • udp客戶端
      • 示例
      • • 服務端
        • 客戶端
    • 模擬QQ聊天，多個客戶端和服務端通信
    • 其他常見問題如粘包等

socket的定義

Socket是應用層與TCP/IP協議族通信的中間軟件抽象層，它是一組接口。在設計模式中，Socket其實就是一個門面模式，它把復雜的TCP/IP協議族隱藏在Socket接口后面，對用戶來說，一組簡單的接口就是全部，讓Socket去組織數據，以符合指定的協議。所以，我們無需深入理解tcp/udp協議，socket已經為我們封裝好了，我們只需要遵循socket的規定去編程，寫出的程序自然就是遵循tcp/udp標準的。

補充：也有人將socket說成ip+port，ip是用來標識互聯網中的一臺主機的位置，而port是用來標識這臺機器上的一個應用程序，ip地址是配置到網卡上的，而port是應用程序開啟的，ip與port的綁定就標識了互聯網中獨一無二的一個應用程序，而程序的pid是同一臺機器上不同進程或者線程的標識

套接字的工作流程

先從服務器端說起。服務器端先初始化Socket，然后與端口綁定(bind)，對端口進行監聽(listen)，調用accept阻塞，等待客戶端連接。在這時如果有個客戶端初始化一個Socket，然后連接服務器(connect)，如果連接成功，這時客戶端與服務器端的連接就建立了。客戶端發送數據請求，服務器端接收請求并處理請求，然后把回應數據發送給客戶端，客戶端讀取數據，最后關閉連接，一次交互結束。

socket函數使用

socket函數用法

import socket socket.socket(socket_family,socket_type,protocal=0) # socket_family 可以是 AF_UNIX 或 AF_INET。 # socket_type 可以是 SOCK_STREAM 或 SOCK_DGRAM。protocol 一般不填,默認值為 0。# 獲取tcp/ip套接字 tcpSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 獲取udp/ip套接字 udpSock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)# 由于 socket 模塊中有太多的屬性。我們在這里破例使用了'from module import *'語句。 # 使用 'from socket import *',我們就把 socket 模塊里的所有屬性都帶到我們的命名空間里了,這樣能 大幅減短我們的代碼。 # 例如tcpSock = socket(AF_INET, SOCK_STREAM)

服務端套接字函數

s.bind() #綁定(主機,端口號)到套接字 s.listen() #開始TCP監聽 s.accept() #被動接受TCP客戶的連接,(阻塞式)等待連接的到來

客戶端套接字函數

s.connect() #主動初始化TCP服務器連接 s.connect_ex() #connect()函數的擴展版本,出錯時返回出錯碼,而不是拋出異常

公共用途的套接字函數

s.recv() #接收TCP數據 s.send() #發送TCP數據(send在待發送數據量大于己端緩存區剩余空間時,數據丟失,不會發完) s.sendall() #發送完整的TCP數據(本質就是循環調用send,sendall在待發送數據量大于己端緩存區剩余空間時,數據不丟失,循環調用send直到發完) s.recvfrom() #接收UDP數據 s.sendto() #發送UDP數據 s.getpeername() #連接到當前套接字的遠端的地址 s.getsockname() #當前套接字的地址 s.getsockopt() #返回指定套接字的參數 s.setsockopt() #設置指定套接字的參數 s.close() #關閉套接字

面向文件的套接字方法

s.fileno() #套接字的文件描述符 s.makefile() #創建一個與該套接字相關的文件

打電話的流程演示

服務端.py

import socket phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) # 買手機 phone.bind(('127.0.0.1',8080)) # 插電話卡phone.listen(5) # 開機，backlogprint('starting....') conn,addr=phone.accept() # 接電話 print(conn) print('client addr',addr) print('ready to read msg') client_msg=conn.recv(1024) # 收消息 print('client msg: %s' %client_msg) conn.send(client_msg.upper()) #發消息conn.close() phone.close()

客戶端.py

import socket phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) phone.connect(('127.0.0.1',8080)) # 撥通電話phone.send('hello'.encode('utf-8')) # 發消息back_msg=phone.recv(1024) print(back_msg)phone.close()

基于TCP的套接字

略

基于UDP的套接字

udp服務端

ss = socket() # 創建一個服務器的套接字
ss.bind() # 綁定服務器套接字
inf_loop: # 服務器無限循環
cs = ss.recvfrom()/ss.sendto() # 對話(接收與發送)
ss.close() # 關閉服務器套接字

udp客戶端

cs = socket() # 創建客戶套接字
comm_loop: # 通訊循環
cs.sendto()/cs.recvfrom() # 對話(發送/接收)
cs.close() # 關閉客戶套接字

示例

服務端

# -*- coding: utf-8 -*- """ @File : 191226_基于UDP協議的socket_server端.py @Time : 2019/12/26 23:32 @Author : Dontla @Email : sxana@qq.com @Software: PyCharm """ import socketip_port = ('192.168.1.49', 9000) BUFSIZE = 1024 udp_server_client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)udp_server_client.bind(ip_port)while True:msg, addr = udp_server_client.recvfrom(BUFSIZE)print(msg.decode('utf-8'), addr)udp_server_client.sendto(msg.upper(), addr)

客戶端

# -*- coding: utf-8 -*- """ @File : 191226_基于UDP協議的socket_client端.py @Time : 2019/12/26 23:32 @Author : Dontla @Email : sxana@qq.com @Software: PyCharm """import socketip_port = ('192.168.1.49', 9000) BUFSIZE = 1024 udp_server_client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)while True:msg = input('>>: ').strip()if not msg:continueudp_server_client.sendto(msg.encode('utf-8'), ip_port)back_msg, addr = udp_server_client.recvfrom(BUFSIZE)print(back_msg.decode('utf-8'), addr)

模擬QQ聊天，多個客戶端和服務端通信

服務端：

# -*- coding: utf-8 -*- """ @File : 191228_多個客戶端與服務端通信_server端.py @Time : 2019/12/28 10:46 @Author : Dontla @Email : sxana@qq.com @Software: PyCharm """ import socketip_port = ('192.168.1.49', 9000) udp_server_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) udp_server_sock.bind(ip_port)while True:qq_msg, addr = udp_server_sock.recvfrom(1024)print('來自[{}:{}]的一條消息:{}'.format(addr[0], addr[1], qq_msg.decode('utf-8')))back_msg = input('回復消息: ').strip()udp_server_sock.sendto(back_msg.encode('utf-8'), addr)

客戶端：

# -*- coding: utf-8 -*- """ @File : 191228_多個客戶端與服務端通信_client端1.py @Time : 2019/12/28 10:51 @Author : Dontla @Email : sxana@qq.com @Software: PyCharm """ import socketBUFSIZE = 1024 udp_client_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)qq_name_dic = {'TOM': ('192.168.1.49', 9000),'JACK': ('192.168.1.49', 9000),'一棵樹': ('192.168.1.49', 9000),'武大郎': ('192.168.1.49', 9000), }while True:qq_name = input('請選擇聊天對象: ').strip()while True:if not qq_name or qq_name not in qq_name_dic:breakmsg = input('請輸入消息,回車發送: ').strip()if msg == 'quit':breakif not msg:continueudp_client_socket.sendto(msg.encode('utf-8'), qq_name_dic[qq_name])back_msg, addr = udp_client_socket.recvfrom(BUFSIZE)print('來自[{}:{}]的一條消息:{}'.format(addr[0], addr[1], back_msg.decode('utf-8')))# udp_client_socket.close()

其他常見問題如粘包等

略

引用文章1：【Python3之socket編程】

總結

以上是生活随笔為你收集整理的python socket.socket()函数 套接字详解及TCP、UDP程序示例（粘包等）的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。