devbox
小蓝xlanll
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Qt网络编程-写一个简单的网络调试助手_如何写一个网络调试助手

作者：小蓝xlanll | 2024-05-17 12:48:05

赞

踩

如何写一个网络调试助手

环境

Windows：Qt5.15.2（VS2022）

Linux：Qt5.12.12（gcc)

源代码

TCP服务器

头文件：

  1. #ifndef TCPSERVERWIDGET_H
  2. #define TCPSERVERWIDGET_H
  3. #include <QWidget>
  4. namespace Ui {
  5. class TCPServerWidget;
  6. }
  7. class QTcpServer;
  8. class QTcpSocket;
  9. class TCPServerWidget : public QWidget {
  10.     Q_OBJECT
  11. public:
  12.     explicit TCPServerWidget(QWidget *parent = nullptr);
  13.     ~TCPServerWidget();
  14.  
  15. private:
  16.     QTcpSocket *socket(int row);
  17. private slots:
  18.     void on_listen_clicked();
  19.     void on_close_clicked();
  20.     void on_send_clicked();
  21.     void on_clear_clicked();
  22.  
  23. private:
  24.     Ui::TCPServerWidget *ui;
  25.     QTcpServer *m_Server;
  26.     QList<QTcpSocket *> m_Clients;
  27. };
  28. #endif // TCPSERVERWIDGET_H

源文件：

  1. #include "tcpserverwidget.h"
  2. #include "common.h"
  3. #include "ui_tcpserverwidget.h"
  4. #include <QHeaderView>
  5. #include <QTcpServer>
  6. #include <QTcpSocket>
  7. TCPServerWidget::TCPServerWidget(QWidget *parent)
  8.     : QWidget(parent), ui(new Ui::TCPServerWidget) {
  9.     ui->setupUi(this);
  10.     ui->localIp->addItem("Any");
  11.     ui->localIp->addItems(getIPAddresses());
  12.     ui->clientTable->setEditTriggers(QAbstractItemView::NoEditTriggers);
  13.     ui->clientTable->setSelectionBehavior(QAbstractItemView::SelectRows);
  14.     ui->clientTable->horizontalHeader()->setSectionResizeMode(
  15.         QHeaderView::Stretch);
  16.     m_Server = new QTcpServer;
  17.     connect(m_Server, &QTcpServer::newConnection, [=]() {
  18.         QTcpSocket *tcpSocket = m_Server->nextPendingConnection();
  19.         QString ip = tcpSocket->peerAddress().toString();
  20.         quint16 port = tcpSocket->peerPort();
  21.         appendLog(ui->textEdit, QString("%1:%2:connect").arg(ip).arg(port));
  22.         bool r = false;
  23.         for (int i = 0; i < ui->clientTable->rowCount(); ++i) {
  24.             QTableWidgetItem *ipitem = ui->clientTable->item(i, 0);
  25.             QTableWidgetItem *portitem = ui->clientTable->item(i, 1);
  26.             if (nullptr != ipitem && nullptr != portitem &&
  27.                 ipitem->text() == ip && portitem->text().toUShort() == port) {
  28.                 r = true;
  29.                 break;
  30.             }
  31.         }
  32.         connect(tcpSocket, &QTcpSocket::disconnected, [=]() {
  33.             appendLog(ui->textEdit,
  34.                       QString("%1:%2 disconnected")
  35.                           .arg(tcpSocket->peerAddress().toString())
  36.                           .arg(tcpSocket->peerPort()));
  37.             for (int i = 0; i < ui->clientTable->rowCount(); ++i) {
  38.                 QTableWidgetItem *ipitem = ui->clientTable->item(i, 0);
  39.                 QTableWidgetItem *portitem = ui->clientTable->item(i, 1);
  40.                 if (nullptr != ipitem && nullptr != portitem &&
  41.                     ipitem->text() == ip &&
  42.                     portitem->text().toUShort() == port) {
  43.                     ui->clientTable->removeRow(i);
  44.                     break;
  45.                 }
  46.             }
  47.             for (QTcpSocket *socket : m_Clients) {
  48.                 if (ip == socket->peerAddress().toString() &&
  49.                     port == socket->peerPort()) {
  50.                     m_Clients.removeOne(socket);
  51.                     socket = nullptr;
  52.                     break;
  53.                 }
  54.             }
  55.         });
  56.         connect(tcpSocket, &QTcpSocket::readyRead, [=]() {
  57.             QByteArray data = (ui->toHex->isChecked())
  58.                 ? tcpSocket->readAll().toHex()
  59.                 : tcpSocket->readAll();
  60.             appendLog(ui->textEdit,
  61.                       QString("%1:%2:%3").arg(ip).arg(port).arg(QString(data)));
  62.         });
  63.         m_Clients.append(tcpSocket);
  64.         int row = ui->clientTable->rowCount();
  65.         ui->clientTable->insertRow(row);
  66.         ui->clientTable->setItem(row, 0, new QTableWidgetItem(ip));
  67.         ui->clientTable->setItem(row, 1,
  68.                                  new QTableWidgetItem(QString::number(port)));
  69.     });
  70. }
  71.  
  72. TCPServerWidget::~TCPServerWidget() {
  73.     delete ui;
  74. }
  75.  
  76. QTcpSocket *TCPServerWidget::socket(int row) {
  77.     QTableWidgetItem *ipitem = ui->clientTable->item(row, 0);
  78.     QTableWidgetItem *portitem = ui->clientTable->item(row, 1);
  79.     if (nullptr != ipitem && nullptr != portitem) {
  80.         QString ip = ipitem->text();
  81.         quint16 port = portitem->text().toUShort();
  82.         for (QTcpSocket *tcpSocket : m_Clients) {
  83.             if (ip == tcpSocket->peerAddress().toString() &&
  84.                 port == tcpSocket->peerPort())
  85.                 return tcpSocket;
  86.         }
  87.     }
  88.     return nullptr;
  89. }
  90.  
  91. void TCPServerWidget::on_listen_clicked() {
  92.  
  93.     if (ui->listen->text() == "listen") {
  94.         if (m_Server->listen((ui->localIp->currentText() == "Any")
  95.                                  ? QHostAddress::Any
  96.                                  : QHostAddress(ui->localIp->currentText()),
  97.                              ui->localPort->value())) {
  98.             ui->listen->setText("listening");
  99.             appendLog(ui->textEdit, "start listening");
  100.         } else {
  101.             appendLog(ui->textEdit,
  102.                       "start listen error:" + m_Server->errorString());
  103.         }
  104.     } else {
  105.         m_Server->close();
  106.         ui->listen->setText("listen");
  107.         for (QTcpSocket *tcpSocket : m_Clients) {
  108.             tcpSocket->close();
  109.             tcpSocket->disconnectFromHost();
  110.         }
  111.         m_Clients.clear();
  112.         appendLog(ui->textEdit, "stop listening");
  113.     }
  114. }
  115.  
  116. void TCPServerWidget::on_close_clicked() {
  117.     int row = ui->clientTable->currentRow();
  118.     QTcpSocket *tcpSocket = socket(row);
  119.     if (nullptr != tcpSocket) {
  120.         tcpSocket->close();
  121.         tcpSocket->disconnectFromHost();
  122.     }
  123. }
  124.  
  125. void TCPServerWidget::on_send_clicked() {
  126.     QByteArray data = (ui->toHex->isChecked())
  127.         ? QByteArray::fromHex(ui->message->text().toUtf8())
  128.         : ui->message->text().toUtf8();
  129.     int row = ui->clientTable->currentRow();
  130.     QTcpSocket *tcpSocket = socket(row);
  131.     if (nullptr != tcpSocket)tcpSocket->write(data, data.size());
  132. }
  133.  
  134. void TCPServerWidget::on_clear_clicked() {
  135.     ui->textEdit->clear();
  136. }

