C++ Qt开发:QUdpSocket实现组播通信

2024-03-20 16:20

本文主要是介绍C++ Qt开发:QUdpSocket实现组播通信,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

Qt 是一个跨平台C++图形界面开发库,利用Qt可以快速开发跨平台窗体应用程序,在Qt中我们可以通过拖拽的方式将不同组件放到指定的位置,实现图形化开发极大的方便了开发效率,本章将重点介绍如何运用QUdpSocket组件实现基于UDP的组播通信。

组播是一种一对多的通信方式,允许一个发送者将数据报文发送到多个接收者,这些接收者通过共享相同的组播IP地址进行通信。在设置组播地址时需要注意,该范围被限制在239.0.0.0~239.255.255.255以内,这是预留给组播的地址范围。

setSocketOption 设置套接字

在Qt中使用组播,首先需要调用setSocketOption函数,该函数是 QUdpSocket 类的成员函数,用于设置套接字的选项。

该函数原型如下:

bool QUdpSocket::setSocketOption(QAbstractSocket::SocketOption option, const QVariant & value
)
  • option:要设置的套接字选项,这里应该是 QAbstractSocket::MulticastTtlOption,表示设置多播 TTL 选项。
  • value:选项的值,这里应该是 TTL 的值。在 IPv4 中,TTL 是一个 8 位的字段,表示数据报在网络中允许经过的最大路由器数量。通常情况下,TTL 值越大,数据报能够传播的范围就越广。

函数返回一个 bool 类型的值,表示是否成功设置了选项。如果设置成功,返回 true,否则返回 false

MainWindow::MainWindow(QWidget *parent): QMainWindow(parent), ui(new Ui::MainWindow)
{ui->setupUi(this);udpSocket=new QUdpSocket(this);// 设置为多播udpSocket->setSocketOption(QAbstractSocket::MulticastTtlOption,1);
}

bind 绑定套接字地址

接着就是对特定端口的绑定,绑定端口可以通过调用bind函数,该函数用于将 QUdpSocket 绑定到指定的本地地址和端口,并设置特定的绑定选项。

在我们的课件中,使用 bind()QUdpSocket 绑定到 IPv4 的任意地址,并指定了一个组播(Multicast)端口,同时设置了共享地址(ShareAddress)选项。

该函数原型如下:

void QUdpSocket::bind(const QHostAddress & address, quint16 port, BindMode mode = DefaultForPlatform
)
  • address:要绑定的本地地址,这里使用 QHostAddress::AnyIPv4 表示绑定到 IPv4 的任意地址。
  • port:要绑定的本地端口号,这里应该是组播端口号。
  • mode:绑定模式,指定套接字的行为。这里使用 QUdpSocket::ShareAddress 表示共享地址选项,它允许多个套接字同时绑定到相同的地址和端口。

函数将 QUdpSocket 绑定到指定的地址和端口,并且允许多个套接字同时共享相同的地址和端口。

joinMulticastGroup 加入组播

joinMulticastGroup() 函数是 QUdpSocket 类的成员函数,用于将 QUdpSocket 加入指定的多播组。

该函数原型如下:

bool QUdpSocket::joinMulticastGroup(const QHostAddress & groupAddress, const QNetworkInterface & iface = QNetworkInterface()
)
  • groupAddress:要加入的多播组的组播地址。
  • iface:要加入多播组的网络接口。默认情况下,会选择默认的网络接口。

函数返回一个 bool 类型的值,表示是否成功加入了多播组。如果成功加入多播组,返回 true;否则返回 false。通过调用 joinMulticastGroup() 函数,QUdpSocket 将成为指定多播组的成员,并能够接收该多播组发送的数据报。

// 开始组播
void MainWindow::on_pushButton_start_clicked()
{// 获取IPQString IP= ui->lineEdit_address->text();groupAddress=QHostAddress(IP);// 获取端口quint16 groupPort = ui->lineEdit_port->text().toUInt();// 绑定端口if (udpSocket->bind(QHostAddress::AnyIPv4, groupPort, QUdpSocket::ShareAddress)){// 加入组播udpSocket->joinMulticastGroup(groupAddress);ui->plainTextEdit->appendPlainText("[*] 加入组播 " + IP + ":" + QString::number(groupPort));}
}

