快捷導(dǎo)航

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

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

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

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

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

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

基本概念

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

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

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

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

常用功能

創(chuàng)建 Socket：

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

綁定（Bind）：

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

監(jiān)聽（Listen）：

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

接受連接（Accept）：

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

連接（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())

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

#打印返回?cái)?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)建客戶端套接字對(duì)象
    # 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)聽I(yíng)P和PORT
    print(f" [*] Listening on {IP}:{PORT}")

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

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

if __name__ == "__main__":
    main()

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