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

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

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