TCP客户端

头文件：

  1. #ifndef TCPCLIENTWIDGET_H
  2. #define TCPCLIENTWIDGET_H
  3.  
  4. #include <QWidget>
  5.  
  6. namespace Ui {
  7. class TCPClientWidget;
  8. }
  9.  
  10. class QTcpSocket;
  11. class TCPClientWidget : public QWidget {
  12.     Q_OBJECT
  13.  
  14. public:
  15.     explicit TCPClientWidget(QWidget *parent = nullptr);
  16.     ~TCPClientWidget();
  17.  
  18. private slots:
  19.     void on_connect_clicked();
  20.  
  21.     void on_send_clicked();
  22.  
  23.     void on_clear_clicked();
  24.  
  25. private:
  26.     Ui::TCPClientWidget *ui;
  27.     QTcpSocket *m_Socket;
  28. };
  29.  
  30. #endif // TCPCLIENTWIDGET_H

源文件：

  1. #include "tcpclientwidget.h"
  2. #include "common.h"
  3. #include "ui_tcpclientwidget.h"
  4. #include <QFutureWatcher>
  5. #include <QTcpSocket>
  6. #include <QtConcurrent/QtConcurrent>
  7.  
  8. TCPClientWidget::TCPClientWidget(QWidget *parent)
  9.     : QWidget(parent), ui(new Ui::TCPClientWidget) {
  10.     ui->setupUi(this);
  11.     ui->localIp->addItems(getIPAddresses());
  12.     m_Socket = new QTcpSocket;
  13.     connect(m_Socket, &QTcpSocket::disconnected, [=]() {
  14.         ui->connect->setText("connect");
  15.         appendLog(ui->textEdit, "disconnect");
  16.     });
  17.     connect(m_Socket, &QTcpSocket::readyRead, [=]() {
  18.         QByteArray data = (ui->toHex->isChecked()) ? m_Socket->readAll().toHex()
  19.                                                    : m_Socket->readAll();
  20.         appendLog(ui->textEdit, QString(data));
  21.     });
  22. }
  23.  
  24. TCPClientWidget::~TCPClientWidget() {
  25.     delete ui;
  26. }
  27.  
  28. void TCPClientWidget::on_connect_clicked() {
  29.     if ("connect" == ui->connect->text()) {
  30.         if (ui->bind->isChecked()) {
  31.             if (!m_Socket->bind(QHostAddress(ui->localIp->currentText()),
  32.                                 ui->localPort->value())) {
  33.                 appendLog(ui->textEdit,
  34.                           "bind error:" + m_Socket->errorString());
  35.                 return;
  36.             }
  37.         }
  38.         ui->connect->setEnabled(false);
  39.         m_Socket->connectToHost(QHostAddress(ui->serverIp->text()),
  40.                                 ui->serverPort->value());
  41.         if (m_Socket->waitForConnected()) {
  42.             ui->connect->setText("disconnect");
  43.  
  44.             appendLog(ui->textEdit, "connect");
  45.         } else
  46.             appendLog(ui->textEdit, "connect error:" + m_Socket->errorString());
  47.         ui->connect->setEnabled(true);
  48.     } else {
  49.         m_Socket->close();
  50.         m_Socket->disconnectFromHost();
  51.         ui->connect->setText("connect");
  52.         appendLog(ui->textEdit, "disconnect");
  53.     }
  54. }
  55.  
  56. void TCPClientWidget::on_send_clicked() {
  57.     QByteArray data = (ui->toHex->isChecked())
  58.         ? QByteArray::fromHex(ui->message->text().toUtf8())
  59.         : ui->message->text().toUtf8();
  60.     if (m_Socket->isOpen()) m_Socket->write(data, data.size());
  61. }
  62.  
  63. void TCPClientWidget::on_clear_clicked() {
  64.     ui->textEdit->clear();
  65. }

