qt 多线程实现tcp通信

Qt提供了QtConcurrent库、QThread类和信号与槽机制来实现多线程通信。下面是一个简单的示例，演示如何使用QThread类和信号与槽机制来实现TCP通信：

1. 创建一个QTcpSocket对象，并在构造函数中连接其readyRead()信号到一个槽函数，用于接收数据。

class TcpClient : public QObject
{
    Q_OBJECT

public:
    TcpClient(QObject *parent = nullptr);

public slots:
    void readData();

private:
    QTcpSocket *m_socket;
};

TcpClient::TcpClient(QObject *parent)
    : QObject(parent)
{
    m_socket = new QTcpSocket(this);
    connect(m_socket, &QTcpSocket::readyRead, this, &TcpClient::readData);
}

2. 在槽函数中读取数据并发出信号，用于将数据发送到主线程。

void TcpClient::readData()
{
    QByteArray data = m_socket->readAll();
    emit dataReceived(data);
}

3. 在主线程中创建一个TcpClient对象，并连接其dataReceived()信号到一个槽函数，用于处理接收到的数据。

class MainWindow : public QMainWindow
{
    Q_OBJECT

public:
    MainWindow(QWidget *parent = nullptr);

public slots:
    void processData(QByteArray data);

private:
    TcpClient *m_client;
};

MainWindow::MainWindow(QWidget *parent)
    : QMainWindow(parent)
{
    m_client = new TcpClient(this);
    connect(m_client, &TcpClient::dataReceived, this, &MainWindow::processData);
}

4. 在槽函数中处理接收到的数据。

void MainWindow::processData(QByteArray data)
{
    // 处理接收到的数据
}

5. 在另一个线程中连接到服务器，并发送数据。

class TcpThread : public QThread
{
    Q_OBJECT

public:
    TcpThread(QObject *parent = nullptr);

signals:
    void error(QString message);

protected:
    void run() override;

private:
    QTcpSocket *m_socket;
};

TcpThread::TcpThread(QObject *parent)
    : QThread(parent)
{
}

void TcpThread::run()
{
    m_socket = new QTcpSocket();
    m_socket->connectToHost("127.0.0.1", 12345);
    if (!m_socket->waitForConnected()) {
        emit error(m_socket->errorString());
        return;
    }

    // 发送数据
    m_socket->write("Hello world!");
    m_socket->flush();
}

6. 在主线程中创建一个TcpThread对象，并启动线程。

TcpThread *thread = new TcpThread(this);
thread->start();

通过以上步骤，就可以在Qt中实现TCP通信的多线程应用程序。