import socket

# 创建了一个UDP的socket对象
server_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
# socket.AF_INET: 使用IPv4地址族
# socket.SOCK_DGRAM: 使用UDP协议（数据报套接字）

# 前一个是我的ipv4地址，如果用127.0.0.1则是在本地
# 如果是空字符，服务端绑定到所有的ip地址
server_socket.bind(('192.168.100.199', 6666))
# bind()方法将套接字绑定到指定地址和端口
# '192.168.100.199': 绑定到特定局域网IP
# 其他选择：
#   '127.0.0.1': 本地回环，只能本机访问
#   '0.0.0.0': 绑定所有网络接口
#   '': 同'0.0.0.0'
# 6666: 端口号，范围0-65535（0-1023为系统保留）

while True:
    # msg是收到的数据，addr是源地址和端口号
    msg, addr = server_socket.recvfrom(1024)
    # recvfrom()是阻塞方法，会一直等待直到收到数据
    # 1024: 缓冲区大小，单位字节
    # msg: 接收到的字节数据
    # addr: 元组 (客户端IP, 客户端端口)
    
    if msg.decode('utf8') == 'quit':
        break  # 如果客户端发送'quit'，则退出循环
    
    print(f'来自IP：{addr[0]},端口号：{addr[1]}的消息：{msg}')
    # 显示消息来源和内容

    send_msg = input('服务端>>')
    # 等待用户输入回复内容
    
    # 不能发送字符串，应该是字节数据
    server_socket.sendto(send_msg.encode('utf8'), addr)
    # sendto()发送数据到指定地址
    # encode('utf8'): 将字符串转为字节数据
    # addr: 目标地址（这里发回给原客户端）

# close
server_socket.close()
# 关闭套接字，释放资源

import socket

# 创建了一个UDP的socket对象
client_socket = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

# 客户端socket不用bind
# 客户端通常由系统自动分配端口号
# 如果需要绑定特定端口，也可以使用bind()

while True:
    # send msg
    send_msg = input('客户端>>')
    if send_msg == 'quit':
        break  # 输入'quit'退出
    
    client_socket.sendto(send_msg.encode('utf8'), ('192.168.100.199', 6666))
    # 发送数据到服务器
    # ('192.168.100.199', 6666): 服务器地址和端口
    # 必须与服务器绑定的地址一致

    # receive msg
    msg, addr = client_socket.recvfrom(1024)
    # 等待服务器回复
    # 注意：这里会阻塞，直到收到服务器响应
    
    print(f'来自服务端IP：{addr[0]},端口号：{addr[1]}的消息：{msg}')
    # 显示服务器回复

client_socket.close()
# 关闭客户端套接字

socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

# 服务端必须绑定，客户端可选
server_socket.bind((IP地址, 端口号))

# 接收数据（返回数据和来源地址）
data, addr = socket.recvfrom(缓冲区大小)

# 发送数据到指定地址
socket.sendto(字节数据, (目标IP, 目标端口))

# 发送：字符串 → 字节
send_msg.encode('utf8')

# 接收：字节 → 字符串
msg.decode('utf8')