QT网络（二）：TCP通信

devtools/2024/12/22 7:53:03/

传输层概念

传输控制协议（transmission control protocol，TCP）是一种被大多数 Internet 网络协议用于数据传输的底层网络协议，它是可靠的、面向流和连接的传输协议，特别适合用于连续数据传输。

应用层在网络模型中的层次如下所示：

 传输层管理着端到端的通信，即主机到主机的通信。它的主要职责是为不同主机上的应用程序（占用不同端口）提供数据传输，同时保证这些数据的完整性和可靠性。

网络中还有一个IP协议概念，它与TCP的区分如下图所示：

IP协议属于网络层，是在TCP的报文基础上多了一个头部信息，例如在下列通信过程中，发送和接收的信息在每一层中通过该层的协议进行封包和拆包，最终实现通信。

通常IP层协议已经封装在操作系统中的IP协议栈中用于实现PC---PC的通信（这里的PC是不同的PC），开发QT应用程序时，实际上是PC上的进程，此时使用的是TCP和UDP，实现的是PC(A)----PC(B)的通讯（这里的PC可以是不同的PC，也可以是同一台PC，同一台时就是所谓的IPC主机内通信），A、B为计算机中的进程（可以理解为QT应用程序）。

TCP是面向连接的可靠传输协议，因此TCP 通信必须先建立 TCP 连接，通信端分为客 户端和服务器端Qt 提供 QTcpSocket 类和 QTcpServer 类，用于设计 TCP 通信应用程序。 服务器端程序必须使用 QTcpServer 进行端口监听，建立服务器；使用 QTcpSocket 建立连接，然后使用套接字（socket）进行通信。

相关的类介绍

QTcpServer类

QTcpServer 主要用于在服务器端进行网络监听，创建网络 socket 连接。该类提供的主要函数接口如下表所示，表中列出了函数的返回值，省略了函数的输入参数。

函数 listen()开始服务器端监听，可以设置监听的 IP 地址和端口，一般一个服务器端程序只监听某个端口的网络连接。

当有新的客户端接入时，QTcpServer 内部的函数 incomingConnection()会创建一个与客户端 连接的 QTcpSocket 对象，然后发射 newConnection()信号。在与 newConnection()信号关联的槽函数中，我们可以用 nextPendingConnection()接受客户端的连接，然后使用 QTcpSocket 对象与客户端通信。

所以最后数据通信是通过QTcpSocket类对象完成的，QTcpSocket 类提供了 TCP 的接口，可以用 QTcpSocket 类实现标准的网络通信协议，如 POP3、SMTP 和 NNTP 等（这些协议属于上层协议，也就是应用层），也可以设计自定义协议。

QTcpSocket类

由于 QTcpSocket继承了QAbstractSocket类，而QAbstractSocket又继承了QIODevice类，因此QTcpSocket是一种I/O类设备，具有流数据读写功能，其他大部分的功能函数都继承自QAbstractSocket类。QAbstractSocket类的主要接口函数如下表（省略了函数的输入参数）

TCP 客户端使用 QTcpSocket 对象与 TCP 服务器端建立连接并通信。客户端的 QTcpSocket 对象首先通过 connectToHost()尝试连接到服务器，该函数需要指定服务器的 IP 地址和端口。函数 connectToHost()以异步方式连接到服务器，不会阻塞程序运行，成功连接后 QTcpSocket 对象发 射 connected()信号。

客户端和服务器端建立 socket 连接后，各自的 QTcpSocket 对象就可以向缓冲区写数据或从接收缓冲区读取数据，实现数据通信。当缓冲区有新数据进入时，QTcpSocket 对象会发射readyRead() 信号，我们一般在此信号的槽函数里读取缓冲区数据。接收与发送是异步工作的，有各自的缓冲区。

TCP 服务器端程序设计

主窗口MainWindow头文件

