Qt网络编程-TCP与UDP

网络基础

TCP与UDP基础

关于TCP与UDP的基础这里就不过多介绍了,具体可以查看对应百度百科介绍:

TCP(传输控制协议)_百度百科 (baidu.com)

UDP_百度百科 (baidu.com)

需要知道这两者的区别:

  1. 可靠性:

    • TCP:TCP 是一种面向连接的协议,它提供可靠的数据传输。它使用序号、确认和重传等机制来确保数据的可靠性,以及按序传递数据包。如果数据包丢失或损坏,TCP 会自动进行重传,直到数据被正确接收。
    • UDP:UDP 是一种无连接的协议,它不提供数据包的可靠性保证。UDP 发送的数据包可能丢失、重复或无序,因此它不适合对数据可靠性要求很高的应用。
  2. 连接性:

    • TCP:TCP 是面向连接的,它在通信双方建立连接后(有客户端与服务器之分)才能进行数据传输。TCP 连接是可靠的、有序的、全双工的,通信双方可以进行双向通信。
    • UDP:UDP 是无连接的,它不需要在通信双方之间建立连接(没有客户端与服务器之分)。每个 UDP 数据包都是独立的,发送者和接收者之间没有持久的连接。
  3. 效率:

    • TCP:TCP 通过使用流量控制和拥塞控制等机制,以及连接的建立和维护,会产生一定的开销。因此,TCP 在可靠性和有序性方面提供了较高的保证,但可能会牺牲一些效率。
    • UDP:UDP 不需要进行连接的建立和维护,也不需要进行重传或流量控制等操作,因此它通常比 TCP 具有更低的开销和更高的效率。

网络通信以上两者都绕不开IP地址与端口这两个。

开发调试所需工具

一般情况需要网络调试助手或者wireshark抓包工具,网络调试助手我用的是NetAssist。关于NetAssist和WireShark怎么使用,后面会介绍。

windows与linux如何查看和修改本地的IP端口

Window

cmd命令行:ipconfig/all

修改:

设置选中“网络和Internet”

Linux

命令行:ifconfig -a:

static QStringList getIPAddresses() {QStringList addresses;for (const QHostAddress &address : QNetworkInterface::allAddresses()) {if (address.protocol() == QAbstractSocket::IPv4Protocol)addresses.append(address.toString());}return addresses;
}

或者直接查看网络设置。

使用Qt函数获取

Qt要使用网络模块记得工程文件添加:QT += network

static QStringList getIPAddresses() {QStringList addresses;for (const QHostAddress &address : QNetworkInterface::allAddresses()) {if (address.protocol() == QAbstractSocket::IPv4Protocol)addresses.append(address.toString());}return addresses;
}

编译运行查看打印:

Windows与Linux查看本地连接情况

Windows和Linux都需要借助netstat命令,但是两者稍微有一些不一样。

Windows

比如我使用刚刚的调试助手NetAssist,建立一个tcp服务器,然后监听IP:192.168.5.1,端口:8080。

查看一下这个服务器是否监听成功,命令行输入:netstat -antp TCP(‘p’指定对应协议,后面需要接协议类型TCP或UDP)

 或者直接输入命令 netstat -antp TCP|findstr 8080:

再起一个调试助手以客户端的形式连接这个服务器:

 再次输入: netstat -antp TCP|findstr 8080:

能够查看到刚刚建立的连接。

查看对应链接是哪个应用建立的,先输入: netstat -antpo TCP|findstr 8080:

然后使用tasklist查看对应进程: 

如果是UDP改为 netstat -antp UDP|findstr 8080 即可

Linux 

Linux 的netstat的命令指定对应协议不需要 -p TCP或者-p UDP,而是-t就是TCP,-u就是UDP,如下图所示:

 Qt实现TCP

因为TCP是需要建立链接,分客户端和服务器端的,所以需要分别编写。

服务器端

服务器由QTcpServer来实现,QTcpServer的信号:

需要注意newConnection这个信号,当有客户端连接这个服务器时,会触发这个信号。

所有的方法:


需要注意的几个方法:


bool  listen(const QHostAddress &address = QHostAddress::Any, quint16 port = 0)
 
监听对应IP和端口,IP为空则默认监听any

close()

停止监听

bool isListening() const
 
是否正在监听

QHostAddress serverAddress() const
 
监听的IP地址

quint16 serverPort() const
 
监听的端口

void setMaxPendingConnections(int numConnections)
 
设置允许建立的最大连接数

比如监听IP 127.0.0.1 端口 8080:

QTcpServer server;

server.listen(QHostAddress("127.0.0.1"),8080); 

