赞
踩
目录
(User Datagram Protocol即用户数据报协议)是一个轻量级的,不可靠的,面向数据报的无连接
协议。在网络质量令人十分不满意的环境下,UDP协议数据包丢失严重。由于UDP的特性:它不属于连
接型协议,因而具有资源消耗小,处理速度快的优点,所以通常音频、视频和普通数据在传送时使用
UDP较多,因为它们即使偶尔丢失一两个数据包,也不会对接收结果产生太大影响。所以QQ这种对保密
要求并不太高的聊天程序就是使用的UDP协议。
在Qt中提供了QUdpSocket 类来进行UDP数据报(datagrams)的发送和接收。Socket简单地说,就是
一个IP地址加一个port端口 。
流程:①创建QUdpSocket套接字对象 ②如果需要接收数据,必须绑定端口 ③发送数据用
writeDatagram,接收数据用 readDatagram 。
#include <QUdpSocket>
QUdpSocket *udpSocket = new QUdpSocket(this);
writeDatagram()
函数直接指定目标IP地址和端口。但如果需要从特定的本地端口接收数据,可以进行绑定:udpSocket->bind(localPort, QUdpSocket::ShareAddress);
writeDatagram()
函数发送数据包到目标地址和端口:QHostAddress targetAddress("192.168.0.100"); // 目标IP地址 quint16 targetPort = 1234; // 目标端口 QByteArray data = "Hello, UDP!"; // 要发送的数据 udpSocket->writeDatagram(data, targetAddress, targetPort);
readyRead
信号到一个槽函数,并在槽函数中读取数据:connect(udpSocket, &QUdpSocket::readyRead, this, &MyClass::readPendingDatagrams);
然后在槽函数readPendingDatagrams()
中处理接收到的数据:
void MyClass::readPendingDatagrams() { while (udpSocket->hasPendingDatagrams()) { QByteArray datagram; datagram.resize(udpSocket->pendingDatagramSize()); udpSocket->readDatagram(datagram.data(), datagram.size()); // 在这里处理接收到的数据 // ... } }
这样,你就可以使用UDP套接字在Qt中进行简单的UDP通信了。
示例说明: 假设我们有两个Qt应用程序,一个作为UDP服务器,另一个作为UDP客户端。服务器监听特定端口接收来自客户端的消息,并将消息原样发送回客户端。
- #include <QTcpServer>
- #include <QTcpSocket>
-
- class Server : public QObject
- {
- Q_OBJECT
-
- public:
- Server(QObject *parent = nullptr) : QObject(parent)
- {
- udpSocket = new QUdpSocket(this);
- udpSocket->bind(QHostAddress::Any, 1234);
-
- connect(udpSocket, &QUdpSocket::readyRead, this, &Server::readPendingDatagrams);
- }
-
- private slots:
- void readPendingDatagrams()
- {
- while (udpSocket->hasPendingDatagrams()) {
- QByteArray datagram;
- datagram.resize(udpSocket->pendingDatagramSize());
- udpSocket->readDatagram(datagram.data(), datagram.size());
-
- // 将接收到的数据原样发送回客户端
- udpSocket->writeDatagram(datagram, QHostAddress::LocalHost, 5678);
- }
- }
-
- private:
- QUdpSocket *udpSocket;
- };
![](https://csdnimg.cn/release/blogv2/dist/pc/img/newCodeMoreWhite.png)
- #include <QTcpSocket>
-
- class Client : public QObject
- {
- Q_OBJECT
-
- public:
- Client(QObject *parent = nullptr) : QObject(parent)
- {
- udpSocket = new QUdpSocket(this);
- }
-
- void sendMessage(const QByteArray &message)
- {
- udpSocket->writeDatagram(message, QHostAddress::LocalHost, 1234);
- }
-
- private:
- QUdpSocket *udpSocket;
- };
![](https://csdnimg.cn/release/blogv2/dist/pc/img/newCodeMoreWhite.png)
- // 在服务器端创建服务器对象
- Server server;
-
- // 在客户端创建客户端对象
- Client client;
-
- // 客户端发送消息给服务器
- client.sendMessage("Hello, server!");
-
- // 服务器会将消息原样发送回客户端
-
- // 可以在客户端的槽函数中处理接收到的消息
以上示例演示了简单的UDP通信过程,在实际应用中,你可以根据需要进行更复杂的数据处理和错误处理。
在UDP通信中,一些常见的错误例子可能包括:
错误1:未绑定本地端口 在使用QUdpSocket
时,如果忘记将UDP套接字绑定到本地端口,可能会导致数据无法正确发送或接收。
错误示例:
QUdpSocket *udpSocket = new QUdpSocket(this); udpSocket->writeDatagram("Hello, UDP!", QHostAddress::LocalHost, 1234);
改正方法: 确保在发送或接收数据前,先将UDP套接字绑定到本地端口。
QUdpSocket *udpSocket = new QUdpSocket(this); udpSocket->bind(QHostAddress::Any, 5678); // 绑定本地端口 udpSocket->writeDatagram("Hello, UDP!", QHostAddress::LocalHost, 1234);
错误2:接收数据时未处理所有数据报 在UDP通信中,可能会有多个数据报同时到达,如果只处理其中一个数据报,可能会导致其他数据报被丢弃。
错误示例:
void MyClass::readPendingDatagrams() { QByteArray datagram; datagram.resize(udpSocket->pendingDatagramSize()); udpSocket->readDatagram(datagram.data(), datagram.size()); // 处理接收到的数据(仅处理一个数据报) // ... }
改正方法: 使用循环处理所有待处理的数据报。
void MyClass::readPendingDatagrams() { while (udpSocket->hasPendingDatagrams()) { QByteArray datagram; datagram.resize(udpSocket->pendingDatagramSize()); udpSocket->readDatagram(datagram.data(), datagram.size()); // 处理接收到的数据(处理所有数据报) // ... } }
错误3:接收数据时未正确处理数据大小 当接收到的数据大小超过pendingDatagramSize()
返回的值时,可能会导致数据截断。
错误示例:
void MyClass::readPendingDatagrams() { while (udpSocket->hasPendingDatagrams()) { QByteArray datagram; // 问题:未正确处理数据大小,导致截断 datagram.resize(udpSocket->pendingDatagramSize()); udpSocket->readDatagram(datagram.data(), datagram.size()); // 处理接收到的数据 // ... } }
改正方法: 在读取数据之前,先获取实际接收到的数据大小,并根据该大小调整数组大小。
void MyClass::readPendingDatagrams() { while (udpSocket->hasPendingDatagrams()) { QByteArray datagram; datagram.resize(udpSocket->pendingDatagramSize()); // 获取实际接收到的数据大小,并根据该大小调整数组大小 qint64 bytesRead = udpSocket->readDatagram(datagram.data(), datagram.size()); // 处理接收到的数据 // 注意:如果需要使用`bytesRead`来截取datagram的有效部分,确保不使用未读取部分。 // ... } }
这些是一些常见的错误例子和相应的改正方法。通过注意这些细节,可以更好地编写稳定和可靠的UDP通信代码。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。