QTcpSocket服务器 定时器，多线程结合

QTcpsocket 写服务器程序时，需要定时向客户端发送监控数据，同时需要响应客户端请求。
           

问题是： QTcpSocket 只能在同一个线程中使用，定时器会在主线程中运行
           

解决方案：在定时器中发送信号给封装的客户端数据处理socket，并在线程中将该信号与socket中的操作相连接。
           

//clientsocket.h
#ifndef CLIENTSOCKET_H
#define CLIENTSOCKET_H


#include <QTcpSocket>
#include <QTimer>


class ClientSocket : public QTcpSocket
{
	Q_OBJECT


public:
	ClientSocket(QObject *parent);
	~ClientSocket();


signals:
	void sigReadData(const QString &data);


public slots:
	void slotTimeOut();
	void slotReadyRead();
	void slotWriteData(const QString& data);


private:
	QTimer* _timer;
	
};


#endif // CLIENTSOCKET_H


// clientSocket.cpp
#include "clientsocket.h"
#include <QDebug>


ClientSocket::ClientSocket(QObject *parent)
	: QTcpSocket(parent)
{
	connect(this, &QAbstractSocket::readyRead, this, &ClientSocket::slotReadyRead);


	//_timer = new QTimer(this);
	//connect(_timer, &QTimer::timeout, this, &ClientSocket::slotTimeOut);
	//_timer->start(2000);
}


ClientSocket::~ClientSocket()
{


}


void ClientSocket::slotReadyRead()
{
	QString recv = readAll();
	emit sigReadData(recv);


}


void ClientSocket::slotTimeOut()
{
	write(QByteArray(this->objectName().toStdString().c_str()));
}


void ClientSocket::slotWriteData(const QString& data)
{
	write(data.toStdString().c_str());
	flush();
}


//serverListener.h
#ifndef SERVERLISTENER_H
#define SERVERLISTENER_H


#include <QTcpServer>
#include <QTimer>
#include "clientsocket.h"


class ServerListener : public QTcpServer
{
	Q_OBJECT


public:
	ServerListener(QObject *parent);
	~ServerListener();


	virtual void incomingConnection(qintptr handle);


signals:
	void sigWriteData(const QString& data);


public slots:
	void slotReadData(const QString& data);
	void slotSendMMIDataTimeOut();


private:
	ClientSocket *_clientSock;
	QTimer* _timer;
	
};


#endif // SERVERLISTENER_H


//serverListener.cpp
#include "serverlistener.h"
#include <QThread>
#include <QDebug>


ServerListener::ServerListener(QObject *parent)
	: QTcpServer(parent)
{


}


ServerListener::~ServerListener()
{


}


void ServerListener::incomingConnection(qintptr handle)
{
	_clientSock = new ClientSocket(0x00);
	_clientSock->setSocketDescriptor(handle);


	QThread *thread = new QThread(this);
	_clientSock->moveToThread(thread);
	_timer = new QTimer(this);
	connect(_clientSock, &ClientSocket::sigReadData, this, &ServerListener::slotReadData);
	connect(this, &ServerListener::sigWriteData, _clientSock, &ClientSocket::slotWriteData);
	connect(_timer, &QTimer::timeout, this, &ServerListener::slotSendMMIDataTimeOut);


	_timer->start(2000);
	thread->start();
}


void ServerListener::slotReadData(const QString& data)
{
	qDebug() << data;
}


void ServerListener::slotSendMMIDataTimeOut()
{
	QString data = QString::fromLocal8Bit("Ryan data");
	//_clientSock->write(data.toStdString().c_str()); //如果在这里的话，就会报错
	emit ServerListener::sigWriteData(data);
}




//main.cpp
#include "serverlistener.h"
#include <QtCore/QCoreApplication>
#include <QHostAddress>


int main(int argc, char *argv[])
{
	QCoreApplication a(argc, argv);


	ServerListener listener(0x00);
	listener.listen(QHostAddress::Any, 6000);


	return a.exec();
}