写一个简单的例子。

ui:

头文件:

#ifndef MAINWINDOW_H
#define MAINWINDOW_H
#include <QMainWindow>
#include <QTcpServer>
#include <QTcpSocket>
QT_BEGIN_NAMESPACE
namespace Ui {
class MainWindow;
}
QT_END_NAMESPACE
class MainWindow : public QMainWindow
{Q_OBJECT
public:MainWindow(QWidget *parent = nullptr);~MainWindow();
private slots:void on_listen_clicked();void on_disconnect_clicked();void on_send_clicked();void newConnection();
private:Ui::MainWindow *ui;QTcpServer *m_Server;QTcpServer *m_Server1;QList<QTcpSocket *> m_Sockets;void showLog(const QString &log);
};
#endif // MAINWINDOW_H

 源文件:

#include "mainwindow.h"
#include <QDateTime>
#include <QHostAddress>
#include <QNetworkInterface>
#include "ui_mainwindow.h"
static QStringList getIPAddresses() {QStringList addresses;for (const QHostAddress &address : QNetworkInterface::allAddresses()) {if (address.protocol() == QAbstractSocket::IPv4Protocol)addresses.append(address.toString());}return addresses;
}MainWindow::MainWindow(QWidget *parent): QMainWindow(parent), ui(new Ui::MainWindow) {ui->setupUi(this);setWindowTitle("TcpServer");ui->tableWidget->setEditTriggers(QAbstractItemView::NoEditTriggers);ui->localIp->addItems(getIPAddresses());ui->tableWidget->setSelectionBehavior(QAbstractItemView::SelectRows);m_Server = new QTcpServer;connect(m_Server, &QTcpServer::newConnection, this,&MainWindow::newConnection);for (QTcpSocket *socket : m_Sockets) {connect(socket, &QTcpSocket::readyRead, [=]() {showLog(QString("%1:%2:%3").arg(socket->peerAddress().toString()).arg(socket->peerPort()).arg(QString(socket->readAll().toHex())));});connect(socket, &QTcpSocket::disconnected, [=]() {showLog(QString("disconnect:%1:%2:%3").arg(socket->peerAddress().toString()).arg(socket->peerPort()).arg(QString(socket->readAll().toHex())));for (int i = 0; i < ui->tableWidget->rowCount(); i++) {QTableWidgetItem *ipItem = ui->tableWidget->item(i, 0);QTableWidgetItem *portItem = ui->tableWidget->item(i, 1);if (nullptr != ipItem && nullptr != portItem) {if (ipItem->text() == socket->peerAddress().toString() &&portItem->text() == socket->peerPort()) {ui->tableWidget->removeRow(i);break;}}}});connect(socket,static_cast<void (QTcpSocket::*)(const QAbstractSocket::SocketError)>(&QTcpSocket::error),[=](QAbstractSocket::SocketError error) {qDebug() << "error:" << error;showLog("error:" + QString::number(int(error)));});connect(socket, &QTcpSocket::stateChanged,[=](QAbstractSocket::SocketState state) {qDebug() << "stateChanged:" << state;showLog("stateChanged:" + QString::number(int(state)));});}
}MainWindow::~MainWindow() { delete ui; }void MainWindow::on_listen_clicked() {if (ui->listen->text() == "listen") {if (m_Server->listen(QHostAddress(ui->localIp->currentText()),ui->localPort->value()))ui->listen->setText("listening");elseui->textEdit->append("listen fail");} else {for (QTcpSocket *socket : m_Sockets) {socket->close();socket->disconnectFromHost();}m_Server->close();ui->listen->setText("listen");}
}void MainWindow::on_disconnect_clicked() {int row = ui->tableWidget->currentRow();if (-1 != row) {QTableWidgetItem *ipItem = ui->tableWidget->item(row, 0);QTableWidgetItem *portItem = ui->tableWidget->item(row, 1);if (nullptr != ipItem && nullptr != portItem) {QString ip = ipItem->text();quint16 port = portItem->text().toUShort();for (QTcpSocket *socket : m_Sockets) {if (ip == socket->peerAddress().toString() &&port == socket->peerPort()) {socket->close();socket->disconnectFromHost();break;}}}}
}void MainWindow::on_send_clicked() {QByteArray ba = ui->send->text().toUtf8();int row = ui->tableWidget->currentRow();if (-1 != row) {QTableWidgetItem *ipItem = ui->tableWidget->item(row, 0);QTableWidgetItem *portItem = ui->tableWidget->item(row, 1);if (nullptr != ipItem && nullptr != portItem) {QString ip = ipItem->text();quint16 port = portItem->text().toUShort();for (QTcpSocket *socket : m_Sockets) {if (ip == socket->peerAddress().toString() &&port == socket->peerPort()) {socket->write(ba);break;}}}}
}void MainWindow::newConnection() {QTcpSocket *socket = m_Server->nextPendingConnection();m_Sockets.append(socket);// m_TcpSocket = socket;int row = ui->tableWidget->rowCount();ui->tableWidget->insertRow(row);QTableWidgetItem *ipItem =new QTableWidgetItem(socket->peerAddress().toString());QTableWidgetItem *portItem =new QTableWidgetItem(QString::number(socket->peerPort()));qDebug() << socket->peerAddress().toString() << "," << socket->peerPort()<< "," << socket->peerName();ui->tableWidget->setItem(row, 0, ipItem);ui->tableWidget->setItem(row, 1, portItem);connect(socket, &QTcpSocket::disconnected, [=]() {showLog(QString("disconnected:%1:%2").arg(socket->peerAddress().toString()).arg(socket->peerPort()));// m_TcpSocket = nullptr;for (int i = 0; i < ui->tableWidget->rowCount(); i++) {QTableWidgetItem *ipItem = ui->tableWidget->item(i, 0);QTableWidgetItem *portItem = ui->tableWidget->item(i, 1);if (nullptr != ipItem && nullptr != portItem) {if (ipItem->text() == socket->peerAddress().toString() &&portItem->text() == QString::number(socket->peerPort())) {ui->tableWidget->removeRow(i);break;}}}});
}void MainWindow::showLog(const QString &log) {ui->textEdit->append(QString("%1:%2").arg(QDateTime::currentDateTime().toString("yyyy/MM/dd hh:mm:ss.zzz")).arg(log));
}