#ifndef MAINWINDOW_H
#define MAINWINDOW_H#include <QMainWindow>
#include    <QTcpServer>
#include    <QLabel>QT_BEGIN_NAMESPACE
namespace Ui { class MainWindow; }
QT_END_NAMESPACEclass MainWindow : public QMainWindow
{Q_OBJECTprivate:QLabel  *labListen;         //状态栏标签QLabel  *labSocketState;    //状态栏标签QTcpServer *tcpServer;             //TCP服务器QTcpSocket *tcpSocket=nullptr;     //TCP通讯的SocketQString getLocalIP();              //获取本机IP地址
//protected:
//    void    closeEvent(QCloseEvent *event);   //close事件处理函数
public:MainWindow(QWidget *parent = nullptr);~MainWindow();      //析构函数里需要做一些处理，以保证断开与客户端的连接，并停止网络监听private slots://自定义槽函数void    do_newConnection();         //关联QTcpServer的newConnection()信号void    do_socketStateChange(QAbstractSocket::SocketState socketState);void    do_clientConnected();       //客户端 socket 已连接void    do_clientDisconnected();    //客户端 socket 已断开void    do_socketReadyRead();       //读取socket传入的数据//UI生成的void on_actStart_triggered();     //开始监听void on_actStop_triggered();      //停止监听void on_actClear_triggered();     //清空文本框void on_btnSend_clicked();        //发送消息void on_actHostInfo_triggered();  //接收消息
private:Ui::MainWindow *ui;
};#endif // MAINWINDOW_H

变量 tcpServer 用于建立 TCP 服务器，变量tcpSocket 用于与客户端进行 socket 连接和通信。

在主窗口的构造函数中，首先获取本机IP地址并打印，然后创建TCP服务器QTcpServer 对象 tcpServer并将newConnection() 信号与自定义槽函数 do_newConnection()关联。

MainWindow::MainWindow(QWidget *parent) :QMainWindow(parent),ui(new Ui::MainWindow)
{ui->setupUi(this);labListen=new QLabel("监听状态:");labListen->setMinimumWidth(150);ui->statusBar->addWidget(labListen);labSocketState=new QLabel("Socket状态：");labSocketState->setMinimumWidth(200);ui->statusBar->addWidget(labSocketState);QString localIP=getLocalIP();   //获取本机IP地址this->setWindowTitle(this->windowTitle()+"----本机IP地址："+localIP);ui->comboIP->addItem(localIP);tcpServer=new QTcpServer(this); //创建TCP服务器connect(tcpServer,SIGNAL(newConnection()),this,SLOT(do_newConnection()));
}QString MainWindow::getLocalIP()
{//获取本机IPv4地址QString hostName=QHostInfo::localHostName();    //本地主机名QHostInfo hostInfo=QHostInfo::fromName(hostName);QString   localIP="";QList<QHostAddress> addList=hostInfo.addresses();  //本机IP地址列表if (addList.isEmpty())return localIP;foreach(QHostAddress aHost, addList)if (QAbstractSocket::IPv4Protocol==aHost.protocol()){//如果本机装有虚拟机软件，设置了VMnetx以太网适配器,可能会返回这些网络的地址localIP=aHost.toString();// break;qDebug()<<localIP<<Qt::endl;}return localIP;
}

获取本机IP地址使用往期博客讲解的localHostName()和fromName()来从主机名中获取了QHostInfo类型的对象，通过改对象的addresses()韩素华就可以获取本机IP地址列表，

这里需要注意的是，例程中直接返回了找到的第一个IPv4地址。如果有多个IPv4地址还需要根据其他条件判断来取舍。

在析构函数中，应确保窗口关闭时断开与 TCP 客户端的socket 连接，停止 TCP 服务器的网络监听。（先断开与客户端的连接，再停止监听）

MainWindow::~MainWindow()
{//析构函数if (tcpSocket != nullptr){if (tcpSocket->state()==QAbstractSocket::ConnectedState)tcpSocket->disconnectFromHost();    //断开与客户端的连接}if (tcpServer->isListening())tcpServer->close();     //停止网络监听delete ui;
}

开始监听

TCP服务器可以使用QTcpServer::listen()函数在本机某个 IP 地址和端口上开始 TCP监听，以等待 TCP 客户端的接入。对应“开始监听”按钮的槽函数如下：

