TCP服務(wù)器斷開連接自動重聯(lián)機(jī)制

客戶端加入定時器實(shí)現(xiàn)斷線重聯(lián)(客戶端服務(wù)端代碼見上一篇博客)

編譯環(huán)境:Qt 5.9.5

ui界面如圖:

代碼如下

tcpclient.h

#ifndef TCPCLIENT_H #define TCPCLIENT_H#include <QWidget> #include <QTcpSocket> #include <QTimer> #include <iostream> #include <string> using namespace std;namespace Ui { class TcpClient; }class TcpClient : public QWidget {Q_OBJECTpublic:explicit TcpClient(QWidget *parent = 0);~TcpClient();protected:void newTcpConnect();void init();private slots://void on_pushButtonEnter_clicked();void slotconnectedsuccess(); //處理連接成功的信號void slotreceive(); //接收服務(wù)器傳過來的信息void on_pushButtonSend_clicked();void slotdisconnected(); //處理離開聊天室的信號void slotTimeout(); //處理timeou信號void connectButton();private:Ui::TcpClient *ui;bool status; //用來判斷是否進(jìn)入了服務(wù)器size_t strSize;int port;QHostAddress *serverIP;QString userName;QTcpSocket *tcpsocket;QTimer m_timer;};#endif // TCPCLIENT_H

tcpclient.cpp

#include "tcpclient.h" #include "ui_tcpclient.h" #include <QHostAddress> #include <QMessageBox> #include <QDebug>TcpClient::TcpClient(QWidget *parent) :QWidget(parent),ui(new Ui::TcpClient) {ui->setupUi(this);//將進(jìn)入服務(wù)器的標(biāo)志位置為falsestatus = false;//未連接內(nèi)不能發(fā)送信息ui->pushButtonSend->setEnabled(false);init(); }TcpClient::~TcpClient() {delete ui; }void TcpClient::init() {port = 8888;ui->lineEditServerPort->setText(QString::number(port));QString ip = ui->lineEditServerIp->text();userName = ui->lineEditUserName->text();tcpsocket = new QTcpSocket(this);//tcpsocket->connectToHost(ip, port);connect(ui->pushButtonEnter, &QPushButton::clicked, this, &TcpClient::connectButton);connect(tcpsocket, &QTcpSocket::connected, this, &TcpClient::slotconnectedsuccess);connect(tcpsocket, &QTcpSocket::readyRead, this, &TcpClient::slotreceive);connect(tcpsocket, &QTcpSocket::disconnected, this, &TcpClient::slotdisconnected);connect(&m_timer, &QTimer::timeout, this, &TcpClient::slotTimeout);}void TcpClient::connectButton() {if(ui->pushButtonEnter->text() == "連接服務(wù)器") {newTcpConnect();//tcpsocket->disconnectFromHost();}else if(ui->pushButtonEnter->text() == "離開服務(wù)器") {tcpsocket->disconnectFromHost();//newTcpConnect();} }//用來處理連接成功的信號 void TcpClient::slotconnectedsuccess() {m_timer.stop(); //連接成功后定時器停止status = true;ui->textEdit->append("連接成功");ui->pushButtonSend->setEnabled(true);ui->pushButtonEnter->setText("離開服務(wù)器"); QString msg = userName + ": connected";tcpsocket->write(msg.toUtf8().data()); }void TcpClient::slotreceive() {QByteArray array = tcpsocket->readAll();QString strHead = QString(array).section(" ", 0, 0);QString strText = QString(array).section(" ", 1, 1);QString buf = userName + ":";if(strHead == buf) {ui->textEdit->append(buf + strText);}}void TcpClient::on_pushButtonSend_clicked() {//獲取編輯區(qū)內(nèi)容QString str = ui->lineEditSend->text();//加頭信息qint64 textSize = str.size();QString strHead = QString("%1##%2##%3").arg(userName + ": ").arg(textSize).arg(str);tcpsocket->write(strHead.toUtf8().data());ui->lineEditSend->clear(); }void TcpClient::slotdisconnected() { m_timer.start(2000); //連接斷開時開啟定時器，定時時間為2sstatus == false;ui->textEdit->append("斷開連接");ui->pushButtonSend->setEnabled(false);ui->pushButtonEnter->setText("連接服務(wù)器");}void TcpClient::slotTimeout() {qDebug() << "重聯(lián)服務(wù)器222222222";if(status == true) {qDebug() << "重聯(lián)服務(wù)器";ui->textEdit->append("重聯(lián)服務(wù)器...");newTcpConnect();} }void TcpClient::newTcpConnect() {tcpsocket->abort();port = 8888;ui->lineEditServerPort->setText(QString::number(port));QString ip = ui->lineEditServerIp->text();tcpsocket->connectToHost(ip, port);if (!tcpsocket->waitForConnected(3000)) {//連接時長為3s，超過3秒連不上則輸出錯誤信息//QMessageBox::warning(this, "錯誤", "連接超時");}}

總結(jié)

以上是生活随笔為你收集整理的[Qt] TCP客户端与服务器断开连接自动重联机制的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。