QT网络编程之实现UDP广播发送和接收

推荐一个不错的人工智能学习网站，通俗易懂，内容全面，作为入门科普和学习提升都不错，分享一下给大家：前言icon-default.png?t=N7T8https://www.captainbed.cn/ai

一.UDP通信

1.QT中实现UDP通信主要用到了以下类：QUdpSocket、QHostAddress；

2.UdpServer是服务器端，用于监听客户端发送的消息并回复同样的消息；

  UdpClient是客户端，用于向服务器发送一条消息，并等待来自服务器的回复；

3.UDP与TCP的区别

UDP像写信，只要知道地址就可以发

TCP像打电话，只有两人同时在线才能通信

4.UDP多播组播

二．示例代码

本示例代码实现功能为本地管理的组播收发功能。

1.mainwindow.h

#ifndef MAINWINDOW_H

#define MAINWINDOW_H

#include <QMainWindow>

#include    <QUdpSocket>

#include    <QLabel>

namespace Ui {

class MainWindow;

}

class MainWindow : public QMainWindow

{

    Q_OBJECT

private:

    QLabel  *LabSocketState;

    QUdpSocket  *udpSocket;//用于与连接的客户端通讯的QTcpSocket

    QHostAddress    groupAddress;//组播地址

    QString getLocalIP();//获取本机IP地址

public:

    explicit MainWindow(QWidget *parent = 0);

    ~MainWindow();

private slots:

//自定义槽函数

    void    onSocketStateChange(QAbstractSocket::SocketState socketState);

    void    onSocketReadyRead();//读取socket传入的数据

    

    void on_actStart_triggered();

    void on_actStop_triggered();

    void on_actClear_triggered();

    void on_actHostInfo_triggered();

    void on_btnMulticast_clicked();

private:

    Ui::MainWindow *ui;

};

#endif // MAINWINDOW_H

2.mainwindow.cpp

#include "mainwindow.h"

#include "ui_mainwindow.h"

#include    <QtNetwork>

QString MainWindow::getLocalIP()

{

    QString hostName=QHostInfo::localHostName();//本地主机名

    QHostInfo   hostInfo=QHostInfo::fromName(hostName);

    QString   localIP="";

    QList<QHostAddress> addList=hostInfo.addresses();//

    if (!addList.isEmpty())

    for (int i=0;i<addList.count();i++)

    {

        QHostAddress aHost=addList.at(i);

        if (QAbstractSocket::IPv4Protocol==aHost.protocol())

        {

            localIP=aHost.toString();

            break;

        }

    }

    return localIP;

}

MainWindow::MainWindow(QWidget *parent) :

    QMainWindow(parent),

    ui(new Ui::MainWindow)

{

    ui->setupUi(this);

    LabSocketState=new QLabel("Socket状态：");//

    LabSocketState->setMinimumWidth(200);

    ui->statusBar->addWidget(LabSocketState);

    QString localIP=getLocalIP();//本地主机名

    this->setWindowTitle(this->windowTitle()+"----本机IP："+localIP);

    udpSocket=new QUdpSocket(this);//用于与连接的客户端通讯的QTcpSocket

    udpSocket->setSocketOption(QAbstractSocket::MulticastTtlOption,1);

    connect(udpSocket,SIGNAL(stateChanged(QAbstractSocket::SocketState)),

            this,SLOT(onSocketStateChange(QAbstractSocket::SocketState)));

    onSocketStateChange(udpSocket->state());

    connect(udpSocket,SIGNAL(readyRead()),

            this,SLOT(onSocketReadyRead()));

}

MainWindow::~MainWindow()

{

    udpSocket->abort();

    delete udpSocket;

    delete ui;

}

void MainWindow::onSocketStateChange(QAbstractSocket::SocketState socketState)

{

    switch(socketState)

    {

    case QAbstractSocket::UnconnectedState:

        LabSocketState->setText("scoket状态：UnconnectedState");

        break;

    case QAbstractSocket::HostLookupState:

        LabSocketState->setText("scoket状态：HostLookupState");

        break;

    case QAbstractSocket::ConnectingState:

        LabSocketState->setText("scoket状态：ConnectingState");

        break;

    case QAbstractSocket::ConnectedState:

        LabSocketState->setText("scoket状态：ConnectedState");

        break;

    case QAbstractSocket::BoundState:

        LabSocketState->setText("scoket状态：BoundState");

        break;

    case QAbstractSocket::ClosingState:

        LabSocketState->setText("scoket状态：ClosingState");

        break;

    case QAbstractSocket::ListeningState:

        LabSocketState->setText("scoket状态：ListeningState");

    }

}

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="[From "+peerAddr.toString()+":"+QString::number(peerPort)+"] ";

        ui->plainTextEdit->appendPlainText(peer+str);

    }

}

