快捷導(dǎo)航

python網(wǎng)絡(luò)編程tcp客戶端及服務(wù)端解讀

更新時間：2025年01月20日 09:19:37 作者：Bojaka

Python的socket模塊提供了基本的網(wǎng)絡(luò)通信功能,包括創(chuàng)建socket對象、綁定地址、監(jiān)聽連接、接受連接、發(fā)送和接收數(shù)據(jù)以及關(guān)閉連接等,TCP和UDP是常用的網(wǎng)絡(luò)協(xié)議,IP地址和端口號用于標(biāo)識通信端點,通過這些功能,可以實現(xiàn)客戶端和服務(wù)器之間的網(wǎng)絡(luò)通信

python網(wǎng)絡(luò)編程tcp客戶端及服務(wù)端

Python 的 socket 模塊是用于網(wǎng)絡(luò)編程的標(biāo)準(zhǔn)庫，提供了低級別的網(wǎng)絡(luò)接口，允許程序通過網(wǎng)絡(luò)進行通信。

以下是對 Python socket 模塊的簡要介紹，包括其基本概念、常用功能和示例。

基本概念

Socket：Socket 是網(wǎng)絡(luò)通信的端點。它可以是一個客戶端或服務(wù)器，允許在網(wǎng)絡(luò)上發(fā)送和接收數(shù)據(jù)。

協(xié)議：socket 模塊支持多種網(wǎng)絡(luò)協(xié)議，最常用的是 TCP（傳輸控制協(xié)議）和 UDP（用戶數(shù)據(jù)報協(xié)議）。

TCP：面向連接的協(xié)議，提供可靠的數(shù)據(jù)傳輸。
UDP：無連接的協(xié)議，傳輸速度快，但不保證數(shù)據(jù)的可靠性。

IP 地址和端口：每個 socket 都與一個 IP 地址和一個端口號相關(guān)聯(lián)。IP 地址標(biāo)識網(wǎng)絡(luò)上的設(shè)備，端口號標(biāo)識設(shè)備上的特定服務(wù)。

常用功能

創(chuàng)建 Socket：

使用 socket.socket() 創(chuàng)建一個新的 socket 對象。
需要指定地址族（如 socket.AF_INET 表示 IPv4）和套接字類型（如 socket.SOCK_STREAM 表示 TCP）。

綁定（Bind）：

使用 bind() 方法將 socket 綁定到特定的 IP 地址和端口號。

監(jiān)聽（Listen）：

服務(wù)器使用 listen() 方法開始監(jiān)聽傳入的連接請求。

接受連接（Accept）：

使用 accept() 方法接受客戶端的連接請求，返回一個新的 socket 對象和客戶端的地址。

連接（Connect）：

客戶端使用 connect() 方法連接到服務(wù)器。

發(fā)送和接收數(shù)據(jù)：

使用 send() 和 sendall() 方法發(fā)送數(shù)據(jù)。
使用 recv() 方法接收數(shù)據(jù)。

關(guān)閉 Socket：

使用 close() 方法關(guān)閉 socket 連接。

tcp客戶端

import socket
target_host = "127.0.0.1"
target_port = 65423
# 創(chuàng)建客戶端套接字
# socket.AF_INET：表示選擇IPv4的地址，socket.SOCK_STREAM：表示TCP傳輸協(xié)議類型
client = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
#連接客戶端 connect the client
client.connect((target_host,target_port))
#使用GET方法發(fā)送數(shù)據(jù)
message = "hello,socker"
client.sendall(message.encode())

#返回數(shù)據(jù)最大字符為4096
response = client.recv(4096)

#打印返回數(shù)據(jù)
print(response.decode())

#關(guān)閉連接

client.close()

tcp服務(wù)端

import socket
import threading

IP = "0.0.0.0"
PORT = 65423

def main():
    # 創(chuàng)建客戶端套接字對象
    # socket.AF_INET：表示選擇IPv4的地址，socket.SOCK_STREAM：表示TCP傳輸協(xié)議類型
    server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 綁定PORT和IP
    server.bind((IP, PORT))
    # 設(shè)置客戶端最大連接數(shù)量5
    server.listen(5)
    # 打印開啟監(jiān)聽IP和PORT
    print(f" [*] Listening on {IP}:{PORT}")

    # 建立連接
    # 讓服務(wù)器進入主循環(huán)中，并在該循環(huán)中等待外來連接
    while True:
        client, address = server.accept()
        # 打印已接受的客戶端連接的ip和端口
        print(f"[*] Accepted connection from {address[0]}:{address[1]}")
        # 創(chuàng)建一個新的線程client_handler，用于處理與該客戶端的通信
        client_handler = threading.Thread(target=handle_client, args=(client,))
        # 啟動線程開始處理客戶端請求
        client_handler.start()

# 定義處理客戶端請求的函數(shù)handle_client，接受一個客戶端套接字作為參數(shù)
def handle_client(client_socket):
    # 使用with語句確保在處理完客戶端請求后自動關(guān)閉套接字
    with client_socket as sock:
    # 從客戶端最多接受1024字節(jié)的數(shù)據(jù)
        request = sock.recv(1024)
    # 打印接收到的請求內(nèi)容，使用decode("utf-8")將字節(jié)數(shù)據(jù)解碼為字符串
        print(f"[*] Received: {request.decode('utf-8')}")  # 修正引號問題
    # 向客戶端發(fā)送確認(rèn)消息ACK，表示已經(jīng)接收到請求
        sock.send(b"ACK")

if __name__ == "__main__":
    main()

使用編寫的tcp客戶端給服務(wù)發(fā)送幾個測試的數(shù)據(jù)包，應(yīng)該會看到以下輸出