有客户端连接后,会触发newConnection这个信号,然后在槽函数中使用nextPendingConnection()这个方法获取对应的客户端QTcpSocket 指针对象。客户端发送消息后会触发readyRead这个信号,使用QTcpSocket的readAll获取发送的信息。编译运行,输入监听的ip和端口然后点击listen按钮然后使用命令查看是否开始监听对应ip和端口:

然后使用调试助手作为客户端连接这个服务器:

 

可以看到触发了newConnection信号,然后获取对应客户端对象将其信息显示到了的表格上面。

实验链接的建立与取消以及消息的互相发送:

可以实现对应的通讯。 

以上是使用调试助手,也可以使用WireShark抓包查看发送和接受的数据。需要注意的是如果客户端和服务器都在本地自己发自己收是用WireShark抓不到的。

这里简单说一下wireshark的用法,首先选择需要抓取的网卡:

比如ping就是走的tcp,测试时我是用 虚拟机ping我的主机,如何使vmware虚拟机和主机ping通可以参考这位博主的博客:实现虚拟机(VM15.5.0)与本机相互通信_vmware和主机怎样才能ping通-CSDN博客

然后查看wireshark可以看到ping的报文:

因为我的主机ip192.168.1.3,虚拟机ip是192.168.1.4,可以输入“ip.src==192.168.1.4 && ip.dst==192.168.1.3” 来过滤:

 同样,我使用虚拟机和主机建立tcp连接然后发送消息也是可以抓到:

 

 

X

客户端

客户端由QTcpSocket实现,QTcpSocket继承自QAbstractSocket,比如上文中在虚拟机中建立一个tcp服务器,监听ip192.168.1.3,端口12345:

