Qt开发之使用socket实现远程控制

#include <heartbeatthread.h>
 
    //心跳包线程
    heartbeatThread *ht = nullptr;
    ht = new heartbeatThread;
    ht -> start();

#ifndef HEARTBEATTHREAD_H
#define HEARTBEATTHREAD_H
 
#include <QThread>
#include <QCoreApplication>
#include <QTimer>
#include <QTcpSocket>
#include <QHostAddress>
#include <QtConcurrent/QtConcurrent>
 
using namespace std;
 
class heartbeatThread : public QThread
{
    Q_OBJECT
 
public:
    explicit heartbeatThread(QObject *parent = nullptr);
    void run(); //任务处理线程
 
    ~heartbeatThread(){
    }
 
public slots:
 
private:
    QTcpSocket *tcpSocket = nullptr;
 
protected:
};
 
#endif // HEARTBEATTHREAD_H

#include "heartbeatthread.h"
 
heartbeatThread::heartbeatThread(QObject *parent)
{
}
 
void heartbeatThread::run()
{
    tcpSocket = new QTcpSocket();
    tcpSocket->connectToHost(QHostAddress("127.0.0.1"), 5000);
 
    QtConcurrent::run([=]()
        {
        while(true)
        {
            try{    //收包
                //将接收内容存储到字符串中
                char recvMsg[1024] = {'\0'};
                int recvRe = tcpSocket->read(recvMsg, 1024);
                if(recvRe != 0 && recvRe != -1) //0:连接未发信息;-1:未连接
                {
                }
            } catch(...){}
            QEventLoop eventloop;
            QTimer::singleShot(1, &eventloop, SLOT(quit()));
            eventloop.exec();
        }
    });
 
    while(true){
        try{    //发包
            //等待连接成功
            if(!tcpSocket->waitForConnected(30000))
            {
                tcpSocket->connectToHost(QHostAddress("127.0.0.1"), 5000);
            }
            else
            {                
                QByteArray block = "block";
                tcpSocket->write(block);
                tcpSocket->flush();
            }
        } catch(...){}
        QEventLoop eventloop;
        QTimer::singleShot(1000, &eventloop, SLOT(quit()));
        eventloop.exec();
    }
}

try{    //收包
    //将接收内容存储到字符串中
    char recvMsg[1024] = {'\0'};
    int recvRe = tcpSocket->read(recvMsg, 1024);
    if(recvRe != 0 && recvRe != -1) //0:连接未发信息;-1:未连接
    {
        QString recvMessage = recvMsg;
        //字符串解析
        head = recvMessage.mid(0, HEAD_LENGTH).simplified();  //网络头，报文总长度
        type = recvMessage.mid(HEAD_LENGTH, TYPE_LENGTH).simplified();  //请求类型
        message = recvMessage.mid(HEAD_LENGTH + TYPE_LENGTH, recvMessage.length()).simplified();  //实际请求内容
        //按照字符串要求分类处理
        handle(type, message);
    }
} catch(...){}

void handle(QString type, QString message)
{
    QStringList handleOptions;
    handleOptions << "aaaa" << "bbbb" << "cccc" ;
 
    /*
    aaaa = 0
    bbbb = 1
    cccc = 2
    */
 
    switch (handleOptions.indexOf(type)) {
    case 0:
        break;
    case 1:
        break;
    case 2:
        break;
   default:
        qDebug() << "do not understand!";
        break;
    }
}