Qt：以太网udp组播发送与接收

#include "mainwindow.h" #include "ui_mainwindow.h" MainWindow::MainWindow(QWidget *parent) : QMainWindow(parent) , ui(new Ui::MainWindow) { ui->setupUi(this); udpSend=new QUdpSocket(this); udpRece=new QUdpSocket(this); udpRece->setSocketOption(QAbstractSocket::MulticastTtlOption,1); connect(udpRece,&QUdpSocket::readyRead,this,&MainWindow::receUdpMess);//连接读取udp通信数据 } MainWindow::~MainWindow() { delete ui; } //接收组播信息 void MainWindow::receUdpMess(){ while (udpRece->hasPendingDatagrams()){ QByteArray receData;//创建接收字节流 QHostAddress peerAddr;//接收地址 quint16 peerPort;//接收端口 quint16 size=udpRece->pendingDatagramSize();//读取接收udp数据大小 receData.resize(size);//重设接收字节流大小 udpRece->readDatagram(receData.data(),receData.size(),&peerAddr,&peerPort);//读取以太网发送端的udp数据 QString peer="[From]+"+peerAddr.toString()+":"+QString::number(peerPort)+"]";//读取发送端地址、端口 ui->plainTextEdit->appendPlainText(peer+receData.data());//将接收内容显示在文本框中 } } //发送组播 void MainWindow::sendUdpMess(){ quint16 groupPort=ui->lineEdit_goupPort->text().toInt();//获取组播端口 QString mesage=ui->lineEdit->text();//读取发送信息 QByteArray sendMess=mesage.toUtf8();//将发送的信息转化为字节流 udpSend->writeDatagram(sendMess,groupAddr,groupPort);//将待发送信息写入udp通信中 ui->plainTextEdit->appendPlainText("[发送端:]"+mesage);//发送信息显示 } //加入组播 void MainWindow::on_pBt_joinGroup_clicked() { QString IP_Group=ui->lineEdit_groupAddr->text();//获取组播地址 groupAddr=QHostAddress(IP_Group); quint16 groupPort=ui->lineEdit_goupPort->text().toInt();//获取组播端口 if(udpRece->bind(QHostAddress::AnyIPv4,groupPort,QUdpSocket::ShareAddress)){//绑定地址 udpRece->joinMulticastGroup(groupAddr);//加入组播 ui->plainTextEdit->appendPlainText("**加入组播成功"); ui->plainTextEdit->appendPlainText("**组播IP地址:"+IP_Group); ui->plainTextEdit->appendPlainText("**绑定端口："+QString::number(groupPort)); ui->pBt_joinGroup->setEnabled(false); ui->pBt_exitGroup->setEnabled(true); } } //退出组播 void MainWindow::on_pBt_exitGroup_clicked() { udpRece->leaveMulticastGroup(groupAddr);//退出组播 udpRece->abort();//解除绑定 ui->plainTextEdit->appendPlainText("**已退出组播"); ui->pBt_exitGroup->setEnabled(false); ui->pBt_joinGroup->setEnabled(true); sendTimer->stop(); } //清空文本框 void MainWindow::on_pBt_clearText_clicked() { ui->plainTextEdit->clear(); } //退出 void MainWindow::on_pBt_exit_clicked() { this->close(); } //发送信息 void MainWindow::on_pushButton_clicked() { sendTimer=new QTimer(this); connect(sendTimer,&QTimer::timeout,this,&MainWindow::sendUdpMess); sendTimer->start(1000);//一秒发一次 }