需求

        預言專案需要寫個qt伺服器，終端與qt伺服器完成socket通訊，因存在多個裝置，單個傳輸檔案大小比較大，所以做多執行緒併發。

實現原理

        客戶端：固定client的執行緒數量，單個執行緒按照設定的間隔不斷髮送資料給伺服器，並接收伺服器的執行緒指標地址。

        服務端：主執行緒為TcpServer，當有一個新連線的時候，會new一個執行緒處理該新連線socket，接收資料後傳送處理該socket的執行緒地址。

Demo

受限說明

        1.同一時刻該應用最大限度的執行緒數，如果超過則仍然會new，然後列印失敗，但是仍然會跑new執行緒的建構函式；

        2.下載原始碼可以將客戶端的時間間隔改下，同時執行執行緒數增大，IDE的qDebug可以看到停止後，index沒有歸零，仔細翻閱除錯資訊，可以找到“錯誤”，此條，以便讀者自己可以使用原始碼嘗試該問題。

        3.寫伺服器時，應對最大執行緒數做限制，此Demo只是專案過程中關鍵功能的記錄，未做處理。

實現截圖

關鍵程式碼

客戶端

單個執行緒socket請求程式碼 TcpClientThread.h

#ifndefTCPCLIENTTHREAD_H

#defineTCPCLIENTTHREAD_H

#include<QThread>

#include<QTcpSocket>

#include<QByteArray>

#include<QHostAddress>

/************************************************************\
 

*類名：TcpClientThread

*描述：執行緒迴圈使用QTcpClient連線伺服器傳送資料、接收資料、斷開

*訊號：

*recvMsg()-收到客戶端的的資料

*函式：

*TcpClientThread()-傳入ip，port，間隔時間（ms）

*start()-開啟執行緒

*stop()-停止

*作者：紅模仿QQ：21497936

*日期版本號描述

*2018年04月13日v1.0.0指定間隔向指定ip和port傳送資料、接收資料

\************************************************************/

classTcpClientThread:publicQThread
 

{

Q_OBJECT

public:

explicitTcpClientThread(QStringip,quint16port,intms=1000,QObject*parent=nullptr);

signals:

voidrecvData(QByteArraydata);

publicslots:

voidstop();

protected:

voidrun();

private:

QTcpSocket*_pTcpSocket;

QString_ip;

quint16_port;

bool_running;

int_ms;

};

#endif//TCPCLIENTTHREAD_H

TcpClientThread.cpp

#include "tcpclientthread.h"
#include <QDebug>

TcpClientThread::TcpClientThread(QString ip, quint16 port, int ms, QObject *parent)
    : QThread(parent)
{
    _ip = ip;
    _port = port;
    _ms = ms;
}

void TcpClientThread::stop()
{
    _running = false;
}

void TcpClientThread::run()
{
    _running = true;
    // 多執行緒new的物件不要直接指定父類，到時可以類似於下面指定父類
    // 直接指定錯誤,提示
    // QObject: Cannot create children for a parent that is in a different thread.
    // (Parent is TcpClientThread(0x1b4b2f28), parent's thread is QThread(0xcb6bcd0),
    // current thread is TcpClientThread(0x1b4b2f28)
    _pTcpSocket = new QTcpSocket();
    // 示例說明：可以指定本執行緒中new的類作為父類，因為_pTcpSocket是在本類中new的
//    _pTcpSocket = new QTcpSocket(_pTcpSocket);
    while(true)
    {
        if(!_running)
        {
            qDebug() <<__FILE__<<__LINE__ << "exit from thread";
            break;
        }
        _pTcpSocket->connectToHost(QHostAddress(_ip), _port);
        if(!_pTcpSocket->waitForConnected())
        {
            qDebug() <<__FILE__<<__LINE__ << "Failed to connect to host"
                     << QHostAddress(_ip).toString() << ":" << _port
                     << _pTcpSocket->errorString();
            continue;
        }
        QString data = "test infomation";
        _pTcpSocket->write(data.toUtf8());
        _pTcpSocket->waitForBytesWritten(3000);
        _pTcpSocket->waitForReadyRead(3000);
        QByteArray byteArray = _pTcpSocket->readAll();
        _pTcpSocket->disconnectFromHost();
        emit recvData(byteArray);
        QThread::msleep(_ms);
    }
    delete _pTcpSocket;
}

伺服器端

newConnection執行緒處理程式碼Thread.h

#ifndefTHREAD_H

#defineTHREAD_H

#include<QObject>

#include<QThread>

#include<QTcpSocket>

#include<QDebug>

#include<QMutexLocker>

/************************************************************\

*類名：Thread

*描述：伺服器端，執行緒處理新連線的socket

*訊號：

*Thread()-傳入socket描述符，注意型別是qintptr,不是int

*error()-錯誤資訊

*recvMsg()-收到客戶端的的資料

*函式：

*TcpClientThread()-傳入ip，port，間隔時間（ms）

*start()-開啟執行緒

*stop()-停止

*作者：紅模仿QQ：21497936

*日期版本號描述

*2018年04月13日v1.0.0處理收到的資訊

\************************************************************/

#defineDEBUGqDebug()<<__FILE__<<__LINE__<<__FUNCTION__<<"currentthread:"<<QThread::currentThread()

classThread:publicQThread

{

Q_OBJECT

public:

explicitThread(qintptrsocketDescriptor,QThread*parent=nullptr);

~Thread();

signals:

voiderror(QStringerrorString);

voidrecvMsg(QStringmsg);

protectedslots:

voidreadyRead();

protected:

voidrun();

private:

qintptr_socketDescriptor;

QTcpSocket*_pTcpSoscket;

staticint_count;

staticQMutex_mutex;

int_index;

};

#endif//THREAD_Hsa

Thread.cpp

#include "thread.h"
#include <QHostAddress>

int Thread::_count = 0;
QMutex Thread::_mutex;

Thread::Thread(qintptr socketDescriptor, QThread *parent)
    : QThread(parent)
{
    _socketDescriptor = socketDescriptor;
    DEBUG;
    _mutex.lock();
    _index = _count;
    _count++;
    DEBUG << _count;
    _mutex.unlock();
}

Thread::~Thread()
{
    DEBUG;
    _mutex.lock();
    _count--;
    DEBUG  << _count;
    _mutex.unlock();
}

void Thread::readyRead()
{
    DEBUG;
    QString msg;
    QByteArray recvData = _pTcpSoscket->readAll();
    _mutex.lock();
    QByteArray sendData = QString("伺服器處理該socket的執行緒地址為：%1, index:%2").arg((quint64)QThread::currentThread()).arg(_index).toUtf8() ;
    _mutex.unlock();
    _pTcpSoscket->write(sendData);
    _pTcpSoscket->waitForBytesWritten(1000);
    _pTcpSoscket->close();
    msg += QString(recvData) + ", sendTo" + _pTcpSoscket->peerAddress().toString() + QString(":%1").arg(_pTcpSoscket->peerPort()) + QString(sendData);
    emit recvMsg(msg);
}

void Thread::run()
{
    DEBUG;
    _pTcpSoscket = new QTcpSocket;
    if(!_pTcpSoscket->setSocketDescriptor(_socketDescriptor))
    {
        emit error(_pTcpSoscket->errorString());
        return;
    }
    // Qt::DirectConnection 執行緒內傳遞訊息，若使用預設的，則會在主執行緒當中處理
    connect(_pTcpSoscket, SIGNAL(readyRead()), this, SLOT(readyRead()), Qt::DirectConnection);
    connect(_pTcpSoscket, SIGNAL(disconnected()), this, SLOT(quit()));
    exec();
}