Qt网络编程-TCP与UDP

news2024/11/14 6:08:39

网络基础

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");
    else
      ui->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://www.coloradmin.cn/o/1440171.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

部署一个在线OCR工具

部署一个在线OCR工具

效果 安装 1.拉取镜像 # 从 dockerhub pull docker pull mmmz/trwebocr:latest 2.运行容器 # 运行镜像 docker run -itd --rm -p 10058:8089 --name trwebocr mmmz/trwebocr:latest 使用 打开浏览器输入 http://192.168.168.110:10058/ 愉快滴使用吧
阅读更多...
五官行为检测（表情基）解决方案提供商

五官行为检测（表情基）解决方案提供商

随着人工智能技术的日益成熟&#xff0c;情感识别与行为分析在企业界的应用逐渐广泛。美摄科技作为业内领先的五官行为检测&#xff08;表情基&#xff09;解决方案提供商&#xff0c;致力于为企业提供高效、精准的情感识别与行为分析服务。 美摄科技的五官行为检测&#xff0…
阅读更多...
【网页设计期末】茶文化网站

【网页设计期末】茶文化网站

本文资源&#xff1a;https://download.csdn.net/download/weixin_47040861/88818886 1.题目要求 设计要求&#xff1a; &#xff08;1&#xff09;网站页面数量不少于4个&#xff0c;文件命名规范&#xff0c;网站结构要求层次清楚&#xff0c;目录结构清晰&#xff0c;代码…
阅读更多...
阿里云服务器多少钱？2024年阿里云服务器租用费用表大全

阿里云服务器多少钱？2024年阿里云服务器租用费用表大全

2024年阿里云服务器租用价格表更新&#xff0c;云服务器ECS经济型e实例2核2G、3M固定带宽99元一年、ECS u1实例2核4G、5M固定带宽、80G ESSD Entry盘优惠价格199元一年&#xff0c;轻量应用服务器2核2G3M带宽轻量服务器一年61元、2核4G4M带宽轻量服务器一年165元12个月、2核4G服…
阅读更多...
LabVIEW动平衡测试与振动分析系统

LabVIEW动平衡测试与振动分析系统

LabVIEW动平衡测试与振动分析系统 介绍了利用LabVIEW软件和虚拟仪器技术开发一个动平衡测试与振动分析系统。该系统旨在提高旋转机械设备的测试精度和可靠性&#xff0c;通过精确测量和分析设备的振动数据&#xff0c;以识别和校正不平衡问题&#xff0c;从而保证机械设备的高…
阅读更多...
【状态管理一】概览：状态使用、状态分类、状态具体使用

【状态管理一】概览：状态使用、状态分类、状态具体使用

文章目录 一. 状态使用概览二. 状态的数据类型1. 算子层面2. 接口层面2.1. UML与所有状态类型介绍2.2. 内部状态&#xff1a;InternalKvState 将知识与实际的应用场景、设计背景关联起来&#xff0c;这是学以致用、刨根问底知识的一种直接方式。 本文介绍 状态数据管理&#x…
阅读更多...
闭区间上连续函数的性质【高数笔记】

闭区间上连续函数的性质【高数笔记】

1. 分几个性质 2. 每个性质的注意事项是什么 3. 每个性质适用什么类型的题型 4. 注意最值定理和正弦函数的不同 5. 做题步骤是什么
阅读更多...
每日一题！如约而至！（图片整理，寻找数组的中心下标）

每日一题！如约而至！（图片整理，寻找数组的中心下标）

今天是腊月二十九&#xff0c;挂灯笼喽&#xff01; 图片整理_牛客题霸_牛客网 (nowcoder.com) #include <stdio.h> #include <string.h>int main() {char str[1001] {\0};while (scanf("%s", str) ! EOF) {//输入的是字符串int len strlen(str);for(…
阅读更多...
C#，佩尔数（Pell Number）的算法与源代码

C#，佩尔数（Pell Number）的算法与源代码

1 佩尔数&#xff08;Pell Number&#xff09; 佩尔数&#xff08;Pell Number&#xff09;是一个自古以来就知道的整数数列&#xff0c;由递推关系定义&#xff0c;与斐波那契数类似。佩尔数呈指数增长&#xff0c;增长速率与白银比的幂成正比。它出现在2的算术平方根的近似值…
阅读更多...
UDP 用户数据报协议

UDP 用户数据报协议

目录 1 UDP 1.1 UDP 的主要特点 1.1.1 UDP 是面向报文的 1.1.2 UDP 通信和端口号的关系 1.2 UDP 的首部格式 1.2.1 UDP 基于端口的分用 1.3 UDP抓包 1 UDP UDP 只在 IP 的数据报服务之上增加了一些功能&#xff1a; 1.复用和分用 2.差错检测 1.1 UDP 的主要特点 1.无连…
阅读更多...
VBA中类的解读及应用第九讲:用WithEvents关键字声明实例化对象类变量

