Qt中udp协议的确认机制实现代码

UDP 协议是无连接、不可靠的协议，不提供确认机制。如果需要确认机制，需要在应用层进行实现。

以下是一个基于 Qt 的简单实现，实现了基于 UDP 协议的可靠传输。

// 定义一个结构体，用于传输数据和确认信息
struct Packet {
    int seqNum;  // 序列号
    QByteArray data;  // 数据
    bool ack;  // 确认信息
};

// 定义一个 UDP 客户端
class UdpClient : public QObject {
    Q_OBJECT

public:
    UdpClient(QObject *parent = nullptr) : QObject(parent) {
        m_socket.bind(QHostAddress::LocalHost, 1234);  // 绑定本地地址和端口
        connect(&m_socket, &QUdpSocket::readyRead, this, &UdpClient::receiveData);
    }

    void sendData(QByteArray data) {
        const int packetSize = 1024;  // 每个数据包的大小
        int numPackets = (data.size() + packetSize - 1) / packetSize;  // 数据包数量
        int seqNum = 0;  // 初始序列号
        for (int i = 0; i < numPackets; ++i) {
            Packet packet;
            packet.seqNum = seqNum;
            packet.data = data.mid(i * packetSize, packetSize);
            packet.ack = false;
            m_socket.writeDatagram(reinterpret_cast<char*>(&packet), sizeof(packet), QHostAddress::LocalHost, 5678);  // 发送数据包
            while (!packet.ack) {  // 等待确认
                QCoreApplication::processEvents();  // 处理事件
            }
            ++seqNum;  // 序列号加 1
        }
    }

signals:
    void dataReceived(QByteArray data);

private:
    QUdpSocket m_socket;

    void receiveData() {
        while (m_socket.hasPendingDatagrams()) {
            Packet packet;
            packet.data.resize(m_socket.pendingDatagramSize());
            m_socket.readDatagram(reinterpret_cast<char*>(&packet), sizeof(packet), nullptr, nullptr);  // 读取数据包
            if (packet.ack) {  // 已确认，忽略
                continue;
            }
            emit dataReceived(packet.data);  // 发送数据
            packet.ack = true;  // 发送确认
            m_socket.writeDatagram(reinterpret_cast<char*>(&packet), sizeof(packet), QHostAddress::LocalHost, 5678);  // 发送确认
        }
    }
};

使用示例：

UdpClient client;
connect(&client, &UdpClient::dataReceived, [&](QByteArray data) {
    // 处理接收到的数据
});
client.sendData("Hello, world!");