QUdpSocket服务端接收数据说明(非阻塞)

先说结论吧,QUdpSocket不支持阻塞式访问,正常非阻塞的要么需要信号槽机制访问,要么需要循环判断,导致的结果就是要不丢包严重,要不CPU占用率高,还是建以利用socket自己去实现UDP。

参考:QT中UDPSocket丢包问题_rabbitjerry的专栏-CSDN博客_qt udp丢包

1.信号槽机制访问

#include <QCoreApplication>
#include <QUdpSocket>
#include <QHostAddress>
#include <QDebug>
#include <QNetworkDatagram>
#include <QObject>
int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);
    QUdpSocket *udp = new QUdpSocket();
    udp->bind(QHostAddress::LocalHost,8080);
    long count = 0;


    QObject::connect(udp,&QUdpSocket::readyRead,[udp,&count]()
    {while (udp->hasPendingDatagrams()) {
            QNetworkDatagram datagram = udp->receiveDatagram();

            qDebug() << datagram.data().size();
                        count ++;
                        qDebug() << "Packet " << count;
        }
    });
    return a.exec();
}

 本地循环测试情况下,客户端不加任何延迟全速发送,客户端发送5000包,服务端接收到230-250包不等,丢包严重,而且CPU占用率达4%-8%。

2.线程中轮询

#include <QCoreApplication>
#include <QUdpSocket>
#include <QHostAddress>
#include <QDebug>
#include <QNetworkDatagram>
#include <QObject>
int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);
    QUdpSocket *udp = new QUdpSocket();
    udp->bind(QHostAddress::LocalHost,8080);
    long count = 0;
    char buffer[1280] = {0};
    while(1)
    {
        while(udp->hasPendingDatagrams())
        {
            qDebug() << udp->readDatagram(buffer,1280);
            count ++;
            qDebug() << "Packet " << count;
        }
    }

    return a.exec();
}

本地循环测试情况下,客户端不加任何延迟全速发送,客户端发送5000包,服务端接收到230-250包不等,丢包严重,而且CPU占用率达12%-15%。

总之,低速的UDP包接收可以利用QUdpSocker来实现,高速的在windows环境下支持挺差的。

上一篇:llvm.20.SwiftCompiler.Compiler-Driver


下一篇:OpenCV: 从摄像头中读取