你一定能看懂的QT TCP服务器与客户端通信实例

清疚 2023-01-23 05:58 5阅读 0赞

**目录**

程序运行效果

可执行程序

界面设计

服务器端代码

客户端代码

服务器端代码详解

客户端代码详解

--------------------

##  ##

## 程序运行效果 ##

首先来看一下程序实现的效果，观看时请注意选择清晰度为“**超清**”

## 可执行程序 ##

如果想体验一下服务器和客户端收发消息的效果，可以从下面网盘连接下载exe运行

链接：[https://pan.baidu.com/s/1TPNPURRPUHIui7rYnNRMmw][https_pan.baidu.com_s_1TPNPURRPUHIui7rYnNRMmw]   
提取码：n9lg

我用的是QT5.9.5，网盘中未上传DLL，如果直接运行报错缺少dll，需要大家自行去自己的QT安装目录拷贝dll文件或通过其它渠道获取。

## 界面设计 ##

为了简单而又准确的展示我的界面，这里我附上服务器端和客户端的设计图，都是直接拖的控件，大家可以结合本文后面小节的代码看。

服务器端界面

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2pvbGluNjc4_size_16_color_FFFFFF_t_70][]

客户端界面

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2pvbGluNjc4_size_16_color_FFFFFF_t_70 1][]

## 服务器端代码 ##

MyTcpServerTest.h

#pragma once
    
    #include <QtWidgets/QMainWindow>
    #include "ui_MyTcpServer.h"
    #include "QTcpServer"
    #include "QTcpSocket"
    
    class MyTcpServerTest : public QMainWindow
    {
        Q_OBJECT
    
    public:
        MyTcpServerTest(QWidget *parent = Q_NULLPTR);
    
    private slots:
        void SendDataToClient();
        void InitTcpClient();
        void ReadDataFromClient();
    
    private:
        Ui::MyTcpServerClass ui;
        QTcpServer m_tcpServer;//必须定义一个QTcpServer变量用于监听客户端连接请求，以及收发数据
        QTcpSocket *m_pTcpClient;//定义此变量用于保存已成功连接服务器的客户端标识
    };

MyTcpServerTest.cpp

#include "MyTcpServerTest.h"
    #include "QMessageBox"
    
    MyTcpServerTest::MyTcpServerTest(QWidget *parent)
        : QMainWindow(parent), m_tcpServer(parent)
    {
        ui.setupUi(this);
    
        m_pTcpClient = NULL;
    
        //监听客户端连接请求
        if (!m_tcpServer.listen(QHostAddress::LocalHost, 10000))
        {
            QMessageBox::critical(NULL, QString("ERROR"), m_tcpServer.errorString(), QMessageBox::Ok
                , QMessageBox::NoButton);
            close();
    
        }
    
        //为“已建立新的连接”信号，设置一个响应函数
        connect(&m_tcpServer, SIGNAL(newConnection()), this, SLOT(InitTcpClient()));
    
        //点击发送按钮时，向服务器端发送消息
        connect(ui.pushButton, SIGNAL(clicked()), this, SLOT(SendDataToClient()));
    }
    
    void MyTcpServerTest::SendDataToClient()
    {
        QString msg = ui.textEdit->toPlainText();//获取在界面输入的文本
        if (m_pTcpClient->isOpen()) {
            QByteArray sendMessage = msg.toUtf8();
            m_pTcpClient->write(sendMessage);//向服务器端发送消息
            m_pTcpClient->flush();
        }
    }
    
    void MyTcpServerTest::InitTcpClient()
    {
        //保存客户端连接标识
        m_pTcpClient = m_tcpServer.nextPendingConnection();
    
        //收到断开连接信号时，调用deleteLater释放资源
        connect(m_pTcpClient, SIGNAL(disconnected()), m_pTcpClient, SLOT(deleteLater()));
        
        //为读取数据信号设置响应函数
        connect(m_pTcpClient, SIGNAL(readyRead()), this, SLOT(ReadDataFromClient()));
    }
    
    void MyTcpServerTest::ReadDataFromClient()
    {
        QByteArray arrRcvData = m_pTcpClient->readAll();//读取客户端发送过来的数据
        if (!arrRcvData.isEmpty())
        {
            ui.textBrowser->append(arrRcvData);//把收到的消息显示到界面上
        }
    }