QTcpSocket *socket =new QTcpSocket;
socket->connectToHost(QHostAddress(),12345);
if(socket->waitForConnected())
{//TODO 连接成功
}
else
{//TODO 连接失败
}connect(socket,&QTcpSocket::disconnected,[=](){
//TODO 处理连接断开
});
connect(socket, &QTcpSocket::readyRead, [=]() {QByteArray receiveData=socket->readAll();//TODO 处理接收的数据});QByteArray sendData;
//TODO 处理发送数据
//发送数据
socket->write(sendData);
//断开连接,两种方式
socket->abort;//强制中断连接
socket->disconnectFromHost();//不会马上关闭连接,等待资源释放后才会中断连接

另外客户端套接字可以绑定bind对应ip和端口,如果没有绑定,则系统会使用之绑定一个随即的可用的ip和端口 :

Qt实现UDP

因为UDP不用建立连接,不用分服务器和客户端,所以对应Qt的UDP部分,只需要使用QUdpSocket一个即可:

QUdpSocket同QTcpSocket一样都继承自QAbstractSocket,使用UDP通信前,对应udp套接字需要绑定对应ip与端口,然后发送数据时需要知道对方的ip与端口(UDP分单播、组播与广播,这里只说单播,组播与广播后面博客再写):

QUdpSocket *udpSocket = new QUdpSocket(this);
udpSocket->bind(QHostAddress("192.168.1.3"), 12345);
connect(udpSocket, &QUdpSocket::readyRead,[=](){while (udpSocket->hasPendingDatagrams()) {QByteArray data;QHostAddress host;quint16 port;data.resize(udpSocket->pendingDatagramSize());udpSocket->readDatagram(data.data(), data.size(), &host, &port);//TODO 处理接受数据}
});
QByteArray sendData;
//TODO 处理发送数据
udpSocket->writeDatagram(sendData, QHostAddress("192.168.1.4"),12345);
//取消绑定
udpSocket->unbind();

使用网络助手模拟udp通信:

使用自己写的udp程序在虚拟机中与之通信:

 使用wireshark抓包:

 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://xiahunao.cn/news/2775802.html

如若内容造成侵权/违法违规/事实不符,请联系瞎胡闹网进行投诉反馈,一经查实,立即删除!

相关文章

day35 数组map和join方法(字符串拼接)

目录 map方法join方法 map方法 使用场景&#xff1a;map 可以遍历数组处理数据&#xff0c;并且返回新的数组map 也称为映射。映射是个术语&#xff0c;指两个元素的集之间元素相互“对应”的关系。map重点在于有返回值&#xff0c;forEach没有返回值&#xff08;undefined&am…

使用 Docker 镜像预热提升容器启动效率详解

概要 在容器化部署中,Docker 镜像的加载速度直接影响到服务的启动时间和扩展效率。本文将深入探讨 Docker 镜像预热的概念、必要性以及实现方法。通过详细的操作示例和实践建议,读者将了解如何有效地实现镜像预热,以加快容器启动速度,提高服务的响应能力。 Docker 镜像预热…

蓝桥杯(Web大学组)2022国赛真题:水果消消乐

思路&#xff1a; 记录点击次数&#xff0c;点击次数为1时&#xff0c;记录点击下标&#xff08;用于隐藏or消除&#xff09;、点击种类&#xff0c;点击次数为2时&#xff0c;判断该下标所对应种类与第一次是否相同 相同&#xff1a;两个都visibility:hidden &#xff08;占…

阿里云资源包管理

-我守在梦的出口&#xff0c;任凭人来人走 阿里云对象存储中的下行流量包是什么&#xff1f; 阿里云对象存储&#xff08;OSS&#xff09;中的下行流量包是一种预付费的流量套餐&#xff0c;用于支付从阿里云 OSS 存储桶下载数据产生的流量费用。当你的应用程序或用户从 OSS 存…

JS中常用占位符使用方法详解_ |%s|%d|%f|%o|%O|%c|

在 JavaScript 中&#xff0c;%s 是一种字符串格式化占位符&#xff0c;用于将字符串插入到另一个字符串中的指定位置。这种方法基于 C 语言的 printf() 函数&#xff0c;但在 JavaScript 中有一些变化。 在 JavaScript 中&#xff0c;%s 可以接受任何类型的值&#xff0c;并将…

复制和粘贴文本时剥离格式的5种方法(MacWindows)

您可能每天复制和粘贴多次。虽然它是一个非常方便的功能&#xff0c;但最大的烦恼之一就是带来了特殊的格式。从网络上获取一些文本&#xff0c;您经常会发现粘贴到文档中时&#xff0c;它保持原始样式。 我们将展示如何使用一些简单的技巧在不格式化的情况下复制和粘贴。 1.…

95.网游逆向分析与插件开发-游戏窗口化助手-窗口化助手显示与大小调整

内容参考于&#xff1a;易道云信息技术研究院VIP课 上一个内容&#xff1a;地图数据获取的逆向分析与C代码还原 码云地址&#xff08;游戏窗口化助手 分支&#xff09;&#xff1a;https://gitee.com/dye_your_fingers/sro_-ex.git 码云版本号&#xff1a;e85c0fc8b85895c8c…

ZigBee学习——在官方例程上实现串口通信

Z-Stack版本为3.0.2 IAR版本为10.10.1 文章目录 一、添加头文件二、定义接收缓冲区三、编写Uart初始化函数四、编写串口回调函数五、函数声明六、函数调用七、可能遇到的问题(function “halUartInit“ has no prototype) 以下所有操作都是在APP层进行&#xff0c;也就是这个文…

【汇编】简单的linux汇编语言程序

一、Linux系统汇编语言 Linux系统上的汇编语言可以使用不同的语法风格&#xff0c;主要包括Intel语法和AT&T语法。这两种语法有各自的特点和风格区别&#xff0c;尽管它们表示的底层机器指令相同。下面分别对两种语法进行简要说明&#xff1a; Intel语法 Intel语法是由I…

github拉取项目,pycharm配置远程服务器环境

拉取项目 从github上拉取项目到pycharmpycharm右下角选择远程服务器上的环境 2.1. 如图 2.2. 输入远程服务器的host&#xff0c;port&#xff0c;username&#xff0c;password连接 2.3. 选择服务器上的环境 链接第3点 注&#xff1a;如果服务器上环境不存在&#xff0c;先创建…

springboot+vue居民小区设备报修系统

小区报修系统可以提高设施维护的效率&#xff0c;减少机构的人力物力成本&#xff0c;并使得维修人员可以更好地了解维护设备的情况&#xff0c;及时解决问题。 对于用户来说&#xff0c;报修系统也方便用户的维修请求和沟通&#xff0c;提高了用户的满意度和信任。其次小区报修…

在 MacOS 上虚拟化 x86Linux 的最佳方法(通过 Rosetta)

categories: [VM] tags: MacOS VM 写在前面 买了 ARM 的 mac, 就注定了要折腾一下虚拟机了… 之前写过一篇文章是通过 utm 虚拟化archlinux, 其实本质上还是调用了 qemu-system-x86_64, 所以速度并不快, 后来想着能不能借用 Rosetta 的优势即原生转译, 来虚拟化 Intel 的 Linu…

【学网攻】 第(24)节 -- 帧中继(点对点)

系列文章目录 目录 系列文章目录 文章目录 前言 一、帧中继是什么&#xff1f; 二、实验 1.引入 实验拓扑图 实验配置 在帧中继中配置通信链路​编辑 实验验证 文章目录 【学网攻】 第(1)节 -- 认识网络【学网攻】 第(2)节 -- 交换机认识及使用【学网攻】 第(3)节 --…

Low 级别反射型 XSS 攻击演示(附链接)

环境准备 如何搭建 DVWA 靶场保姆级教程&#xff08;附链接&#xff09;https://eclecticism.blog.csdn.net/article/details/135834194?spm1001.2014.3001.5502 测试 打开 DVWA 靶场并登录&#xff0c;找到反射型 XSS 页面&#xff08;笔者这里是 Low 级别&#xff09; 先…

【PyQt】09-控件提示信息、Lable标签

文章目录 前言一、控件提示信息1.1 代码1.2 解释 < b >在HTML标签中的作用1.3 添加按键后的代码运行结果 二、QLabel控件介绍2.1 内容2.2 常用的事件2.3 代码结果展示 总结 前言 1、控件提示信息 2、QLabel控件介绍 一、控件提示信息 关键点在于 效果如图所示&#x…

vue3 之 商城项目—详情页

整体认识 路由配置 准备组件模版 <script setup></script><template><div class"xtx-goods-page"><div class"container"><div class"bread-container"><el-breadcrumb separator">">&…

leetcode 3027. 人员站位的方案数 II【离散化前缀和+枚举】

原题链接&#xff1a;3027. 人员站位的方案数 II 题目描述&#xff1a; 给你一个 n x 2 的二维数组 points &#xff0c;它表示二维平面上的一些点坐标&#xff0c;其中 points[i] [xi, yi] 。 我们定义 x 轴的正方向为 右 &#xff08;x 轴递增的方向&#xff09;&#x…

IoC原理

Spring框架的IOC是基于Java反射机制实现的&#xff0c;那具体怎么实现的&#xff0c;下面研究一下 反射 Java反射机制是在运行状态中&#xff0c;对于任意一个类&#xff0c;都能够知道这个类的所有属性和方法&#xff1b;对于任意一个对象&#xff0c;都能够调用它的任意方法…

Unity3d Shader篇(五)— Phong片元高光反射着色器

文章目录 前言一、Phong片元高光反射着色器是什么&#xff1f;1. Phong片元高光反射着色器的工作原理2. Phong片元高光反射着色器的优缺点优点缺点 二、使用步骤1. Shader 属性定义2. SubShader 设置3. 渲染 Pass4. 定义结构体和顶点着色器函数5. 片元着色器函数 三、效果四、总…

idea: 无法创建Java Class文件(SpringBoot)已解决

第一&#xff1a;点击file-->project Sructure... 第二步&#xff1a;点击Moudules 选择自己需要创建java的文件夹&#xff08;我这里选择的是main&#xff09;右键点击Sources&#xff0c;然后点击OK即可 然后就可以创建java类了