UDP

头文件：

  1. #ifndef UDPWIDGET_H
  2. #define UDPWIDGET_H
  3.  
  4. #include <QWidget>
  5.  
  6. namespace Ui {
  7. class UDPWidget;
  8. }
  9.  
  10. class QUdpSocket;
  11. class UDPWidget : public QWidget {
  12.   Q_OBJECT
  13.  
  14.  public:
  15.   explicit UDPWidget(QWidget *parent = nullptr);
  16.   ~UDPWidget();
  17.  
  18.  private slots:
  19.   void on_bind_clicked();
  20.  
  21.   void on_send_2_clicked();
  22.  
  23.   void on_clear_2_clicked();
  24.  
  25.  private:
  26.   Ui::UDPWidget *ui;
  27.   QUdpSocket *m_Socket;
  28. };
  29.  
  30. #endif  // UDPWIDGET_H

源文件：

  1. #include "udpwidget.h"
  2. #include <QUdpSocket>
  3. #include "common.h"
  4. #include "ui_udpwidget.h"
  5.  
  6. UDPWidget::UDPWidget(QWidget *parent) : QWidget(parent), ui(new Ui::UDPWidget) {
  7.   ui->setupUi(this);
  8.   ui->localIp_2->addItems(getIPAddresses());
  9.   m_Socket = new QUdpSocket;
  10.   connect(m_Socket, &QUdpSocket::readyRead, [=]() {
  11.     while (m_Socket->hasPendingDatagrams()) {
  12.       QByteArray data;
  13.       QHostAddress host;
  14.       quint16 port;
  15.       data.resize(m_Socket->pendingDatagramSize());
  16.       m_Socket->readDatagram(data.data(), data.size(), &host, &port);
  17.       data = (ui->toHex_2->isChecked()) ? data.toHex() : data;
  18.       appendLog(ui->textEdit, QString("%1:%2:%3")
  19.                                   .arg(host.toString())
  20.                                   .arg(port)
  21.                                   .arg(QString(data)));
  22.     }
  23.   });
  24. }
  25.  
  26. UDPWidget::~UDPWidget() { delete ui; }
  27.  
  28. void UDPWidget::on_bind_clicked() {
  29.   if (ui->bind->text() == "bind") {
  30.     if (m_Socket->bind(QHostAddress(ui->localIp_2->currentText()),
  31.                        ui->localPort_2->value()))
  32.       ui->bind->setText("unbind");
  33.     else
  34.       appendLog(ui->textEdit, "bind error:" + m_Socket->errorString());
  35.   } else {
  36.     m_Socket->abort();
  37.     ui->bind->setText("bind");
  38.   }
  39. }
  40.  
  41. void UDPWidget::on_send_2_clicked() {
  42.   QByteArray data = (ui->toHex_2->isChecked())
  43.                         ? QByteArray::fromHex(ui->message_2->text().toUtf8())
  44.                         : ui->message_2->text().toUtf8();
  45.   m_Socket->writeDatagram(data, QHostAddress(ui->serverIp->text()),
  46.                           ui->serverPort->value());
  47. }
  48.  
  49. void UDPWidget::on_clear_2_clicked() { ui->textEdit->clear(); }

运行效果

TCP服务器与多个客户端通信：

UDP之间通信：

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小蓝xlanll/article/detail/583678
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号