void MainWindow::on_actStart_triggered()
{//"开始监听"按钮QString  IP=ui->comboIP->currentText();  //IP地址字符串,如"127.0.0.1"quint16  port=ui->spinPort->value();     //端口QHostAddress   address(IP);tcpServer->listen(address,port);    //开始监听//    tcpServer->listen(QHostAddress::LocalHost,port);// Equivalent to QHostAddress("127.0.0.1").ui->textEdit->appendPlainText("**开始监听...");ui->textEdit->appendPlainText("**服务器地址："+tcpServer->serverAddress().toString());ui->textEdit->appendPlainText("**服务器端口："+QString::number(tcpServer->serverPort()));ui->actStart->setEnabled(false);ui->actStop->setEnabled(true);labListen->setText("监听状态：正在监听");
}

函 数 listen()的原型定义如下：

bool QTcpServer::listen(const QHostAddress &address = QHostAddress::Any, quint16 port = 0)

参数 address 是 QHostAddress 类型的主机地址，可以像程序中那样通过 IP 地址字符串创建 QHostAddress 对象。参数 port 是监听的端口号。

TCP监听本机的时候，可以使用本机地址127.0.0.1或常量 QHostAddress::LocalHost，抑或是

本机的实际 IP 地址。

与客户端建立sockect连接

tcpServer 开始监听后，TCP 客户端程序就可以通过 IP 地址和端口连接到此服务器。当有客户端 接入时，tcpServer 会发射 newConnection()信号。其槽函数槽函数 do_newConnection()对应的代码如下所示：

void MainWindow::do_newConnection()
{tcpSocket = tcpServer->nextPendingConnection(); //创建socketconnect(tcpSocket, SIGNAL(connected()),this, SLOT(do_clientConnected()));do_clientConnected();   //执行一次槽函数，显示状态connect(tcpSocket, SIGNAL(disconnected()),this, SLOT(do_clientDisconnected()));connect(tcpSocket,&QTcpSocket::stateChanged,this,&MainWindow::do_socketStateChange);do_socketStateChange(tcpSocket->state());   //执行一次槽函数，显示状态connect(tcpSocket,SIGNAL(readyRead()),  this,SLOT(do_socketReadyRead()));
}

程序通过QTcpServer::nextPendingConnection()函数获取与连接的客户端进行通信的 QTcpSocket 对象 tcpSocket，并将tcpSocket 的几个信号与相应的槽函数连接起来用于处理与客户端的通信。

服务器与客户端连接后tcpSocket会发射connected()信号，该信号的槽函数如下：

void MainWindow::do_clientConnected()
{//客户端接入时ui->textEdit->appendPlainText("**client socket connected");ui->textEdit->appendPlainText("**peer address:"+tcpSocket->peerAddress().toString());ui->textEdit->appendPlainText("**peer port:"+QString::number(tcpSocket->peerPort()));
}

示例中用于打印相关状态。

服务器与客户端断开时，tcpSocket会发送disconnected()信号，该信号的槽函数如下：

void MainWindow::do_clientDisconnected()
{//客户端断开连接时ui->textEdit->appendPlainText("**client socket disconnected");tcpSocket->deleteLater();
}

当Sockect状态发生改变时，会发送stateChanged()信号，该信号对应的槽函数如下：

void MainWindow::do_socketStateChange(QAbstractSocket::SocketState socketState)
{//socket状态变化时switch(socketState){case QAbstractSocket::UnconnectedState:labSocketState->setText("socket状态：UnconnectedState");break;case QAbstractSocket::HostLookupState:labSocketState->setText("socket状态：HostLookupState");break;case QAbstractSocket::ConnectingState:labSocketState->setText("socket状态：ConnectingState");break;case QAbstractSocket::ConnectedState:labSocketState->setText("socket状态：ConnectedState");break;case QAbstractSocket::BoundState:labSocketState->setText("socket状态：BoundState");break;case QAbstractSocket::ClosingState:labSocketState->setText("socket状态：ClosingState");break;case QAbstractSocket::ListeningState:labSocketState->setText("socket状态：ListeningState");}
}

停止监听

TCP服务器停止监听

停止监听使用QTcpServer::close()函数，在停止监听前断开与客户端的连接，槽函数如下：