VBA中类的解读及应用第九讲:用WithEvents关键字声明实例化对象类变量

《VBA中类的解读及应用》教程【10165646】是我推出的第五套教程&#xff0c;目前已经是第一版修订了。这套教程定位于最高级&#xff0c;是学完初级&#xff0c;中级后的教程。 类&#xff0c;是非常抽象的&#xff0c;更具研究的价值。随着我们学习、应用VBA的深入&#xff0…
阅读更多...
MVC框架学习

MVC框架学习

大一的时候写过一个mvc框架的跑酷游戏&#xff0c;但是那时候基础不扎实&#xff0c;没学明白也没听懂。现在深入的学习一下 以下内容参考&#xff1a;MVC 模式 | 菜鸟教程 (runoob.com) MVC 模式 MVC 模式代表 Model-View-Controller&#xff08;模型-视图-控制器&#xff…
阅读更多...
LangChain 最近发布的一个重要功能：LangGraph

LangChain 最近发布的一个重要功能：LangGraph

LangGraph 是 LangChain 最近发布的一个重要功能&#xff0c;LangChain 进入多代理框架领域。通过建立在LangChain 之上&#xff0c;LangGraph 使开发人员可以轻松创建强大的代理运行时。 LangChain 使用其表达语言&#xff08;LCEL&#xff09;为开发人员构建定制链提供技术支…
阅读更多...
Django学习记录02

Django学习记录02

1.请求与响应 1.1get与post的区别 get 一般是从url输入地址&#xff0c;会调用get请求 post 一般是内部数据传输# get请求 def something(request):# req是一个对象&#xff0c;封装了用户发送过来的所有请求相关数据# 1.获取请求方式 http://localhost:8000/something# pri…
阅读更多...
[职场] 智能材料与结构专业的就业前景 #经验分享#学习方法

[职场] 智能材料与结构专业的就业前景 #经验分享#学习方法

智能材料与结构专业的就业前景 智能材料与结构专业是面向国家智能制造强国战略&#xff0c;面向地方经济新旧动能转换需求&#xff0c;学习智能材料与结构的基础理论及基本知识&#xff0c;接受智能材料制备、组织分析、性能测试、智能材料系统集成技能的基本训练&#xff0c;…
阅读更多...
春运一票难求，候补抢票显威，如何设计一个候补订单系统？

春运一票难求，候补抢票显威，如何设计一个候补订单系统？

春运一票难求&#xff0c;候补官方抢票 最近春节火车一票难求&#xff0c;12306系统的候补购票是一种官方支持的抢票方式。在首日票已售罄时&#xff0c;立即提交候补请求&#xff0c;系统会优先考虑候补乘客的需求。根据成功率灵活选择是否候补购票。 当旅客在12306网站购票&…
阅读更多...
mac协议远程管理软件：Termius for Mac 8.4.0激活版

mac协议远程管理软件：Termius for Mac 8.4.0激活版

Termius是一款远程访问和管理工具&#xff0c;旨在帮助用户轻松地远程连接到各种服务器和设备。它适用于多种操作系统&#xff0c;包括Windows、macOS、Linux和移动设备。 该软件提供了一个直观的界面&#xff0c;使用户可以通过SSH、Telnet和Mosh等协议连接到远程设备。它还支…
阅读更多...
考研数据结构笔记（3）

考研数据结构笔记（3）

顺序表存储结构 存储结构顺序结构定义基本操作的实现静态分配问题 动态分配代码功能 顺序表的特点: 顺序表小结顺序表的插入删除插入删除小结 顺序表的查找按位查找按值查找小结 存储结构 顺序结构 定义 线性表是具有相同数据类型的n(n>0)个数据元素的有限序列(每个数据元素…
阅读更多...
Vue + Element UI el-table + sortablejs 行、列拖拽排序

Vue + Element UI el-table + sortablejs 行、列拖拽排序

实现Element UI中的el-table表格组件的行和列的拖拽排序 使用 Vue3 Element Plus UI sortablejs 安装sortablejs pnpm install sortablejs行拖拽 基本实现 效果 <script setup> import { onMounted, ref } from "vue"; import Sortable from "sort…
阅读更多...
Flink流式数据倾斜

Flink流式数据倾斜

1. 流式数据倾斜 流式处理的数据倾斜和 Spark 的离线或者微批处理都是某一个 SubTask 数据过多这种数据不均匀导致的&#xff0c;但是因为流式处理的特性其中又有些许不同 2. 如何解决 2.1 窗口有界流倾斜 窗口操作类似Spark的微批处理&#xff0c;直接两阶段聚合的方式来解决…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023