QT网络编程之UDP通讯

唯·爱

服务端：
头文件：

1. #ifndef UDPSERVER_H
   
2. #define UDPSERVER_H
   
3. 
   
4. #include <QWidget>
   
5. #include <QtNetwork>
   
6. 
   
7. QT_BEGIN_NAMESPACE
   
8. namespace Ui { class UdpServer; }
   
9. QT_END_NAMESPACE
   
10. 
    
11. class UdpServer : public QWidget
    
12. {
    
13.     Q_OBJECT
    
14. 
    
15. public:
    
16.     UdpServer(QWidget *parent = nullptr);
    
17.     ~UdpServer();
    
18. 
    
19. private slots:
    
20.     void on_pushButton_start_clicked();
    
21. 
    
22.     void on_pushButton_send_clicked();
    
23.     void readPendingDatagrams();
    
24. 
    
25. private:
    
26.     Ui::UdpServer *ui;
    
27.     //Udp服务器
    
28.     QUdpSocket *mSocket;
    
29.     //通信的ip和端口，用于获取发送者的 IP 和端口
    
30.     QHostAddress addr;
    
31.     quint16 port;
    
32. };
    
33. #endif // UDPSERVER_H

复制代码

cpp实现：

1. #include "udpserver.h"
   
2. #include "ui_udpserver.h"
   
3. 
   
4. UdpServer::UdpServer(QWidget *parent)
   
5.     : QWidget(parent)
   
6.     , ui(new Ui::UdpServer)
   
7. {
   
8.     ui->setupUi(this);
   
9. }
   
10. 
    
11. UdpServer::~UdpServer()
    
12. {
    
13.     delete ui;
    
14. }
    
15. 
    
16. //启动
    
17. void UdpServer::on_pushButton_start_clicked()
    
18. {
    
19.     //1.创建QUdpSocket对象
    
20.     mSocket = new QUdpSocket(this);
    
21. 
    
22.     //2.连接接收数据信号和槽
    
23.     QObject::connect(mSocket,&QUdpSocket::readyRead,this,&UdpServer::readPendingDatagrams);
    
24. 
    
25. 
    
26.     //3.绑定
    
27.     mSocket->bind(QHostAddress::Any,ui->spinBox->value());
    
28. 
    
29.     //连接回车发送的信号和槽
    
30.     QObject::connect(ui->lineEdit,&QLineEdit::returnPressed,this,&UdpServer::on_pushButton_send_clicked);
    
31. 
    
32.     //禁止端口号和启动按钮
    
33.     ui->spinBox->setEnabled(false);
    
34.     ui->pushButton_start->setEnabled(false);
    
35. }
    
36. 
    
37. void UdpServer::on_pushButton_send_clicked()
    
38. {
    
39.     //获取发送的数据
    
40.     QByteArray arr = ui->lineEdit->text().toUtf8();
    
41. 
    
42.     //发送
    
43.     mSocket->writeDatagram(arr,addr,port);
    
44.     //显示发送的内容
    
45.     ui->textBrowser->insertPlainText("send:"+QString(arr)+"\n");
    
46.     //情况lineEdit
    
47.     ui->lineEdit->clear();
    
48. }
    
49. 
    
50. void UdpServer::readPendingDatagrams()
    
51. {
    
52.     //数据缓冲区
    
53.     QByteArray arr;
    
54.     while(mSocket->hasPendingDatagrams())
    
55.     {
    
56. 
    
57.         //调整缓冲区的大小和收到的数据大小一致
    
58.         arr.resize(mSocket->bytesAvailable());
    
59. 
    
60.         //接收数据
    
61.         mSocket->readDatagram(arr.data(),arr.size(),&addr,&port);
    
62.         //显示
    
63.         ui->textBrowser->insertPlainText(addr.toString()+":"+QString(arr)+"\n");
    
64. 
    
65.         //使能发送按钮和编辑框
    
66.         ui->lineEdit->setEnabled(true);
    
67.         ui->pushButton_send->setEnabled(true);
    
68.     }
    
69. }

复制代码

客户端：

1. #ifndef UDPCILENT_H
   
2. #define UDPCILENT_H
   
3. 
   
4. #include <QWidget>
   
5. #include <QtNetwork>
   
6. 
   
7. QT_BEGIN_NAMESPACE
   
8. namespace Ui { class UdpCilent; }
   
9. QT_END_NAMESPACE
   
10. 
    
11. class UdpCilent : public QWidget
    
12. {
    
13.     Q_OBJECT
    
14. 
    
15. public:
    
16.     UdpCilent(QWidget *parent = nullptr);
    
17.     ~UdpCilent();
    
18. 
    
19. private slots:
    
20.     void on_pushButton_send_clicked();
    
21.     void readPendingDatagrams();
    
22. 
    
23. private:
    
24.     Ui::UdpCilent *ui;
    
25.     //UDP客户端
    
26.     QUdpSocket *mSocket;
    
27. };
    
28. #endif // UDPCILENT_H

复制代码

客户端实现：

1. #include "udpcilent.h"
   
2. #include "ui_udpcilent.h"
   
3. 
   
4. UdpCilent::UdpCilent(QWidget *parent)
   
5.     : QWidget(parent)
   
6.     , ui(new Ui::UdpCilent)
   
7. {
   
8.     ui->setupUi(this);
   
9.     //1.创建QUdpSocket
   
10.     mSocket = new QUdpSocket(this);
    
11.     //2.通信(接收)
    
12.     QObject::connect(mSocket,&QUdpSocket::readyRead,this,&UdpCilent::readPendingDatagrams);
    
13. 
    
14.     //连接回车发送的信号和槽
    
15.     QObject::connect(ui->lineEdit_send,&QLineEdit::returnPressed,this,&UdpCilent::on_pushButton_send_clicked);
    
16. 
    
17. }
    
18. 
    
19. UdpCilent::~UdpCilent()
    
20. {
    
21.     delete ui;
    
22. }
    
23. 
    
24. //发送
    
25. void UdpCilent::on_pushButton_send_clicked()
    
26. {
    
27.     //获取发送的数据
    
28.     QByteArray arr = ui->lineEdit_send->text().toUtf8();
    
29. 
    
30.     //发送
    
31.     //mSocket->writeDatagram(arr,QHostAddress(ui->lineEdit_ip->text()),ui->spinBox->value());
    
32.     mSocket->writeDatagram(arr,QHostAddress::Broadcast,ui->spinBox->value());
    
33.     //显示发送的内容
    
34.     ui->textBrowser->insertPlainText("send:"+QString(arr)+"\n");
    
35.     //情况lineEdit
    
36.     ui->lineEdit_send->clear();
    
37. }
    
38. 
    
39. void UdpCilent::readPendingDatagrams()
    
40. {
    
41.     QHostAddress addr; //用于获取发送者的 IP 和端口
    
42.     quint16 port;
    
43.     //数据缓冲区
    
44.     QByteArray arr;
    
45.     while(mSocket->hasPendingDatagrams())
    
46.     {
    
47.         //调整缓冲区的大小和收到的数据大小一致
    
48.         arr.resize(mSocket->bytesAvailable());
    
49. 
    
50.         //接收数据
    
51.         mSocket->readDatagram(arr.data(),arr.size(),&addr,&port);
    
52.         //显示
    
53.         ui->textBrowser->insertPlainText(addr.toString()+":"+QString(arr)+"\n");
    
54.     }
    
55. }

复制代码