QT实现UDP广播和接收

#include <QCoreApplication>
#include <QNetworkDatagram>
#include <QUdpSocket>

struct ReceiveThread::ReceiveThreadPrivate
{
    const quint16 recvPort = 6000;
    volatile bool runing = true;
};

ReceiveThread::ReceiveThread(QObject *parent)
    : QThread{parent}
    , d_ptr(new ReceiveThreadPrivate)
{}

ReceiveThread::~ReceiveThread()
{
    onStop();
}

void ReceiveThread::onStart()
{
    d_ptr->runing = true;
    if (isRunning()) {
        return;
    }
    start();
}

void ReceiveThread::onStop()
{
    d_ptr->runing = false;
    if (isRunning()) {
        quit();
        wait();
    }
}

void ReceiveThread::run()
{
    qInfo() << "Start Receive-----------------";
    QScopedPointer<QUdpSocket> recvUdpSocket(new QUdpSocket);
    //not working
    //    connect(recvUdpSocket.data(),
    //            &QUdpSocket::readyRead,
    //            this,
    //            &UdpReceiveThread::onReadyRead,
    //            Qt::DirectConnection);
    qInfo() << recvUdpSocket->bind(QHostAddress::Any, d_ptr->recvPort, QUdpSocket::ShareAddress);
    while (d_ptr->runing) {
        recvUdpSocket->waitForReadyRead(100);
        while (d_ptr->runing && recvUdpSocket->hasPendingDatagrams()) {
            QNetworkDatagram datagram = recvUdpSocket->receiveDatagram();
            processTheDatagram(datagram);
        }
        qApp->processEvents();
    }
    qInfo() << "Stop Receive-----------------";
}

void ReceiveThread::processTheDatagram(const QNetworkDatagram &datagram)
{
    qInfo() << "Receive From:" << datagram.senderAddress().toString() << datagram.senderPort()
            << "To:" << datagram.destinationAddress() << datagram.destinationPort()
            << datagram.data();
}