服务端代码 (python)

import socketdef udp_server(host='0.0.0.0', port=12345):# 创建一个UDP套接字sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)# 绑定服务器的IP地址和端口号sock.bind((host, port))print(f"UDP服务器已启动，监听端口 {port}...")try:while True:# 接收来自客户端的数据包data, addr = sock.recvfrom(1024)  # 1024是缓冲区大小# 打印接收到的数据和客户端地址print(f"接收到来自 {addr} 的数据: {data.decode()}")# 构造响应数据response = f"服务器已接收到来自 {addr} 的数据: {data.decode()}"# 向客户端发送响应数据包sock.sendto(response.encode(), addr)# 打印发送响应的确认print(f"已向 {addr} 发送响应数据")except KeyboardInterrupt:print("服务器接收到中断信号，正在关闭...")finally:# 关闭套接字sock.close()print("服务器已关闭")# 运行UDP服务器
udp_server()

在这个示例中，服务器使用recvfrom方法接收数据包，该方法会阻塞直到接收到一个数据包。数据包包含两部分：数据本身和客户端的地址（IP地址和端口号）。

注意，虽然这个服务器代码看起来是顺序执行的，但实际上UDP套接字能够同时接收多个数据包。当多个数据包同时到达时，它们会被放入操作系统的网络缓冲区中，recvfrom方法会依次处理这些数据包。因此，服务器能够“同时”处理多个客户端的请求，尽管在代码层面上它是顺序处理的。

对于UDP来说，由于每个数据包都是独立的，并且没有建立持久的连接，所以通常不需要像TCP那样为每个客户端创建单独的线程或进程。

---

---

客户端：

如果程序在发送数据之前没有绑定端口，那么每次发送数据时，系统可能会分配一个新的端口号‌。这是因为UDP协议本身不要求在通信双方之间建立连接，因此每次发送数据时都可以使用不同的端口号。在接收端收到数据之后，系统又会自动释放掉这个端口号‌1。

但是，‌如果程序在发送数据之前绑定了特定的端口，那么只要程序不退出，它就会一直使用这个绑定的端口来发送消息‌。即使多次发送数据，端口号也不会改变，除非程序重新启动或显式地解绑并重新绑定到另一个端口‌。

---

---

UDP通信通常不区分严格的客户端和服务器角色，因为UDP是无连接的协议。不过，为了说明问题，我们可以将两个实体分别称为“发送者”（可以视作客户端）和“接收者”（可以视作服务器），尽管它们在UDP中实际上是对等的。

---

---

以下是 QT代码的实现

---

 客户端(qt)

#include <QCoreApplication>
#include <QUdpSocket>
#include <QByteArray>
#include <QHostAddress>
#include <QTimer>
#include <QDebug>class UdpClient : public QObject {Q_OBJECTpublic:UdpClient(QObject *parent = nullptr): QObject(parent), udpSocket(new QUdpSocket(this)) {// 定时器用于定期发送数据QTimer *timer = new QTimer(this);connect(timer, &QTimer::timeout, this, &UdpClient::sendDatagram);timer->start(1000); // 每秒发送一次// 连接接收信号到槽函数connect(udpSocket, &QUdpSocket::readyRead, this, &UdpClient::readPendingDatagrams);}private slots:void sendDatagram() {QByteArray datagram = "Hello from Client!";udpSocket->writeDatagram(datagram, QHostAddress::LocalHost, 12345);qDebug() << "Sent datagram:" << datagram;}void readPendingDatagrams() {while (udpSocket->hasPendingDatagrams()) {QByteArray datagram;datagram.resize(udpSocket->pendingDatagramSize());QHostAddress sender;quint16 senderPort;udpSocket->readDatagram(datagram.data(), datagram.size(), &sender, &senderPort);qDebug() << "Received datagram from" << sender.toString() << ":" << senderPort;qDebug() << datagram;}}private:QUdpSocket *udpSocket;
};int main(int argc, char *argv[]) {QCoreApplication a(argc, argv);UdpClient client;return a.exec();
}#include "main.moc"

---

服务端(qt) 

#include <QCoreApplication>
#include <QUdpSocket>
#include <QByteArray>
#include <QDebug>class UdpServer : public QObject {Q_OBJECTpublic:UdpServer(QObject *parent = nullptr): QObject(parent), udpSocket(new QUdpSocket(this)) {// 绑定接收端口udpSocket->bind(12345);// 连接接收信号到槽函数connect(udpSocket, &QUdpSocket::readyRead, this, &UdpServer::readPendingDatagrams);}private slots:void readPendingDatagrams() {while (udpSocket->hasPendingDatagrams()) {QByteArray datagram;datagram.resize(udpSocket->pendingDatagramSize());QHostAddress sender;quint16 senderPort;udpSocket->readDatagram(datagram.data(), datagram.size(), &sender, &senderPort);qDebug() << "Received datagram from" << sender.toString() << ":" << senderPort;qDebug() << datagram;// 发送响应给客户端QByteArray response = "Hello from Server!";udpSocket->writeDatagram(response, sender, senderPort);qDebug() << "Sent response:" << response;}}private:QUdpSocket *udpSocket;
};int main(int argc, char *argv[]) {QCoreApplication a(argc, argv);UdpServer server;return a.exec();
}#include "main.moc"

FR:徐海涛(hunkxu)