void MainWindow::on_actStart_triggered()

{//加入组播

    QString     IP=ui->comboIP->currentText();

    groupAddress=QHostAddress(IP);//多播组地址

    quint16     groupPort=ui->spinPort->value();//端口

    if (udpSocket->bind(QHostAddress::AnyIPv4, groupPort, QUdpSocket::ShareAddress))//先绑定端口

    {

        udpSocket->joinMulticastGroup(groupAddress); //加入多播组

        ui->plainTextEdit->appendPlainText("**加入组播成功");

        ui->plainTextEdit->appendPlainText("**组播地址IP："+IP);

        ui->plainTextEdit->appendPlainText("**绑定端口："+QString::number(groupPort));

        ui->actStart->setEnabled(false);

        ui->actStop->setEnabled(true);

        ui->comboIP->setEnabled(false);

    }

    else

        ui->plainTextEdit->appendPlainText("**绑定端口失败");

}

void MainWindow::on_actStop_triggered()

{//退出组播

    udpSocket->leaveMulticastGroup(groupAddress);//退出组播

    udpSocket->abort(); //解除绑定

    ui->actStart->setEnabled(true);

    ui->actStop->setEnabled(false);

    ui->comboIP->setEnabled(true);

    ui->plainTextEdit->appendPlainText("**已退出组播,解除端口绑定");

}

void MainWindow::on_actClear_triggered()

{

    ui->plainTextEdit->clear();

}

void MainWindow::on_actHostInfo_triggered()

{

    QString hostName=QHostInfo::localHostName();//本地主机名

    ui->plainTextEdit->appendPlainText("本机主机名："+hostName+"\n");

    QHostInfo   hostInfo=QHostInfo::fromName(hostName);

    QList<QHostAddress> addList=hostInfo.addresses();//

    if (!addList.isEmpty())

    for (int i=0;i<addList.count();i++)

    {

        QHostAddress aHost=addList.at(i);

        if (QAbstractSocket::IPv4Protocol==aHost.protocol())

        {

            QString IP=aHost.toString();

            ui->plainTextEdit->appendPlainText("本机IP地址："+aHost.toString());

            if (ui->comboIP->findText(IP)<0)

                ui->comboIP->addItem(IP);

        }

    }

}

void MainWindow::on_btnMulticast_clicked()

{//发送组播消息

    quint16     groupPort=ui->spinPort->value();

    QString  msg=ui->editMsg->text();

    QByteArray  datagram=msg.toUtf8();

    udpSocket->writeDatagram(datagram,groupAddress,groupPort);

    ui->plainTextEdit->appendPlainText("[multicst] "+msg);

    ui->editMsg->clear();

    ui->editMsg->setFocus();

}

三.测试结果

  1. 初始状态

2.组播通讯结果

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/539698.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Spring Boot 集成 WebSocket 实例 | 前端持续打印远程日志文件更新内容（模拟 tail 命令）

Spring Boot 集成 WebSocket 实例 | 前端持续打印远程日志文件更新内容（模拟 tail 命令）

这个是我在 CSDN 的第一百篇原则博文&#xff0c;留念&#x1f60e; #1 需求说明 先说下项目结构&#xff0c;后端基于 Spring Boot 3&#xff0c;前端为 node.js 开发的控制台程序。现在希望能够在前端模拟 tail 命令&#xff0c;持续输出后端的日志文件。 #2 技术方案 #2.…
阅读更多...
Ansible自动化运维Inventory与Ad-Hoc

Ansible自动化运维Inventory与Ad-Hoc

前言 自动化运维是指利用自动化工具和技术来简化、自动化和优化IT基础设施的管理和运维过程&#xff0c;从而提高效率、降低成本&#xff0c;并减少人为错误。在当今复杂的IT环境中&#xff0c;自动化运维已经成为许多组织和企业提高生产力和保证系统稳定性的重要手段。Ansibl…
阅读更多...
react native常用插件

react native常用插件

react-native-async-storage/async-storage 说明&#xff1a;AsyncStorage 是一个在 react-native 中轻量存储的库&#xff1b;跟 localStorage 类似&#xff0c;API 也几乎一样&#xff1b;存储的时候需要将存储内容转成字符串存储。 react-navigation/material-bottom-tabs …
阅读更多...
SwiftUI的textfile

