【QT】UDP

核心API

示例：回显服务器

服务器端编写：

第一步：创建出socket对象

第二步：连接信号槽

第三步：绑定端口号

第四步：编写信号槽所绑定方法

第五步：编写第四步中处理请求的方法

客户端编写：

界面设计

代码编写

发送按钮槽函数

处理响应函数

完整代码：

测试结果：

注意：

使用Qt网络编程的API，需要先在 .pro文件中添加 network模块！！

QT += core gui network

核心API

主要的类有两个 QUdpSocket 和 QNetworkDatagram，upd传输的是数据报，QNetworkDatagram就是qt中udp传输的内容；

QUdpSocket 表示⼀个 UDP 的 socket ⽂件.

名称	类型	说明	对应原生API
bind(const QHostAddress&, quint16)	方法	绑定指定的端⼝号.	bind
receiveDatagram()	方法	返回QNetworkDatagram读取⼀个 UDP 数据报	recvfrom
writeDatagram(const QNetworkDatagram&)	方法	发送⼀个 UDP 数据报	sendto
readyRead	信号	在收到数据并准备就绪后触发	⽆ (类似于 IO 多路复⽤的通知机制)

QNetworkDatagram 表示⼀个 UDP 数据报

名称	类型	说明	对应原生API
QNetworkDatagram(const QByteArray&, const QHostAddress& , quint16 )	构造函数	通过 QByteArray , ⽬标 IP 地址, ⽬标端⼝号构造⼀个 UDP 数据报. 通常⽤于发送数据时.	无
data()	方法	获取数据报内部持有的数据. 返回 QByteArray	无
senderAddress()	方法	获取数据报中包含的对端的 IP 地址.	无
senderPort()	方法	获取数据报中包含的对端的端⼝号.	；无

在编写udp相关代码时，注意事项：

一定要先连接信号槽，再绑定端口号，一旦绑定端口了，意味着请求就可以被收到了，如果在完成绑定之后，在连接信号槽之前，有客户端把请求发过来了，此时就可能读不到这样的请求。
一个端口号只能被一个socket绑定。
socket->errorString() 本质上也是对系统的errno机制进行封装

示例：回显服务器

服务器端编写：

第一步：创建出socket对象

socket = new QUdpSocket(this);

第二步：连接信号槽

connect(socket , &QUdpSocket::readyRead , this , &Widget::processRequest);

第三步：绑定端口号

这里记得判断是否绑定成功，如果端口号被其他socket所绑定，我们就不能在绑定该端口号！

    bool ret = socket->bind(QHostAddress::Any,9090);

    if(!ret)

    {

        //绑定失败

        QMessageBox::critical(this,"服务器启动出错",socket->errorString());

        return;

    }

第四步：编写信号槽所绑定方法

void Widget::processRequest()

{

    //1.读取请求并解析

    const QNetworkDatagram& requestDatagram = socket->receiveDatagram();

    QString request = requestDatagram.data(); //这里data()返回的是QByte数据

    //2.根据请求计算响应（由于这里仅仅是回显服务器，响应不需要计算，就是请求本身）

    const QString& response = process(request);

    //3.把响应写回客户端,响应数据包（数据是啥，客户端ip地址，客户端端口）

    QNetworkDatagram responseDatagram(response.toUtf8(),requestDatagram.senderAddress(),requestDatagram.senderPort());

    //response.toUtf8() 取出QString内部的字节数组

    socket->writeDatagram(responseDatagram);

    //4.把这次交互的信息，显示到界面上

    QString log = "[" + requestDatagram.senderAddress().toString() + ":" + QString::number(requestDatagram.senderPort())+

            "] req：" + request + ", resp：" + response;

    ui->listWidget->addItem(log);

}

第五步：编写第四步中处理请求的方法

QString Widget::process(const QString &request)

{

//请求处理过程，由于当前是回显服务i，响应和请求完全一样，不需要进行处理

return request;

}

完整代码如下：