## 客户端代码 ##

MyTcpClient.h

#pragma once
    
    #include <QtWidgets/QMainWindow>
    #include "ui_MyTcpClient.h"
    #include "QTcpSocket"
    
    
    class MyTcpClient : public QMainWindow
    {
        Q_OBJECT
    
    public:
        MyTcpClient(QWidget *parent = Q_NULLPTR);
    
    private slots:
    
        //读取服务器端发送过来的数据
        void ReadDataFromTcpServer();
    
        //发送数据到服务器端
        void SendDataToTcpServer();
    
        //获取通信错误
        void ReadError(QAbstractSocket::SocketError error);
    
    
    private:
        Ui::MyTcpClientClass ui;
    
        QTcpSocket *tcpClient;//必须定义一个QTcpSocket变量，用于和服务器建立连接，以及收发数据
    };

MyTcpClient.cpp

#include "MyTcpClient.h"
    #include "QMessageBox"
    #include "QHostAddress"
    
    
    MyTcpClient::MyTcpClient(QWidget *parent)
        : QMainWindow(parent)
    {
        ui.setupUi(this);
    
        tcpClient = new QTcpSocket(this);
        tcpClient->abort();//取消已有连接
        tcpClient->connectToHost(QHostAddress::LocalHost,10000);//连接到本机服务器10000端口
    
        //为读取数据信号设置响应函数
        connect(tcpClient, SIGNAL(readyRead()), this, SLOT(ReadDataFromTcpServer()));
    
        //为通信错误信号设置响应函数
        connect(tcpClient, SIGNAL(error(QAbstractSocket::SocketError)), this
            , SLOT(ReadError(QAbstractSocket::SocketError)));
    
        //点击发送按钮时，执行发送数据函数
        connect(ui.pushButton, SIGNAL(clicked()), this, SLOT(SendDataToTcpServer()));
    
        //设置等待时间为30秒，30秒内还未连接成功，返回false
        if (tcpClient->waitForConnected(30000))
        {
            //已连接到服务器
        }
        else 
        {
            //未连接服务器
        }
    }
    
    
    void MyTcpClient::ReadDataFromTcpServer()
    {
        QByteArray arrRcvData = tcpClient->readAll();//读取服务器发来的数据
        if (!arrRcvData.isEmpty())
        {
            ui.textBrowser->append(arrRcvData);//把收到的消息显示到界面上
        }
    }
    
    
    void MyTcpClient::ReadError(QAbstractSocket::SocketError error)
    {
        QMessageBox::warning(this,"WARNING", "The connection to the server has been lost！"
            , QMessageBox::Ok, QMessageBox::NoButton);
        tcpClient->disconnectFromHost();//断开通信连接
    }
    
    void MyTcpClient::SendDataToTcpServer() 
    {
        QString msg = ui.textEdit->toPlainText();//获取在界面输入的文本
        if (tcpClient->isOpen()) {
            QByteArray sendMessage = msg.toUtf8();
            tcpClient->write(sendMessage);//发送数据给服务器
            tcpClient->flush();
        }
    }

## 服务器端代码详解 ##

待后续添加

## 客户端代码详解 ##

待后续添加

[https_pan.baidu.com_s_1TPNPURRPUHIui7rYnNRMmw]: https://pan.baidu.com/s/1TPNPURRPUHIui7rYnNRMmw
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2pvbGluNjc4_size_16_color_FFFFFF_t_70]: /images/20221004/848dc675fe6a407bb0459d3f3d522684.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2pvbGluNjc4_size_16_color_FFFFFF_t_70 1]: /images/20221004/997cf75da8a14ddba1231b004180099c.png