import socket


def udp_server(host='127.0.0.1', port=9876):
    # 创建UDP套接字
    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

    # 绑定套接字到指定的IP和端口
    sock.bind((host, port))

    print(f"UDP服务器启动，监听 {host}:{port}")

    while True:
        # 接收数据
        data, addr = sock.recvfrom(1024)  # 缓冲区大小1024字节
        print(f"收到来自 {addr} 的消息: {data}")

        # 发送确认消息
        response = "消息已接收"
        sock.sendto(response.encode(), addr)
        print(f"已发送确认消息给 {addr}")


if __name__ == "__main__":
    udp_server()