QTcpSocket – client[通俗易懂]

全栈程序员站长

发布于 2022-09-30 12:33:41

4490

发布于 2022-09-30 12:33:41

大家好，又见面了，我是你们的朋友全栈君。

#include "mainwindow.h"
#include "ui_clientWindow.h"
#include <QMessageBox>
#include <QDateTime>
MainWindow::MainWindow(QWidget *parent) :
QMainWindow(parent),
ui(new Ui::clientWindow)
{ 

ui->setupUi(this);
init();
initConnect();
}
MainWindow::~MainWindow()
{ 

delete ui;
}
void MainWindow::slotReadError(QAbstractSocket::SocketError error)
{ 

mTcpClient->disconnectFromHost();
ui->mConnectButton->setText(QStringLiteral("连接"));
mSwitch = false;
QMessageBox msgBox;
msgBox.setText(tr("failed to connect server because %1").arg(mTcpClient->errorString()));
msgBox.exec();
}
void MainWindow::slotReadData()
{ 

QByteArray buffer = mTcpClient->readAll();
if(!buffer.isEmpty())
{ 

ui->mReceiveEdit->append(QDateTime::currentDateTime().toString("yyyy-MM-dd hh:mm:ss"));
ui->mReceiveEdit->append(QString::fromUtf8(buffer));
}
}
void MainWindow::slotConnectNetwork()
{ 

if(mSwitch)
{ 
   //断开
mTcpClient->disconnectFromHost();
if (mTcpClient->state() == QAbstractSocket::UnconnectedState || mTcpClient->waitForDisconnected(1000))  //已断开连接则进入if{}
{ 

ui->mConnectButton->setText(QStringLiteral("连接"));
ui->mSendButton->setEnabled(false);
}
mSwitch = false;
}
else
{ 
   //连接
mTcpClient->connectToHost(ui->mAddrEdit->text(), static_cast<quint16>(ui->mPortEdit->text().toInt()));
if(mTcpClient->waitForConnected(1000))  // 连接成功则进入if{}
{ 

ui->mConnectButton->setText(QStringLiteral("断开"));
ui->mSendButton->setEnabled(true);
}
mSwitch = true;
}
}
void MainWindow::slotSendText()
{ 

QString data = ui->mSendTextEdit->toPlainText();
if(data.simplified().size())
{ 

mTcpClient->write(data.toUtf8());
}
ui->mSendTextEdit->clear();
}
void MainWindow::init()
{ 

setWindowTitle(QStringLiteral("Client"));
mTcpClient = new QTcpSocket(this);   //实例化tcpClient
mTcpClient->abort();                 //取消原有连接
ui->mSendButton->setEnabled(false);
}
void MainWindow::initConnect()
{ 

connect(mTcpClient, &QTcpSocket::readyRead, this,&MainWindow::slotReadData);
connect(mTcpClient, SIGNAL(error(QAbstractSocket::SocketError)),
this, SLOT(slotReadError(QAbstractSocket::SocketError)));
connect(ui->mConnectButton,&QPushButton::clicked,this,&MainWindow::slotConnectNetwork);
connect(ui->mClearButton,&QPushButton::clicked,this,[this](){ 
ui->mReceiveEdit->clear();});
connect(ui->mSendButton,&QPushButton::clicked,this,&MainWindow::slotSendText);
}