leaveMulticastGroup 退出组播

leaveMulticastGroup() 函数用于将 QUdpSocket 从指定的多播组中移除。通过调用该函数,QUdpSocket 将不再是指定多播组的成员,不再接收该多播组发送的数据报。

该函数原型如下:

bool QUdpSocket::leaveMulticastGroup(const QHostAddress & groupAddress, const QNetworkInterface & iface = QNetworkInterface()
)
  • groupAddress:要离开的多播组的组播地址。
  • iface:要离开多播组的网络接口。默认情况下,会选择默认的网络接口。

函数返回一个 bool 类型的值,表示是否成功离开了多播组。如果成功离开多播组,返回 true;否则返回 false

// 关闭组播
void MainWindow::on_pushButton_stop_clicked()
{// 退出组播udpSocket->leaveMulticastGroup(groupAddress);udpSocket->abort();ui->plainTextEdit->appendPlainText("[-] 退出组播");
}

writeDatagram 发送数据报

writeDatagram() 函数是 QUdpSocket 类的成员函数,用于发送数据报到指定的多播组。通过调用该函数,可以将数据报发送到指定的多播组和端口,让其他成员接收到该数据报。

其函数原型如下:

qint64 QUdpSocket::writeDatagram(const QByteArray & datagram, const QHostAddress & groupAddress, quint16 port
)
  • datagram:要发送的数据报的内容,通常是一个 QByteArray 对象。
  • groupAddress:要发送到的多播组的组播地址。
  • port:要发送到的多播组的端口号。

函数返回一个 qint64 类型的值,表示实际发送的字节数。如果发送成功,返回发送的字节数;否则返回 -1。

// 发送组播消息
void MainWindow::on_pushButton_send_clicked()
{quint16 groupPort = ui->lineEdit_port->text().toUInt();QString msg=ui->lineEdit_msg->text();QByteArray datagram=msg.toUtf8();udpSocket->writeDatagram(datagram,groupAddress,groupPort);
}

readDatagram 接收数据报

readDatagram() 函数是 QUdpSocket 类的成员函数,用于从套接字中读取数据报,并将其存储到指定的缓冲区中。通常情况下,可以使用这个函数来接收来自其他主机的数据报。通过使用该函数可从套接字中读取数据报,并获取数据报的源地址和端口号。

其函数原型如下:

qint64 QUdpSocket::readDatagram(char * data, qint64 maxSize, QHostAddress * address = nullptr, quint16 * port = nullptr
)
  • data:指向用于存储接收数据的缓冲区的指针。
  • maxSize:缓冲区的最大大小,即最多可以接收的字节数。
  • address:指向用于存储发送数据报的源地址的 QHostAddress 对象的指针。
  • port:指向用于存储发送数据报的源端口号的 quint16 类型的指针。

该函数返回一个 qint64 类型的值,表示实际接收的字节数。如果接收成功,返回接收的字节数;否则返回 -1。

// 读取数据报
void MainWindow::onSocketReadyRead()
{while(udpSocket->hasPendingDatagrams()){QByteArray datagram;datagram.resize(udpSocket->pendingDatagramSize());QHostAddress peerAddr;quint16 peerPort;udpSocket->readDatagram(datagram.data(),datagram.size(),&peerAddr,&peerPort);QString str=datagram.data();QString peer="[从 "+peerAddr.toString()+":"+QString::number(peerPort)+" 发送] ";ui->plainTextEdit->appendPlainText(peer+str);}
}

读者可自行运行课件程序,并在多台电脑中配置相同网段,当点击发送消息时所有同网段的程序都将收到广播,如下图所示;

这篇关于C++ Qt开发:QUdpSocket实现组播通信的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/830029

相关文章

Oracle查询优化之高效实现仅查询前10条记录的方法与实践

