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)
{
}

标签：MySocketImp,void,Widget,timer,重连题,connect,QTcpSocket,port,QTimer
来源： https://blog.csdn.net/zzwwgg1984/article/details/122273754