SwiftUI的textfile

SwiftUI的textfile 记录一下SwiftUI的textfile的基本使用方法 import SwiftUIstruct TextfileBootCamp: View {State var enterString ""State var enterList [String]()var body: some View {NavigationView(content: {VStack {/// 双向绑定输入的字符TextField(…
阅读更多...
泽众云真机-机型支持ADB调试功能即将上线

泽众云真机-机型支持ADB调试功能即将上线

最近云真机平台在线客服&#xff0c;收到很多咨询关于ADB调试功能&#xff0c;什么时候能更新&#xff1f;据小编所知&#xff0c;正在升级之中&#xff0c;有一块专门为了解决ADB调试功能提前准备&#xff0c;升级网络硬件设备&#xff0c;目前平台的功能已开发完成&#xff0…
阅读更多...
使用docker-compose部署MySQL三主六从半同步集群（MMM架构）

使用docker-compose部署MySQL三主六从半同步集群（MMM架构）

文章目录 &#x1f50a;博主介绍&#x1f964;本文内容部署MySQL三主六从半同步集群一主二从同步集群规划需要安装docker和docker-compose命令形式安装安装docker安装docker-compose 宝塔面板形式安装 部署node1节点的master1docker-compose.yaml文件my.cnf文件授权启动 部署no…
阅读更多...
C# danbooru Stable Diffusion 提示词反推 Onnx Demo

C# danbooru Stable Diffusion 提示词反推 Onnx Demo

目录 说明 效果 模型信息 项目 代码 下载 C# danbooru Stable Diffusion 提示词反推 Onnx Demo 说明 模型下载地址&#xff1a;https://huggingface.co/deepghs/ml-danbooru-onnx 效果 模型信息 Model Properties ------------------------- ----------------------…
阅读更多...
OpenvSwitch VXLAN 隧道实验

OpenvSwitch VXLAN 隧道实验

OpenvSwitch VXLAN 隧道实验 最近在了解 openstack 网络&#xff0c;下面基于ubuntu虚拟机安装OpenvSwitch&#xff0c;测试vxlan的基本配置。 节点信息&#xff1a; 主机名IP地址OS网卡node1192.168.95.11Ubuntu 22.04ens33node2192.168.95.12Ubuntu 22.04ens33 网卡信息&…
阅读更多...
2024/3/14打卡棋子（14届蓝桥杯）——差分

2024/3/14打卡棋子（14届蓝桥杯）——差分

标准差分模板 差分——前缀和的逆运算&#xff08;一维二维&#xff09;-CSDN博客 题目 小蓝拥有 nn 大小的棋盘&#xff0c;一开始棋盘上全都是白子。 小蓝进行了 m 次操作&#xff0c;每次操作会将棋盘上某个范围内的所有棋子的颜色取反(也就是白色棋子变为黑色&#xff0…
阅读更多...
【数据结构与算法】(13)：交换排序之冒泡排序和快速排序

【数据结构与算法】(13)：交换排序之冒泡排序和快速排序

&#x1f921;博客主页&#xff1a;Code_文晓 &#x1f970;本文专栏&#xff1a;数据结构与算法 &#x1f63b;欢迎关注&#xff1a;感谢大家的点赞评论关注&#xff0c;祝您学有所成&#xff01; ✨✨&#x1f49c;&#x1f49b;想要学习更多数据结构与算法点击专栏链接查看&…
阅读更多...
StarRocks——滴滴的极速多维分析实践

StarRocks——滴滴的极速多维分析实践

背景 滴滴集团作为生活服务领域的头部企业&#xff0c;其中橙心优选经过一年多的数据体系建设&#xff0c;逐渐将一部分需要实时交互查询&#xff0c;即席查询的多维数据分析需求由ClickHouse迁移到了StarRocks中&#xff0c;接下来以StarRocks实现的漏斗分析为例介绍StarRocks…
阅读更多...
MapReduce解析：从定义到核心思想，编程规范与序列化解读

MapReduce解析：从定义到核心思想，编程规范与序列化解读

目录 一、 MapReduce1.1 MapReduce定义1.2 MapReduce优缺点1.2.1 优点1.2.2 缺点 1.3 MapReduce核心思想1.4 MapReduce进程1.5 常用数据序列化类型1.6 MapReduce编程规范1.6.1Mapper阶段1.6.2 Reduce阶段1.6.3 Driver阶段 1.7 WordCount案例实操1.7.1 本地测试1.7.2 提交到集群…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023