UDP广播和组播的实现

本是古典何须时尚 2022-12-28 06:12 255阅读 0赞

### UDP的广播： ###

**widget.h：**

#ifndef WIDGET_H
    #define WIDGET_H
    
    #include <QWidget>
    #include <QUdpSocket>
    #include <QByteArray>
    #include <QNetworkInterface>
    #include <QDateTime>
    
    QT_BEGIN_NAMESPACE
    namespace Ui { class Widget; }
    QT_END_NAMESPACE
    
    class Widget : public QWidget
    {
        Q_OBJECT
    
    public:
        Widget(QWidget *parent = nullptr);
        ~Widget();
    
    private slots:
        void on_connectButton_clicked();
    
        void on_quitButton_clicked();
    
        void on_sendMessageButton_clicked();
    
    private:
        Ui::Widget *ui;
        QUdpSocket * udpSocket;
    };
    #endif // WIDGET_H

**widget.cpp：**

#include "widget.h"
    #include "ui_widget.h"
    
    Widget::Widget(QWidget *parent)
        : QWidget(parent)
        , ui(new Ui::Widget)
    {
        ui->setupUi(this);
    
        udpSocket = new QUdpSocket(this);
    
        this->connect(udpSocket,&QUdpSocket::readyRead,[=](){
            while (udpSocket->hasPendingDatagrams()) {
                QByteArray datagram;//用于存放接收的数据报
                datagram.resize(udpSocket->pendingDatagramSize());
                udpSocket->readDatagram(datagram.data(),datagram.size());
    
                QDateTime dateTime = QDateTime::currentDateTime();
    
                ui->recvMessageTextEdit->append(dateTime.toString("yyyy-MM-dd hh:mm:ss") + ":  " + QString(datagram));
            }
    
            ui->recvMessageTextEdit->append("接收完成！！！");
        });
    }
    
    Widget::~Widget()
    {
        delete ui;
    }
    
    
    void Widget::on_connectButton_clicked()
    {
        QList<QHostAddress> AddressList = QNetworkInterface::allAddresses();
        QHostAddress result;
        foreach(QHostAddress address, AddressList){
            if(address.protocol() == QAbstractSocket::IPv4Protocol &&
                    address != QHostAddress::Null &&
                    address != QHostAddress::LocalHost){
                if (address.toString().contains("127.0.0.1")){
                    continue;
                }
                result = address;
                break;
            }
        }
    
        udpSocket->bind(QHostAddress(result.toString()),ui->portLineEdit->text().toUInt(),QAbstractSocket::ShareAddress);
    
        ui->ipLineEdit->setText(result.toString());
    
        //udpSocket->joinMulticastGroup(QHostAddress(ui->ipLineEdit->text()));
    }
    
    void Widget::on_quitButton_clicked()
    {
        udpSocket->close();
    }
    
    void Widget::on_sendMessageButton_clicked()
    {
        udpSocket->writeDatagram(ui->sendMessageTextEdit->toPlainText().toUtf8().data(),ui->sendMessageTextEdit->toPlainText().toUtf8().length(),QHostAddress::Broadcast,ui->portLineEdit->text().toUInt());
        ui->sendMessageTextEdit->clear();
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d0bDE5OTI_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d0bDE5OTI_size_16_color_FFFFFF_t_70 1][]

### UDP的组播： ###

**widget.h：**

**widget.cpp：**

#include "widget.h"
    #include "ui_widget.h"
    
    Widget::Widget(QWidget *parent)
        : QWidget(parent)
        , ui(new Ui::Widget)
    {
        ui->setupUi(this);
    
        udpSocket = new QUdpSocket(this);
    
        this->connect(udpSocket,&QUdpSocket::readyRead,[=](){
            while (udpSocket->hasPendingDatagrams()) {
                QByteArray datagram;//用于存放接收的数据报
                datagram.resize(udpSocket->pendingDatagramSize());
                udpSocket->readDatagram(datagram.data(),datagram.size());
    
                QDateTime dateTime = QDateTime::currentDateTime();
    
                ui->recvMessageTextEdit->append(dateTime.toString("yyyy-MM-dd hh:mm:ss") + ":  " + QString(datagram));
            }
    
            ui->recvMessageTextEdit->append("接收完成！！！");
        });
    }
    
    Widget::~Widget()
    {
        delete ui;
    }
    
    
    void Widget::on_connectButton_clicked()
    {
        QList<QHostAddress> AddressList = QNetworkInterface::allAddresses();
        QHostAddress result;
        foreach(QHostAddress address, AddressList){
            if(address.protocol() == QAbstractSocket::IPv4Protocol &&
                    address != QHostAddress::Null &&
                    address != QHostAddress::LocalHost){
                if (address.toString().contains("127.0.0.1")){
                    continue;
                }
                result = address;
                break;
            }
        }
    
        udpSocket->bind(QHostAddress(result.toString()),ui->portLineEdit->text().toUInt(),QAbstractSocket::ShareAddress);
    
        //设置组播地址： 224.0.0.1-> 239.255.255.255
        ui->ipLineEdit->setText("224.0.0.2");
    
        bool isSuccess = udpSocket->joinMulticastGroup(QHostAddress(ui->ipLineEdit->text()));
    
        qDebug() << isSuccess;
    }
    
    void Widget::on_quitButton_clicked()
    {
        udpSocket->close();
    }
    
    void Widget::on_sendMessageButton_clicked()
    {
        udpSocket->writeDatagram(ui->sendMessageTextEdit->toPlainText().toUtf8().data(),ui->sendMessageTextEdit->toPlainText().toUtf8().length(),QHostAddress(ui->ipLineEdit->text()),ui->portLineEdit->text().toUInt());
        ui->sendMessageTextEdit->clear();
    }

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d0bDE5OTI_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d0bDE5OTI_size_16_color_FFFFFF_t_70 2][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d0bDE5OTI_size_16_color_FFFFFF_t_70]: /images/20221120/6b5eacbb3f334281929e41de20767fd4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d0bDE5OTI_size_16_color_FFFFFF_t_70 1]: /images/20221120/d8e3a201072142fdb16620951d34f4af.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d0bDE5OTI_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20201214210633477.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3d0bDE5OTI=,size_16,color_FFFFFF,t_70