import socket

# 創(chuàng)建 socket 對象，AF_INET 表示使用 IPv4 地址，SOCK_STREAM 表示使用 TCP 協(xié)議
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 綁定 IP 地址和端口，這里綁定本地主機的 8080 端口
server_socket.bind(("localhost", 8080))

# 開始監(jiān)聽，監(jiān)聽隊列長度為 5
server_socket.listen(5)
print("服務器開始監(jiān)聽...")

# 接受客戶端連接，accept() 方法會阻塞等待客戶端連接
client_socket, client_address = server_socket.accept()
print(f"客戶端 {client_address} 已連接")

# 接收客戶端發(fā)送的數(shù)據(jù)，1024 表示緩沖區(qū)大小
data = client_socket.recv(1024).decode()
print(f"接收到客戶端消息：{data}")

# 向客戶端發(fā)送數(shù)據(jù)
response = "服務器已收到消息"
client_socket.send(response.encode())

# 關閉連接
client_socket.close()
server_socket.close()

import socket

# 創(chuàng)建 socket 對象
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 連接到服務器，這里連接本地主機的 8080 端口
client_socket.connect(("localhost", 8080))

# 向服務器發(fā)送數(shù)據(jù)
message = "Hello, Server!"
client_socket.send(message.encode())

# 接收服務器返回的數(shù)據(jù)
response = client_socket.recv(1024).decode()
print(f"收到服務器回復：{response}")

# 關閉連接
client_socket.close()

import socket

# 創(chuàng)建 socket 對象，SOCK_DGRAM 表示使用 UDP 協(xié)議
server_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

# 綁定 IP 地址和端口
server_socket.bind(("localhost", 9090))
print("UDP 服務器啟動，等待客戶端消息...")

while True:
    # 接收客戶端發(fā)送的數(shù)據(jù)和客戶端地址
    data, client_address = server_socket.recvfrom(1024)
    print(f"收到客戶端 {client_address} 的消息：{data.decode()}")

    # 向客戶端發(fā)送數(shù)據(jù)
    response = "服務器已收到你的 UDP 消息"
    server_socket.sendto(response.encode(), client_address)

    # 如果收到特定消息就退出循環(huán)
    if data.decode() == "exit":
        break

# 關閉 socket
server_socket.close()

import socket

# 創(chuàng)建 socket 對象
client_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

# 向服務器發(fā)送數(shù)據(jù)
server_address = ("localhost", 9090)
message = "Hello, UDP Server!"
client_socket.sendto(message.encode(), server_address)

# 接收服務器返回的數(shù)據(jù)
response, server_address = client_socket.recvfrom(1024)
print(f"收到服務器 {server_address} 的回復：{response.decode()}")

# 再次發(fā)送消息并接收回復（測試多輪通信）
message = "This is another message"
client_socket.sendto(message.encode(), server_address)
response, server_address = client_socket.recvfrom(1024)
print(f"收到服務器回復：{response.decode()}")

# 發(fā)送退出消息
client_socket.sendto("exit".encode(), server_address)

# 關閉連接
client_socket.close()