QT之远程控制对方电脑
- 时间：2022-07-09
- 浏览：
QT之远程控制对方电脑
核心代码
#ifndef CONTROLER_H
#define CONTROLER_H
#include "interface.h"
#include "mapthread.h"
#include "cmdthread.h"
#include <QTcpServer>
#include <QTcpSocket>
#include <QDebug>
#include <QHostAddress>
#include <QObject>
#include <QVector>
typedef struct SocketAndThread
{
QTcpSocket* socket;
QThread* thread;
} SocketAndThread;
class Controler : public QObject
{
Q_OBJECT
private:
QTcpServer* pCmdServer;
QTcpServer* pMapServer;
QVector<SocketAndThread>* vec;
public:
const static int DATA_HEARER_MAP = 1; //图像数据
const static int DATA_HEADER_CMD = 2; //命令数据
const static int DATA_HEARER_RES = 3; //命令结果数据
const static int MAP_SERVER_PORT = 5648;
const static int CMD_SERVER_PORT = 5649;
explicit Controler(QObject *parent = 0);
public slots:
void newMapClient();
void newCmdClient();
void someSocketDisconnected();
};
#endif // CONTROLER_H
#include "controler.h"
Controler::Controler(QObject *parent) :
QObject(parent)
{
vec = new QVector<SocketAndThread>;
pMapServer = new QTcpServer;
pMapServer->listen(QHostAddress::Any, MAP_SERVER_PORT);
qDebug()<<"map server listening"<<endl;
connect(pMapServer, SIGNAL(newConnection()), this, SLOT(newMapClient()));
pCmdServer = new QTcpServer;
pCmdServer->listen(QHostAddress::Any, CMD_SERVER_PORT);
qDebug()<<"cmd server listening"<<endl;
connect(pCmdServer, SIGNAL(newConnection()), this, SLOT(newCmdClient()));
}
/**
*每当有一个新连接时，启动一个线程单独为之服务
*/
void Controler::newMapClient()
{
QTcpSocket* clientMapSocket = pMapServer->nextPendingConnection();
qDebug()<<"new map connection:"<<clientMapSocket->peerAddress().toString()<<endl;
MapThread* mapThread = new MapThread(clientMapSocket);
connect(clientMapSocket, SIGNAL(disconnected()), this, SLOT(someSocketDisconnected()));
SocketAndThread st = {clientMapSocket, mapThread};
vec->append(st);
mapThread->start();
}
void Controler::newCmdClient()
{
QTcpSocket* clientCmdSocket = pCmdServer->nextPendingConnection();
qDebug()<<"new cmd connection:"<<clientCmdSocket->peerAddress().toString()<<endl;
CmdThread* cmdThread = new CmdThread(clientCmdSocket);
connect(clientCmdSocket, SIGNAL(disconnected()), this, SLOT(someSocketDisconnected()));
SocketAndThread st = {clientCmdSocket, cmdThread};
vec->append(st);
cmdThread->start();
}
void Controler::someSocketDisconnected()
{
for(int i = 0; i < vec->size(); i ++)
{
if(vec->at(i).socket->state() == QAbstractSocket::UnconnectedState)
{
if(vec->at(i).socket->isOpen())
vec->at(i).socket->close();
vec->at(i).thread->quit();
connect(vec->at(i).thread, SIGNAL(finished()), vec->at(i).thread, SLOT(deleteLater()));
vec->remove(i);
i --;
}
}
}
评论列表（条）