void MainWindow::on_actStop_triggered()
{//"停止监听"按钮if (tcpServer->isListening())   //tcpServer正在监听{if (tcpSocket != nullptr)if (tcpSocket->state()==QAbstractSocket::ConnectedState)tcpSocket->disconnectFromHost();tcpServer->close();         //停止监听ui->actStart->setEnabled(true);ui->actStop->setEnabled(false);labListen->setText("监听状态：已停止监听");}
}

与客户端数据通信

TCP 服务器端和客户端通过 QTcpSocket 对象通信时，需要规定两者的通信协议，即传输的数据内容如何解析。QTcpSocket 间接继承自 QIODevice，因此支持流数据读写功能。

对于数据的传输有两种协议：基于行、基于块

基于行的数据通信协议一 般用于纯文本数据的通信，每一行数据以一个换行符结束。函数canReadLine()判断是否有新的一 行数据需要读取，如果有就可以用函数 readLine()读取一行数据。基于块的数据通信协议一般用于二进制数据的传输，需要自定义具体的格式。

示例程序中发送的是纯文本数据，使用的是基于行的传输模式，服务器向客户端发送消息如下：

void MainWindow::on_btnSend_clicked()
{//"发送消息"按钮，发送一行字符串，以换行符结束QString  msg=ui->editMsg->text();ui->textEdit->appendPlainText("[out] "+msg);ui->editMsg->clear();ui->editMsg->setFocus();QByteArray  str=msg.toUtf8();str.append('\n');       //添加一个换行符tcpSocket->write(str);
}

程序中将文本输入框中的QString类型字符串转换为QByteArray 类型的字节数组 str，然后在 str 最后面添加 一个换行符，用 QIODevice::write()函数将 str 写入缓冲区，这样就能向客户端发送一行文字。

当客户端发送数据时，服务器端缓冲区有新数据进入，QTcpSocket 对象会发射 readyRead()信号，该信号对应的槽函数是do_socketReadyRead()，一般在这个槽函数中进行接收数据的处理：

void MainWindow::do_socketReadyRead()
{//读取缓冲区的行文本while(tcpSocket->canReadLine())ui->textEdit->appendPlainText("[in] "+tcpSocket->readLine());
}

每当缓冲区数据攒够一行时（检测到换行符），就通过tcpSocket->readLine()获取一行数据。

TCP Server 通过上述方式与TCP Client 进行双向通信，且这个连接一直存在，直到某一方的 QTcpSocket 对象调用函数 disconnectFromHost()断开 socket 连接。

TCP客户端程序设计

主窗口设计

客户端主窗口与服务器窗口类似，头文件如下：

#ifndef MAINWINDOW_H
#define MAINWINDOW_H#include <QMainWindow>
#include    <QTcpSocket>
#include    <QLabel>QT_BEGIN_NAMESPACE
namespace Ui { class MainWindow; }
QT_END_NAMESPACEclass MainWindow : public QMainWindow
{Q_OBJECT
private:QTcpSocket  *tcpClient;   //socketQLabel  *labSocketState;  //状态栏显示标签QString  getLocalIP();    //获取本机IP地址
public:MainWindow(QWidget *parent = nullptr);~MainWindow();private slots:
//自定义槽函数void    do_connected();void    do_disconnected();void    do_socketStateChange(QAbstractSocket::SocketState socketState);void    do_socketReadyRead();//读取socket传入的数据void on_actConnect_triggered();     //连接服务器void on_actDisconnect_triggered();  //断开服务器void on_actClear_triggered();       //清空文本框void on_btnSend_clicked();          //向服务器发送消息
private:Ui::MainWindow *ui;
};#endif // MAINWINDOW_H

Mainwindow中也定义了一个用于 socket 连接和通信的 QTcpSocket 变量 tcpClient。在主窗口构造函数中，创建 tcpClient，并建立信号与槽函数的关联。相关槽函数与服务端器一致。