《Oracle查询优化之高效实现仅查询前10条记录的方法与实践》:本文主要介绍Oracle查询优化之高效实现仅查询前10条记录的相关资料,包括使用ROWNUM、ROW_NUMBER()函数、FET... 目录1. 使用 ROWNUM 查询2. 使用 ROW_NUMBER() 函数3. 使用 FETCH FI

Python脚本实现自动删除C盘临时文件夹

《Python脚本实现自动删除C盘临时文件夹》在日常使用电脑的过程中,临时文件夹往往会积累大量的无用数据,占用宝贵的磁盘空间,下面我们就来看看Python如何通过脚本实现自动删除C盘临时文件夹吧... 目录一、准备工作二、python脚本编写三、脚本解析四、运行脚本五、案例演示六、注意事项七、总结在日常使用

Java实现Excel与HTML互转

《Java实现Excel与HTML互转》Excel是一种电子表格格式,而HTM则是一种用于创建网页的标记语言,虽然两者在用途上存在差异,但有时我们需要将数据从一种格式转换为另一种格式,下面我们就来看看... Excel是一种电子表格格式,广泛用于数据处理和分析,而HTM则是一种用于创建网页的标记语言。虽然两

Java中Springboot集成Kafka实现消息发送和接收功能

《Java中Springboot集成Kafka实现消息发送和接收功能》Kafka是一个高吞吐量的分布式发布-订阅消息系统,主要用于处理大规模数据流,它由生产者、消费者、主题、分区和代理等组件构成,Ka... 目录一、Kafka 简介二、Kafka 功能三、POM依赖四、配置文件五、生产者六、消费者一、Kaf

使用Python实现在Word中添加或删除超链接

《使用Python实现在Word中添加或删除超链接》在Word文档中,超链接是一种将文本或图像连接到其他文档、网页或同一文档中不同部分的功能,本文将为大家介绍一下Python如何实现在Word中添加或... 在Word文档中,超链接是一种将文本或图像连接到其他文档、网页或同一文档中不同部分的功能。通过添加超

windos server2022里的DFS配置的实现

《windosserver2022里的DFS配置的实现》DFS是WindowsServer操作系统提供的一种功能,用于在多台服务器上集中管理共享文件夹和文件的分布式存储解决方案,本文就来介绍一下wi... 目录什么是DFS?优势:应用场景:DFS配置步骤什么是DFS?DFS指的是分布式文件系统(Distr

NFS实现多服务器文件的共享的方法步骤

《NFS实现多服务器文件的共享的方法步骤》NFS允许网络中的计算机之间共享资源,客户端可以透明地读写远端NFS服务器上的文件,本文就来介绍一下NFS实现多服务器文件的共享的方法步骤,感兴趣的可以了解一... 目录一、简介二、部署1、准备1、服务端和客户端:安装nfs-utils2、服务端:创建共享目录3、服

基于Python开发电脑定时关机工具

《基于Python开发电脑定时关机工具》这篇文章主要为大家详细介绍了如何基于Python开发一个电脑定时关机工具,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1. 简介2. 运行效果3. 相关源码1. 简介这个程序就像一个“忠实的管家”,帮你按时关掉电脑,而且全程不需要你多做

C#使用yield关键字实现提升迭代性能与效率

《C#使用yield关键字实现提升迭代性能与效率》yield关键字在C#中简化了数据迭代的方式,实现了按需生成数据,自动维护迭代状态,本文主要来聊聊如何使用yield关键字实现提升迭代性能与效率,感兴... 目录前言传统迭代和yield迭代方式对比yield延迟加载按需获取数据yield break显式示迭

Python实现高效地读写大型文件

《Python实现高效地读写大型文件》Python如何读写的是大型文件,有没有什么方法来提高效率呢,这篇文章就来和大家聊聊如何在Python中高效地读写大型文件,需要的可以了解下... 目录一、逐行读取大型文件二、分块读取大型文件三、使用 mmap 模块进行内存映射文件操作(适用于大文件)四、使用 pand