import socket
if __name__ == '__main__':
    # 創(chuàng)建tcp客戶端套接字
    # 1. AF_INET：表示ipv4
    # 2. SOCK_STREAM: tcp傳輸協(xié)議
    tcp_client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 和服務(wù)端應(yīng)用程序建立連接
    tcp_client_socket.connect(("192.168.131.62", 8080))
    # 代碼執(zhí)行到此，說明連接建立成功
    # 準(zhǔn)備發(fā)送的數(shù)據(jù)
    send_data = "你好服務(wù)端，我是客戶端小黑!".encode("gbk")
    # 發(fā)送數(shù)據(jù)
    tcp_client_socket.send(send_data)
    # 接收數(shù)據(jù), 這次接收的數(shù)據(jù)最大字節(jié)數(shù)是1024
    recv_data = tcp_client_socket.recv(1024)
    # 返回的直接是服務(wù)端程序發(fā)送的二進(jìn)制數(shù)據(jù)
    print(recv_data)
    # 對數(shù)據(jù)進(jìn)行解碼
    recv_content = recv_data.decode("gbk")
    print("接收服務(wù)端的數(shù)據(jù)為:", recv_content)
    # 關(guān)閉套接字
    tcp_client_socket.close()

import socket
if __name__ == '__main__':
    # 創(chuàng)建tcp服務(wù)端套接字
    tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 設(shè)置端口號復(fù)用，讓程序退出端口號立即釋放
    tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True) 
    # 給程序綁定端口號
    tcp_server_socket.bind(("", 8989))
    # 設(shè)置監(jiān)聽
    # 128:最大等待建立連接的個數(shù)， 提示： 目前是單任務(wù)的服務(wù)端，同一時刻只能服務(wù)與一個客戶端，后續(xù)使用多任務(wù)能夠讓服務(wù)端同時服務(wù)與多個客戶端，
    # 不需要讓客戶端進(jìn)行等待建立連接
    # listen后的這個套接字只負(fù)責(zé)接收客戶端連接請求，不能收發(fā)消息，收發(fā)消息使用返回的這個新套接字來完成
    tcp_server_socket.listen(128)
    # 等待客戶端建立連接的請求, 只有客戶端和服務(wù)端建立連接成功代碼才會解阻塞，代碼才能繼續(xù)往下執(zhí)行
    # 1. 專門和客戶端通信的套接字： service_client_socket
    # 2. 客戶端的ip地址和端口號： ip_port
    service_client_socket, ip_port = tcp_server_socket.accept()
    # 代碼執(zhí)行到此說明連接建立成功
    print("客戶端的ip地址和端口號:", ip_port)
    # 接收客戶端發(fā)送的數(shù)據(jù), 這次接收數(shù)據(jù)的最大字節(jié)數(shù)是1024
    recv_data = service_client_socket.recv(1024)
    # 獲取數(shù)據(jù)的長度
    recv_data_length = len(recv_data)
    print("接收數(shù)據(jù)的長度為:", recv_data_length)
    # 對二進(jìn)制數(shù)據(jù)進(jìn)行解碼
    recv_content = recv_data.decode("gbk")
    print("接收客戶端的數(shù)據(jù)為:", recv_content)
    # 準(zhǔn)備發(fā)送的數(shù)據(jù)
    send_data = "ok, 問題正在處理中...".encode("gbk")
    # 發(fā)送數(shù)據(jù)給客戶端
    service_client_socket.send(send_data)
    # 關(guān)閉服務(wù)與客戶端的套接字， 終止和客戶端通信的服務(wù)
    service_client_socket.close()
    # 關(guān)閉服務(wù)端的套接字, 終止和客戶端提供建立連接請求的服務(wù)
    tcp_server_socket.close()

# 參數(shù)1: 表示當(dāng)前套接字
# 參數(shù)2: 設(shè)置端口號復(fù)用選項
# 參數(shù)3: 設(shè)置端口號復(fù)用選項對應(yīng)的值
tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)

import socket
import threading
 
 
# 處理客戶端的請求操作
def handle_client_request(service_client_socket, ip_port):
    # 循環(huán)接收客戶端發(fā)送的數(shù)據(jù)
    while True:
        # 接收客戶端發(fā)送的數(shù)據(jù)
        recv_data = service_client_socket.recv(1024)
        # 容器類型判斷是否有數(shù)據(jù)可以直接使用if語句進(jìn)行判斷，如果容器類型里面有數(shù)據(jù)表示條件成立，否則條件失敗
        # 容器類型: 列表、字典、元組、字符串、set、range、二進(jìn)制數(shù)據(jù)
        if recv_data:
            print(recv_data.decode("gbk"), ip_port)
            # 回復(fù)
            service_client_socket.send("ok，問題正在處理中...".encode("gbk"))
 
        else:
            print("客戶端下線了:", ip_port)
            break
    # 終止和客戶端進(jìn)行通信
    service_client_socket.close()
 
 
if __name__ == '__main__':
    # 創(chuàng)建tcp服務(wù)端套接字
    tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 設(shè)置端口號復(fù)用，讓程序退出端口號立即釋放
    tcp_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, True)
    # 綁定端口號
    tcp_server_socket.bind(("", 9090))
    # 設(shè)置監(jiān)聽, listen后的套接字是被動套接字，只負(fù)責(zé)接收客戶端的連接請求
    tcp_server_socket.listen(128)
    # 循環(huán)等待接收客戶端的連接請求
    while True:
        # 等待接收客戶端的連接請求
        service_client_socket, ip_port = tcp_server_socket.accept()
        print("客戶端連接成功:", ip_port)
        # 當(dāng)客戶端和服務(wù)端建立連接成功以后，需要創(chuàng)建一個子線程，不同子線程負(fù)責(zé)接收不同客戶端的消息
        sub_thread = threading.Thread(target=handle_client_request, args=(service_client_socket, ip_port))
        # 設(shè)置守護(hù)主線程
        sub_thread.setDaemon(True)
        # 啟動子線程
        sub_thread.start()
 
 
    # tcp服務(wù)端套接字可以不需要關(guān)閉，因為服務(wù)端程序需要一直運行
    # tcp_server_socket.close()