#include "widget.h"
#include "ui_widget.h"
#include <QMessageBox>
#include <QNetworkDatagram>
Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget)
{ui->setupUi(this);//创建出这个对象socket = new QUdpSocket(this);//设置窗口标题this->setWindowTitle("服务器");//连接信号槽connect(socket,&QUdpSocket::readyRead,this,&Widget::processRequest);//绑定端口号bool ret = socket->bind(QHostAddress::Any,9090);if(!ret){//绑定失败QMessageBox::critical(this,"服务器启动出错",socket->errorString());return;}}Widget::~Widget()
{delete ui;
}void Widget::processRequest()
{//1.读取请求并解析const QNetworkDatagram& requestDatagram = socket->receiveDatagram();QString request = requestDatagram.data();//2.根据请求计算响应（由于这里仅仅是回显服务器，响应不需要计算，就是请求本身）const QString& response = process(request);//3.把响应写回客户端,响应数据包（数据是啥，客户端ip地址，客户端端口）QNetworkDatagram responseDatagram(response.toUtf8(),requestDatagram.senderAddress(),requestDatagram.senderPort());//response.toUtf8() 取出QString内部的字节数组socket->writeDatagram(responseDatagram);//4.把这次交互的信息，显示到界面上QString log = "[" + requestDatagram.senderAddress().toString() + ":" + QString::number(requestDatagram.senderPort())+"] req：" + request + ", resp：" + response;ui->listWidget->addItem(log);
}QString Widget::process(const QString &request)
{//请求处理过程，由于当前是回显服务i，响应和请求完全一样，不需要进行处理return request;
}

客户端编写：

界面设计

我们客户端简单设计成如下：

效果如下：

端口号本质上是一个2字节的无符号整数。

代码编写

首先我们写定义两个常量，描述服务器的地址和端口：

const QString& SERVER_IP = "127.0.0.1";
const quint16 SERVER_PORT = 9090;

发送按钮槽函数

void Widget::on_pushButton_clicked()

{

    //1.获取输入框的内容

    const QString& text = ui->lineEdit->text();

    //2. 构造UDP请求数据，这里ip我们是QString，参数识别不出来，需要我们进行转换

    QNetworkDatagram requestDatagram(text.toUtf8(),QHostAddress(SERVER_IP),SERVER_PORT);

    //3. 发送请求数据

    socket->writeDatagram(requestDatagram);

    //4. 把发送的请求数据也添加到列表框中

    ui->listWidget->addItem("客户端说：" + text);

    //5. 把输入框的内容也清空一下，方便下次输入

    ui->lineEdit->setText("");

}

处理响应函数

void Widget::processHandle()

{

    //通过这个函数来处理收到的响应

    //1.读取到响应的数据

    const QNetworkDatagram& responseDatagram = socket->receiveDatagram();

//这里不用换引用是因为.data()返回的是QByte类型，涉及类型转换

    QString response =responseDatagram.data();

    //2. 把响应数据显示到界面上

    ui->listWidget->addItem("服务器说："+response);

}

完整代码：

widget.h

#ifndef WIDGET_H
#define WIDGET_H#include <QWidget>
#include <QUdpSocket>
QT_BEGIN_NAMESPACE
namespace Ui { class Widget; }
QT_END_NAMESPACEclass Widget : public QWidget
{Q_OBJECTpublic:Widget(QWidget *parent = nullptr);~Widget();void processHandle();
private slots:void on_pushButton_clicked();private:Ui::Widget *ui;QUdpSocket* socket;
};
#endif // WIDGET_H

widget.cpp

#include "widget.h"
#include "ui_widget.h"
#include <QNetworkDatagram>
const QString& SERVER_IP = "127.0.0.1";
const quint16 SERVER_PORT = 9090;
Widget::Widget(QWidget *parent): QWidget(parent), ui(new Ui::Widget)
{ui->setupUi(this);socket = new QUdpSocket(this);//修改窗口标题，区分这是一个客户端程序this->setWindowTitle("客户端");//通过信号槽，来处理服务器返回的数据connect(socket,&QUdpSocket::readyRead,this,&Widget::processHandle);}
Widget::~Widget()
{delete ui;
}void Widget::processHandle()
{//通过这个函数来处理收到的响应//1.读取到响应的数据const QNetworkDatagram& responseDatagram = socket->receiveDatagram();QString response =responseDatagram.data();//2. 把响应数据显示到界面上ui->listWidget->addItem("服务器说："+response);
}void Widget::on_pushButton_clicked()
{//1.获取输入框的内容const QString& text = ui->lineEdit->text();//2. 构造UDP请求数据QNetworkDatagram requestDatagram(text.toUtf8(),QHostAddress(SERVER_IP),SERVER_PORT);//3. 发送请求数据socket->writeDatagram(requestDatagram);//4. 把发送的请求数据也添加到列表框中ui->listWidget->addItem("客户端说：" + text);//5. 把输入框的内容也清空一下，方便下次输入ui->lineEdit->setText("");
}