Python網路程式設計之Python編寫TCP協定程式的步驟

import socket
if __name__ == '__main__':
    # 建立tcp使用者端通訊端
    # 1. AF_INET：表示ipv4
    # 2. SOCK_STREAM: tcp傳輸協定
    tcp_client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 和伺服器端應用程式建立連線
    tcp_client_socket.connect(("192.168.131.62", 8080))
    # 程式碼執行到此，說明連線建立成功
    # 準備傳送的資料
    send_data = "你好伺服器端，我是使用者端小黑!".encode("gbk")
    # 傳送資料
    tcp_client_socket.send(send_data)
    # 接收資料, 這次接收的資料最大位元組數是1024
    recv_data = tcp_client_socket.recv(1024)
    # 返回的直接是伺服器端程式傳送的二進位制資料
    print(recv_data)
    # 對資料進行解碼
    recv_content = recv_data.decode("gbk")
    print("接收伺服器端的資料為:", recv_content)
    # 關閉通訊端
    tcp_client_socket.close()

import socket
if __name__ == '__main__':
    # 建立tcp伺服器端通訊端
    tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 設定埠號複用，讓程式退出埠號立即釋放
    tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True) 
    # 給程式繫結埠號
    tcp_server_socket.bind(("", 8989))
    # 設定監聽
    # 128:最大等待建立連線的個數， 提示： 目前是單任務的伺服器端，同一時刻只能服務與一個使用者端，後續使用多工能夠讓伺服器端同時服務與多個使用者端，
    # 不需要讓使用者端進行等待建立連線
    # listen後的這個通訊端只負責接收使用者端連線請求，不能收發訊息，收發訊息使用返回的這個新通訊端來完成
    tcp_server_socket.listen(128)
    # 等待使用者端建立連線的請求, 只有使用者端和伺服器端建立連線成功程式碼才會解阻塞，程式碼才能繼續往下執行
    # 1. 專門和使用者端通訊的通訊端： service_client_socket
    # 2. 使用者端的ip地址和埠號： ip_port
    service_client_socket, ip_port = tcp_server_socket.accept()
    # 程式碼執行到此說明連線建立成功
    print("使用者端的ip地址和埠號:", ip_port)
    # 接收使用者端傳送的資料, 這次接收資料的最大位元組數是1024
    recv_data = service_client_socket.recv(1024)
    # 獲取資料的長度
    recv_data_length = len(recv_data)
    print("接收資料的長度為:", recv_data_length)
    # 對二進位制資料進行解碼
    recv_content = recv_data.decode("gbk")
    print("接收使用者端的資料為:", recv_content)
    # 準備傳送的資料
    send_data = "ok, 問題正在處理中...".encode("gbk")
    # 傳送資料給使用者端
    service_client_socket.send(send_data)
    # 關閉服務與使用者端的通訊端， 終止和使用者端通訊的服務
    service_client_socket.close()
    # 關閉伺服器端的通訊端, 終止和使用者端提供建立連線請求的服務
    tcp_server_socket.close()

# 引數1: 表示當前通訊端
# 引數2: 設定埠號複用選項
# 引數3: 設定埠號複用選項對應的值
tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)

import socket
import threading
 
 
# 處理使用者端的請求操作
def handle_client_request(service_client_socket, ip_port):
    # 迴圈接收使用者端傳送的資料
    while True:
        # 接收使用者端傳送的資料
        recv_data = service_client_socket.recv(1024)
        # 容器型別判斷是否有資料可以直接使用if語句進行判斷，如果容器型別裡面有資料表示條件成立，否則條件失敗
        # 容器型別: 列表、字典、元組、字串、set、range、二進位制資料
        if recv_data:
            print(recv_data.decode("gbk"), ip_port)
            # 回覆
            service_client_socket.send("ok，問題正在處理中...".encode("gbk"))
 
        else:
            print("使用者端下線了:", ip_port)
            break
    # 終止和使用者端進行通訊
    service_client_socket.close()
 
 
if __name__ == '__main__':
    # 建立tcp伺服器端通訊端
    tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 設定埠號複用，讓程式退出埠號立即釋放
    tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)
    # 繫結埠號
    tcp_server_socket.bind(("", 9090))
    # 設定監聽, listen後的通訊端是被動通訊端，只負責接收使用者端的連線請求
    tcp_server_socket.listen(128)
    # 迴圈等待接收使用者端的連線請求
    while True:
        # 等待接收使用者端的連線請求
        service_client_socket, ip_port = tcp_server_socket.accept()
        print("使用者端連線成功:", ip_port)
        # 當用戶端和伺服器端建立連線成功以後，需要建立一個子執行緒，不同子執行緒負責接收不同使用者端的訊息
        sub_thread = threading.Thread(target=handle_client_request, args=(service_client_socket, ip_port))
        # 設定守護主執行緒
        sub_thread.setDaemon(True)
        # 啟動子執行緒
        sub_thread.start()
 
 
    # tcp伺服器端通訊端可以不需要關閉，因為伺服器端程式需要一直執行
    # tcp_server_socket.close()