MainWindow::MainWindow(QWidget *parent) :QMainWindow(parent),ui(new Ui::MainWindow)
{ui->setupUi(this);tcpClient=new QTcpSocket(this);    //创建socket变量labSocketState=new QLabel("Socket状态：");  //状态栏标签labSocketState->setMinimumWidth(250);ui->statusBar->addWidget(labSocketState);QString localIP=getLocalIP();      //获取本机IPthis->setWindowTitle(this->windowTitle()+"----本机IP地址："+localIP);ui->comboServer->addItem(localIP);connect(tcpClient,SIGNAL(connected()),   this,SLOT(do_connected()));connect(tcpClient,SIGNAL(disconnected()),this,SLOT(do_disconnected()));connect(tcpClient,&QTcpSocket::stateChanged,this,&MainWindow::do_socketStateChange);connect(tcpClient,SIGNAL(readyRead()),   this,SLOT(do_socketReadyRead()));
}void MainWindow::do_connected()
{ //connected()信号的槽函数ui->textEdit->appendPlainText("**已连接到服务器");ui->textEdit->appendPlainText("**peer address:"+tcpClient->peerAddress().toString());ui->textEdit->appendPlainText("**peer port:"+QString::number(tcpClient->peerPort()));ui->actConnect->setEnabled(false);ui->actDisconnect->setEnabled(true);
}void MainWindow::do_disconnected()
{//disConnected()信号的槽函数ui->textEdit->appendPlainText("**已断开与服务器的连接");ui->actConnect->setEnabled(true);ui->actDisconnect->setEnabled(false);
}void MainWindow::do_socketStateChange(QAbstractSocket::SocketState socketState)
{//stateChange()信号的槽函数switch(socketState){case QAbstractSocket::UnconnectedState:labSocketState->setText("socket状态：UnconnectedState");break;case QAbstractSocket::HostLookupState:labSocketState->setText("socket状态：HostLookupState");break;case QAbstractSocket::ConnectingState:labSocketState->setText("socket状态：ConnectingState");break;case QAbstractSocket::ConnectedState:labSocketState->setText("socket状态：ConnectedState");break;case QAbstractSocket::BoundState:labSocketState->setText("socket状态：BoundState");break;case QAbstractSocket::ClosingState:labSocketState->setText("socket状态：ClosingState");break;case QAbstractSocket::ListeningState:labSocketState->setText("socket状态：ListeningState");}
}void MainWindow::do_socketReadyRead()
{//readyRead()信号的槽函数while(tcpClient->canReadLine())ui->textEdit->appendPlainText("[in] "+tcpClient->readLine());
}

与服务器建立连接

客户端与服务建立连接，通过QTcpSocket::connectToHost()函数传入服务器地址和端口号，如果服务器此时处于监听状态就会成功建立连接。断开连接使用QTcpSocket::disconnectFromHost()函数即可，相关代码如下：

void MainWindow::on_actConnect_triggered()
{//“连接服务器”按钮QString   addr=ui->comboServer->currentText();quint16   port=ui->spinPort->value();tcpClient->connectToHost(addr,port);//    tcpClient->connectToHost(QHostAddress::LocalHost,port);
}void MainWindow::on_actDisconnect_triggered()
{//“断开连接”按钮if (tcpClient->state()==QAbstractSocket::ConnectedState)tcpClient->disconnectFromHost();
}

与TCP服务器进行数据通信

和服务器一样，使用QTcpSocket类中提供的函数进行通信，代码部分完全一致：

void MainWindow::on_btnSend_clicked()
{//“发送数据”按钮QString  msg=ui->editMsg->text();ui->textEdit->appendPlainText("[out] "+msg);ui->editMsg->clear();ui->editMsg->setFocus();QByteArray  str=msg.toUtf8();str.append('\n');tcpClient->write(str);
}void MainWindow::do_socketReadyRead()
{//readyRead()信号的槽函数while(tcpClient->canReadLine())ui->textEdit->appendPlainText("[in] "+tcpClient->readLine());
}

小结

通过以上TCP服务器和客户端的程序设计可以看出，两者最大的不同部分是建立连接过程，服务器端通过listen()来主动打开监听，而客户端是通过connectToHost()主动连接服务器，其他部分基本都是一样的。

以上示例仅演示了TCP的基本通信，且是一对一的基于连接的通信，而在实际中的 TCP 服务器端程序允许多个客户端接入，为了使每个 socket 连接独立 通信、互不影响，一般采用多线程，即为一个 socket 连接创建一个线程。

参考

QT6 C++开发指南


http://www.ppmy.cn/devtools/144312.html

相关文章

Android Studio创建新项目并引入第三方so外部aar库驱动NFC读写器读写IC卡

