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