目录
UDP:
举例:
服务器端:
客户端:
使用示例:
错误例子并且改正:
UDP:
(User Datagram Protocol即用户数据报协议)是一个轻量级的,不可靠的,面向数据报的无连接
协议。在网络质量令人十分不满意的环境下,UDP协议数据包丢失严重。由于UDP的特性:它不属于连
接型协议,因而具有资源消耗小,处理速度快的优点,所以通常音频、视频和普通数据在传送时使用
UDP较多,因为它们即使偶尔丢失一两个数据包,也不会对接收结果产生太大影响。所以QQ这种对保密
要求并不太高的聊天程序就是使用的UDP协议。
在Qt中提供了QUdpSocket 类来进行UDP数据报(datagrams)的发送和接收。Socket简单地说,就是
一个IP地址加一个port端口 。
流程:①创建QUdpSocket套接字对象 ②如果需要接收数据,必须绑定端口 ③发送数据用
writeDatagram,接收数据用 readDatagram 。
举例:
- 导入必要的头文件:
#include <QUdpSocket>
- 创建UDP套接字:
QUdpSocket *udpSocket = new QUdpSocket(this);
- 绑定本地端口(可选): 通常,UDP套接字不需要绑定到特定的本地端口,而是通过
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_OBJECTpublic: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;
};
客户端:
#include <QTcpSocket>class Client : public QObject
{Q_OBJECTpublic:Client(QObject *parent = nullptr) : QObject(parent){udpSocket = new QUdpSocket(this);}void sendMessage(const QByteArray &message){udpSocket->writeDatagram(message, QHostAddress::LocalHost, 1234);}private:QUdpSocket *udpSocket;
};
使用示例:
// 在服务器端创建服务器对象 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通信代码。