ToB企服应用市场:ToB评测及商务社交产业平台

标题: C++ Qt开发:QUdpSocket实现组播通信 [打印本页]

作者: 何小豆儿在此    时间: 2024-5-14 19:32
标题: C++ Qt开发:QUdpSocket实现组播通信
Qt 是一个跨平台C++图形界面开发库,使用Qt可以快速开发跨平台窗体应用程序,在Qt中我们可以通过拖拽的方式将差别组件放到指定的位置,实现图形化开发极大的方便了开发效率,本章将重点介绍如何运用QUdpSocket组件实现基于UDP的组播通信。
组播是一种一对多的通信方式,允许一个发送者将数据报文发送到多个接收者,这些接收者通过共享雷同的组播IP地址进行通信。在设置组播地址时需要留意,该范围被限制在239.0.0.0~239.255.255.255以内,这是预留给组播的地址范围。
setSocketOption 设置套接字
在Qt中使用组播,首先需要调用setSocketOption函数,该函数是 QUdpSocket 类的成员函数,用于设置套接字的选项。
该函数原型如下:
  1. bool QUdpSocket::setSocketOption(
  2.     QAbstractSocket::SocketOption option,
  3.     const QVariant & value
  4. )
复制代码
函数返回一个 bool 类型的值,表示是否乐成设置了选项。如果设置乐成,返回 true,否则返回 false。
  1. MainWindow::MainWindow(QWidget *parent)
  2.     : QMainWindow(parent)
  3.     , ui(new Ui::MainWindow)
  4. {
  5.     ui->setupUi(this);
  6.     udpSocket=new QUdpSocket(this);
  7.     // 设置为多播
  8.     udpSocket->setSocketOption(QAbstractSocket::MulticastTtlOption,1);
  9. }
复制代码
bind 绑定套接字地址
接着就是对特定端口的绑定,绑定端口可以通过调用bind函数,该函数用于将 QUdpSocket 绑定到指定的当地地址和端口,并设置特定的绑定选项。
在我们的课件中,使用 bind() 将 QUdpSocket 绑定到 IPv4 的任意地址,并指定了一个组播(Multicast)端口,同时设置了共享地址(ShareAddress)选项。
该函数原型如下:
  1. void QUdpSocket::bind(
  2.     const QHostAddress & address,
  3.     quint16 port,
  4.     BindMode mode = DefaultForPlatform
  5. )
复制代码
函数将 QUdpSocket 绑定到指定的地址和端口,并且允许多个套接字同时共享雷同的地址和端口。
joinMulticastGroup 加入组播
joinMulticastGroup() 函数是 QUdpSocket 类的成员函数,用于将 QUdpSocket 加入指定的多播组。
该函数原型如下:
  1. bool QUdpSocket::joinMulticastGroup(
  2.     const QHostAddress & groupAddress,
  3.     const QNetworkInterface & iface = QNetworkInterface()
  4. )
复制代码
函数返回一个 bool 类型的值,表示是否乐成加入了多播组。如果乐成加入多播组,返回 true;否则返回 false。通过调用 joinMulticastGroup() 函数,QUdpSocket 将成为指定多播组的成员,并可以或许接收该多播组发送的数据报。
  1. // 开始组播
  2. void MainWindow::on_pushButton_start_clicked()
  3. {
  4.     // 获取IP
  5.     QString IP= ui->lineEdit_address->text();
  6.     groupAddress=QHostAddress(IP);
  7.     // 获取端口
  8.     quint16 groupPort = ui->lineEdit_port->text().toUInt();
  9.     // 绑定端口
  10.     if (udpSocket->bind(QHostAddress::AnyIPv4, groupPort, QUdpSocket::ShareAddress))
  11.     {
  12.         // 加入组播
  13.         udpSocket->joinMulticastGroup(groupAddress);
  14.         ui->plainTextEdit->appendPlainText("[*] 加入组播 " + IP + ":" + QString::number(groupPort));
  15.     }
  16. }
复制代码
leaveMulticastGroup 退出组播
leaveMulticastGroup() 函数用于将 QUdpSocket 从指定的多播组中移除。通过调用该函数,QUdpSocket 将不再是指定多播组的成员,不再接收该多播组发送的数据报。
该函数原型如下:
  1. bool QUdpSocket::leaveMulticastGroup(
  2.     const QHostAddress & groupAddress,
  3.     const QNetworkInterface & iface = QNetworkInterface()
  4. )
复制代码
函数返回一个 bool 类型的值,表示是否乐成离开了多播组。如果乐成离开多播组,返回 true;否则返回 false。
  1. // 关闭组播
  2. void MainWindow::on_pushButton_stop_clicked()
  3. {
  4.     // 退出组播
  5.     udpSocket->leaveMulticastGroup(groupAddress);
  6.     udpSocket->abort();
  7.     ui->plainTextEdit->appendPlainText("[-] 退出组播");
  8. }
复制代码
writeDatagram 发送数据报
writeDatagram() 函数是 QUdpSocket 类的成员函数,用于发送数据报到指定的多播组。通过调用该函数,可以将数据报发送到指定的多播组和端口,让其他成员接收到该数据报。
其函数原型如下:
  1. qint64 QUdpSocket::writeDatagram(
  2.     const QByteArray & datagram,
  3.     const QHostAddress & groupAddress,
  4.     quint16 port
  5. )
复制代码
函数返回一个 qint64 类型的值,表示实际发送的字节数。如果发送乐成,返回发送的字节数;否则返回 -1。
  1. // 发送组播消息
  2. void MainWindow::on_pushButton_send_clicked()
  3. {
  4.     quint16 groupPort = ui->lineEdit_port->text().toUInt();
  5.     QString msg=ui->lineEdit_msg->text();
  6.     QByteArray datagram=msg.toUtf8();
  7.     udpSocket->writeDatagram(datagram,groupAddress,groupPort);
  8. }
复制代码
readDatagram 接收数据报
readDatagram() 函数是 QUdpSocket 类的成员函数,用于从套接字中读取数据报,并将其存储到指定的缓冲区中。通常情况下,可以使用这个函数来接收来自其他主机的数据报。通过使用该函数可从套接字中读取数据报,并获取数据报的源地址和端口号。
其函数原型如下:
  1. qint64 QUdpSocket::readDatagram(
  2.     char * data, qint64 maxSize,
  3.     QHostAddress * address = nullptr,
  4.     quint16 * port = nullptr
  5. )
复制代码
该函数返回一个 qint64 类型的值,表示实际接收的字节数。如果接收获功,返回接收的字节数;否则返回 -1。
  1. // 读取数据报
  2. void MainWindow::onSocketReadyRead()
  3. {
  4.     while(udpSocket->hasPendingDatagrams())
  5.     {
  6.         QByteArray datagram;
  7.         datagram.resize(udpSocket->pendingDatagramSize());
  8.         QHostAddress peerAddr;
  9.         quint16 peerPort;
  10.         udpSocket->readDatagram(datagram.data(),datagram.size(),&peerAddr,&peerPort);
  11.         QString str=datagram.data();
  12.         QString peer="[从 "+peerAddr.toString()+":"+QString::number(peerPort)+" 发送] ";
  13.         ui->plainTextEdit->appendPlainText(peer+str);
  14.     }
  15. }
复制代码
读者可自行运行课件程序,并在多台电脑中配置雷同网段,当点击发送消息时全部同网段的程序都将收到广播,如下图所示;


免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。




欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4