[网络协议]QTcpSocket自动重连题 难道QTimer 还有坑?

?一直在弄 QT Tcp 客户端断线重连，之前方式为定时器槽触发后发起连接，如下，但定时器貌似不触发??????/

初版//

#include "mysocketImp.h"
MySocketImp::MySocketImp(QHostAddress ip, int port, int sockDesc, QObject *parent) :
?? ?MySocket(sockDesc,parent), status(false),m_ip(ip),m_port(port)
{
?? ?connect(this, SIGNAL(disconnected()), this, SLOT(dostateDisConnected()));
?? ?connect(this, SIGNAL(connected()), this, SLOT(dostateConnected()));
?? ?connect(&m_timer, SIGNAL(timeout()), this, SLOT(slotTimeout()));
?? ?//m_timer.start(3000);
?? ?//connect(&m_timer, &QTimer::timeout, this, &MySocketImp::slotTimeout);
}

MySocketImp::~MySocketImp()
{

}

void MySocketImp::Connect(const QHostAddress &ip, const int &port)
{
?? ?/*this->connectToHost(ip,port);
?? ?if(!this->waitForConnected(50))
?? ?{
?? ??? ?QString str = this->errorString();
?? ?}*/
?? ?m_timer.setInterval(3000);
?? ?m_timer.start();
?? ?this->connectToHost(ip, port);
?? ?if (!this->waitForConnected(50))
?? ?{
?? ??? ?//m_timer.stop();
?? ??? ?QString str = this->errorString();
?? ??? ?/*m_timer.setInterval(3000);
?? ??? ?m_timer.start();*/
?? ?}

}

void MySocketImp::slotTimeout()
{
?? ?if(!status)
?? ?{
?? ??? ?this->Connect(m_ip,m_port);//Connect
?? ?}
}
void MySocketImp::dostateConnected()
{
?? ?m_timer.stop();
?? ?status = true;
}
void MySocketImp::dostateDisConnected()
{
?? ?status = false;
?? ?this->abort();
?? ?m_timer.setInterval(3000);
?? ?m_timer.start(3000);
}

//改版

#include "mysocketImp.h"
MySocketImp::MySocketImp(QHostAddress ip, int port, int sockDesc, QObject *parent) :
?? ?MySocket(sockDesc,parent), status(false),m_ip(ip),m_port(port)
{
?? ?connect(this, SIGNAL(disconnected()), this, SLOT(dostateDisConnected()));
?? ?connect(this, SIGNAL(connected()), this, SLOT(dostateConnected()));
?? ?//connect(&m_timer, SIGNAL(timeout()), this, SLOT(slotTimeout()));
?? ?//m_timer.start(3000);
?? ?connect(&m_timer, &QTimer::timeout, this, &MySocketImp::slotTimeout);
?? ?m_timer.start(3000);
}

MySocketImp::~MySocketImp()
{

}

void MySocketImp::Connect(const QHostAddress &ip, const int &port)
{
?? ?this->connectToHost(ip,port);
?? ?if(!this->waitForConnected(50))
?? ?{
?? ??? ?QString str = this->errorString();
?? ?}
?? ?//m_timer.setInterval(3000);
?? ?//m_timer.start();
?? ?//this->connectToHost(ip, port);
?? ?//if (!this->waitForConnected(50))
?? ?//{
?? ?//?? ?//m_timer.stop();
?? ?//?? ?QString str = this->errorString();
?? ?//?? ?/*m_timer.setInterval(3000);
?? ?//?? ?m_timer.start();*/
?? ?//}
}

void MySocketImp::slotTimeout()
{
?? ?if(!status)
?? ?{
?? ??? ?this->Connect(m_ip,m_port);//Connect
?? ?}
}
void MySocketImp::dostateConnected()
{
?? ?//m_timer.stop();
?? ?status = true;
}
void MySocketImp::dostateDisConnected()
{
?? ?status = false;
?? ?//this->abort();
?? ?//m_timer.setInterval(3000);
?? ?//m_timer.start(3000);
}

/参考//

class?Widget?:?public?QWidget
{
????Q_OBJECT
public:
????explicit?Widget(QWidget?*parent?=?0);
????~Widget();
private?slots:
????void?readMessage();
????void?displayError(QAbstractSocket::SocketError);
????void?sendMessage();

????void?connected();
????void?disconnected();
????void?onError(QAbstractSocket::SocketError);
????void?onProgress();
private:
????QTcpSocket*?tcpsocket;
????bool?flag;
????QTimer?timer;
????QString?message;
????QPushButton*?button;
};

Widget::Widget(QWidget*?parent):
????QWidget(parent)
{
????button?=?new?QPushButton("Send");
????QVBoxLayout*?layout?=?new?QVBoxLayout(this);
????layout->addWidget(button);

????connect(button,SIGNAL(clicked()),this,SLOT(sendMessage()));

????tcpsocket?=?new?QTcpSocket(this);
????flag?=?false;
????//tcpsocket->abort();
????//tcpsocket->connectToHost("10.2.100.63",80);
????connect(tcpsocket,SIGNAL(readyRead()),this,SLOT(readMessage()));
????connect(tcpsocket,SIGNAL(connected()),this,SLOT(connected()));
????connect(tcpsocket,SIGNAL(disconnected()),this,SLOT(disconnected()));
????connect(tcpsocket,SIGNAL(error(QAbstractSocket::SocketError)),this,SLOT(onError(QAbstractSocket::SocketError)));

????connect(&timer,SIGNAL(timeout()),this,SLOT(onProgress()));
????timer.start(1800);
}

Widget::~Widget()
{
}

void?Widget::onProgress()
{
????if(flag?==?false)
????{
????????tcpsocket->abort();
????????tcpsocket->connectToHost("10.2.100.63",80);
????}
}

void?Widget::readMessage()
{
????QString?tag?=?tcpsocket->readAll();
????std::cout<<"tag:"<<tag.size()<<std::endl;
}

void?Widget::displayError(QAbstractSocket::SocketError)
{
????qDebug()?<<?tcpsocket->errorString();
}

void?Widget::sendMessage()
{
????std::cout<<"write?callback?data."<<std::endl;
????tcpsocket->write("ok");????
}

void?Widget::connected()
{
????flag?=?true;
}

void?Widget::disconnected()
{
????flag?=?false;
}

void?Widget::onError(QAbstractSocket::SocketError)
{
}