Qt UDP多线程跨线程接收数据

在Qt中，可以使用多线程和信号槽机制来实现UDP跨线程接收数据。下面是一个简单的示例代码：

// WorkerThread.h

#ifndef WORKERTHREAD_H
#define WORKERTHREAD_H

#include <QObject>
#include <QUdpSocket>

class WorkerThread : public QObject
{
    Q_OBJECT
public:
    explicit WorkerThread(QObject *parent = nullptr);
    ~WorkerThread();

signals:
    void dataReceived(QByteArray data);

public slots:
    void start();

private slots:
    void readPendingDatagrams();

private:
    QUdpSocket *udpSocket;
};

#endif // WORKERTHREAD_H

// WorkerThread.cpp

#include "WorkerThread.h"

WorkerThread::WorkerThread(QObject *parent) : QObject(parent)
{
    udpSocket = new QUdpSocket(this);
}

WorkerThread::~WorkerThread()
{
    delete udpSocket;
}

void WorkerThread::start()
{
    connect(udpSocket, SIGNAL(readyRead()), this, SLOT(readPendingDatagrams()));
    udpSocket->bind(QHostAddress::AnyIPv4, 1234);
}

void WorkerThread::readPendingDatagrams()
{
    while (udpSocket->hasPendingDatagrams()) {
        QByteArray datagram;
        datagram.resize(udpSocket->pendingDatagramSize());
        udpSocket->readDatagram(datagram.data(), datagram.size());
        emit dataReceived(datagram);
    }
}

// MainWindow.h

#ifndef MAINWINDOW_H
#define MAINWINDOW_H

#include <QMainWindow>
#include <QThread>
#include "WorkerThread.h"

namespace Ui {
class MainWindow;
}

class MainWindow : public QMainWindow
{
    Q_OBJECT

public:
    explicit MainWindow(QWidget *parent = nullptr);
    ~MainWindow();

private slots:
    void on_startButton_clicked();
    void onDataReceived(QByteArray data);

private:
    Ui::MainWindow *ui;
    QThread workerThread;
    WorkerThread *worker;

signals:
    void startWorkerThread();
};

#endif // MAINWINDOW_H

// MainWindow.cpp

#include "MainWindow.h"
#include "ui_MainWindow.h"

MainWindow::MainWindow(QWidget *parent) :
    QMainWindow(parent),
    ui(new Ui::MainWindow)
{
    ui->setupUi(this);
    worker = new WorkerThread();
    worker->moveToThread(&workerThread);
    connect(this, SIGNAL(startWorkerThread()), worker, SLOT(start()));
    connect(worker, SIGNAL(dataReceived(QByteArray)), this, SLOT(onDataReceived(QByteArray)));
}

MainWindow::~MainWindow()
{
    delete ui;
    worker->deleteLater();
}

void MainWindow::on_startButton_clicked()
{
    workerThread.start();
    emit startWorkerThread();
}

void MainWindow::onDataReceived(QByteArray data)
{
    // 在这里处理接收到的数据
    // ...
}

在这个示例中，我们创建了一个WorkerThread类来处理UDP接收数据的工作。该类在一个单独的线程中执行，并通过信号槽机制与主线程通信。主线程中的MainWindow类负责启动WorkerThread并处理接收到的数据。

当点击MainWindow中的startButton按钮时，会启动WorkerThread，并发出startWorkerThread信号。WorkerThread会创建一个QUdpSocket对象并绑定到本地的任意IPv4地址和指定的端口上。当有数据到达时，会通过信号槽机制将数据传递给MainWindow类的onDataReceived槽函数进行处理。

注意，在多线程编程中，要确保跨线程访问的对象的生命周期正确管理，避免出现悬挂指针或内存泄漏等问题。在上面的示例中，我们使用了worker->deleteLater()来确保WorkerThread对象在合适的时候被删除。

希望以上示例能帮助到你！如果有任何问题，请随时提问。