Android Studio创建新项目并引入第三方so外部aar库驱动NFC读写器读写IC卡

本示例使用设备&#xff1a;https://item.taobao.com/item.htm?spma21dvs.23580594.0.0.52de2c1bbW3AUC&ftt&id615391857885 一、打开Android Studio,点击 File> New>New project 菜单&#xff0c;选择 要创建的项目模版&#xff0c;点击 Next 二、输入项目名称…
阅读更多...
[网络]tcp通信协议接口函数及一些简易项目

[网络]tcp通信协议接口函数及一些简易项目

tcp是最常用的传输层协议,面向字节流,相较于其他协议,如udp;tcp更为复杂,tcp额外提供了可靠的、有序的和错误检测功能的数据传输服务.简单点来说,tcp更复杂,数据也更可靠 本文只是介绍tcp通信的一些接口,并不具体介绍tcp协议的内容以及各种策略 服务器端 1.socket int socket(…
阅读更多...
利器 | AppCrawler 自动遍历测试工具实践（一）

利器 | AppCrawler 自动遍历测试工具实践（一）

本文为霍格沃兹测试学院学院学员课程学习笔记&#xff0c;系统学习交流文末加群。 AppCrawler 是由霍格沃兹测试学院校长思寒开源的一个项目,通过名字我们大概也能猜出个方向&#xff0c;Crawler 是爬虫的意思&#xff0c;App 的爬虫&#xff0c;遍历 App &#xff1a; 官方 G…
阅读更多...
游戏网站大全

游戏网站大全

http://piano.ssjjss.com/ 钢琴模拟器 https://gangqin.bmcx.com/?tdsourcetags_pcqq_aiomsg#/ 在线钢琴 https://www.gushiwen.cn/ 古诗文; https://www.bilibili.com/video/BV1UEWpeaEQK/ https://bouncyballs.org/ 掉落的球球 https://fakeupdate.net/ 假装升级界面 ht…
阅读更多...
winform中屏蔽双击最大化或最小化窗体(C#实现)，禁用任务管理器结束程序,在需要屏蔽双击窗体最大化、最小化、关闭

winform中屏蔽双击最大化或最小化窗体(C#实现)，禁用任务管理器结束程序,在需要屏蔽双击窗体最大化、最小化、关闭

winform中屏蔽双击最大化或最小化窗体(C#实现)&#xff0c;禁用任务管理器结束程序,在需要屏蔽双击窗体最大化、最小化、关闭 protected override void WndProc(ref Message m){#region 处理点击窗体标题栏放大缩小问题&#xff0c;禁用点击窗体标题栏放大缩小//logger.Info($&…
阅读更多...
Eclipse设置自动补全后 输入字符串类型变量后会自动追加String的解决方案

Eclipse设置自动补全后 输入字符串类型变量后会自动追加String的解决方案

很简单&#xff0c;先打开eclipse&#xff0c;顶部找到window&#xff0c;点击preference 弹出一个设置窗口&#xff1b; 在窗口左侧选择Java>Editor>Content Assist&#xff1b;然后再右侧找到Disable insertion triggers except Enter 的选项&#xff08;禁用除Enter以…
阅读更多...
uniapp blob格式转换为video .mp4文件使用ffmpeg工具

uniapp blob格式转换为video .mp4文件使用ffmpeg工具

前言 介绍一下这三种对象使用场景 您前端一旦涉及到文件或图片上传Q到服务器&#xff0c;就势必离不了 Blob/File /base64 三种主流的类型它们之间 互转 也成了常态 Blob - FileBlob -Base64Base64 - BlobFile-Base64Base64 _ File uniapp 上传文件 现在已获取到了blob格式的…
阅读更多...
Vue.js前端框架教程12：Vue表单验证rules和form.validate

Vue.js前端框架教程12：Vue表单验证rules和form.validate

文章目录 表单验证:rulesformRef.value.validate 表单验证 在 Vue 中&#xff0c;:rules 和 formRef.value.validate 通常用于表单验证。:rules 是一个对象&#xff0c;定义了表单字段的验证规则&#xff0c;而 formRef.value.validate 是一个方法&#xff0c;用于触发表单验证…
阅读更多...
最新文章

Copyright @ 2022~2023