基于ICMP(Ping)的多线程网络通道监视程序(QT)开辟

汕尾海湾  金牌会员 | 2024-8-13 07:10:16 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 877|帖子 877|积分 2631

基于ICMP(Ping)的多线程网络通道监视程序(QT)开辟
1、 ICMP原理简介

可参考 ICMP(Ping)功能原理及其C++实现简介 。
2、 网络通道监视程序开辟

设计原理： 通过PING 功能实现服务器、交换机、网闸等设备的网络检测，判定网络的否可达和TTL盘算 。
具备功能：


  • 通过多线程，实现多个网络通道同时检测；
  • 支持动态加包。
  • 支持设置网络延长阈值，超过阈值时提示用户。
①、 界面设计

程序采用QT开辟，UI界面如下图所示：

中心区域为 QTableWidget 控件。
②、 PING接口封装

IPing.h :
  1. #pragma once
  4. class IPing
  5. {
  6. public:
  7.         IPing();
  8.         ~IPing();
  10.         void SetPackSize(int isize);
  12.         void PingHost(const char* ip, int& timems, int& ttl);
  14. private:
  15.         int sock;
  16.        
  17.         unsigned int m_iTxID;
  18.         unsigned int m_iTxSequeNum;
  20.         unsigned int m_iSendPackageSize;
  21. };
  24. void InitWinSockEnv();
  26. void CleanupWinSockEnv();
复制代码
IPing.cxx:
  1. #include "IPing.h"
  3. #include <iostream>
  4. #include <string>
  5. #include <chrono>
  6. #include <thread>
  7. #include <iomanip>
  8. #include <winsock2.h>
  9. #pragma comment(lib,"ws2_32.lib")
  12. #define ICMP_PING_DATA_SIZE           40000     //填充数据长度;
  13. #define ICMP_TYPE_PING_REQUEST        8
  14. #define ICMP_TYPE_PING_REPLY          0
  16. #define ICMP_PING_TIMES               1         //Ping次数
  17. #define MAX_BUFFER_SIZE               40100
  20. typedef unsigned char        uint8;
  21. typedef unsigned short                 uint16;
  22. typedef unsigned int         uint32;
  24. //ICMP校验和计算
  25. uint16 MakeChecksum(char* icmp_packet, int size)
  26. {
  27.         uint16 * sum = (uint16*)icmp_packet;
  28.         uint32 checksum = 0;
  29.         while (size > 1)
  30.         {
  31.                 checksum += ntohs(*sum++);
  32.                 size -= sizeof(uint16);
  33.         }
  35.         if (size)
  36.         {
  37.                 *sum = *((uint8*)sum);
  38.                 checksum += ((*sum << 8) & 0xFF00);
  39.         }
  41.         checksum = (checksum >> 16) + (checksum & 0xffff);
  42.         checksum += checksum >> 16;
  44.         return (uint16)(~checksum);
  45. }
  47. IPing::IPing()
  48. {
  49.         sock = 0;
  50.         m_iTxID = 0;
  51.         m_iTxSequeNum = 0;
  53.         m_iSendPackageSize = 32;
  55.         SOCKET s = socket(AF_INET, SOCK_RAW, IPPROTO_ICMP);
  56.         sock = s;
  57. }
  59. IPing::~IPing()
  60. {
  61.         if (sock > 0)
  62.         {
  63.                 closesocket(sock);
  64.         }
  65. }
  67. void IPing::SetPackSize(int isize)
  68. {
  69.         m_iSendPackageSize = isize;
  70. }
  72. void IPing::PingHost(const char* ip, int& timems, int& ttl)
  73. {
  74.         std::string strHost = std::string(ip);
  75.     if (strHost.length()< 5)
  76.     {
  77.                 timems = -1;
  78.                 ttl = -1;
  79.                 return;
  80.     }
  82.         struct sockaddr_in pingaddr;
  83.         memset((char *)&pingaddr, 0, sizeof(pingaddr));
  84.         pingaddr.sin_family = AF_INET;
  85.         pingaddr.sin_port = 0;
  86.         pingaddr.sin_addr.s_addr = inet_addr(strHost.c_str());
  88.         for (int ii = 0; ii < ICMP_PING_TIMES; ++ii)
  89.         {
  90.                 //组帧
  91.                 uint8 ucCmdBuf[MAX_BUFFER_SIZE] = { 0 };
  92.                 uint8* pCurr = ucCmdBuf;
  94.                 *pCurr++ = ICMP_TYPE_PING_REQUEST;                 //Type
  95.                 *pCurr++ = 0x00;                                                 //Code
  96.                 *pCurr++ = 0x00;                                                 //Checksum
  97.                 *pCurr++ = 0x00;                                                 //Checksum
  98.                 *pCurr++ = HIBYTE(m_iTxID);                                 //Identifier
  99.                 *pCurr++ = LOBYTE(m_iTxID);                                 //Identifier
  100.                 *pCurr++ = HIBYTE(m_iTxSequeNum);        //Sequence Number
  101.                 *pCurr++ = LOBYTE(m_iTxSequeNum);             //Sequence Number
  103.                 auto send_clock = std::chrono::system_clock::now();
  104.                 DWORD dwSendTime = std::chrono::duration_cast<std::chrono::milliseconds>(send_clock.time_since_epoch()).count();;
  105.                 *pCurr++ = HIBYTE(HIWORD(dwSendTime));   //Current TickCount
  106.                 *pCurr++ = LOBYTE(HIWORD(dwSendTime));   //Current TickCount
  107.                 *pCurr++ = HIBYTE(LOWORD(dwSendTime));   //Current TickCount
  108.                 *pCurr++ = LOBYTE(LOWORD(dwSendTime));   //Current TickCount
  110.                 //Data
  111.                 for (int k = 0; k < m_iSendPackageSize - 4; ++k)
  112.                 {
  113.                         *pCurr++ = 0x61 + (k % 20);
  114.                 }
  116.                 uint16 usCheckSum = MakeChecksum((char*)ucCmdBuf, pCurr - ucCmdBuf);
  117.                 ucCmdBuf[2] = HIBYTE(usCheckSum);
  118.                 ucCmdBuf[3] = LOBYTE(usCheckSum);
  121.                 int txlen = sendto(sock, (char *)&ucCmdBuf, pCurr - ucCmdBuf, 0, (struct sockaddr *) &pingaddr, sizeof(struct sockaddr_in));
  123.                 uint8 ucRxBuf[MAX_BUFFER_SIZE] = { 0 };
  125.                 struct sockaddr_in rxaddr;
  126.                 memset((char *)&rxaddr, 0, sizeof(rxaddr));
  127.                 rxaddr.sin_family = AF_INET;
  128.                 rxaddr.sin_port = 0;
  129.                 rxaddr.sin_addr.s_addr = inet_addr(strHost.c_str());
  130.                 int iSize = sizeof(struct sockaddr_in);
  133.                 do
  134.                 {
  135.                         int rxlen = recvfrom(sock, (char *)&ucRxBuf, sizeof(ucRxBuf), 0, (struct sockaddr *)&rxaddr, &iSize);   
  136.                         if (rxaddr.sin_addr.S_un.S_addr == pingaddr.sin_addr.S_un.S_addr)
  137.                         {       
  138.                                 if (rxlen >= 0)
  139.                                 {
  140.                                         //IP帧获取TTL
  141.                                         ttl = ucRxBuf[8];
  143.                                         //跳过IP Header 20个字节
  144.                                         uint8* pIcmpFrame = ucRxBuf + 20;
  146.                                         //Type和Code
  147.                                         uint8 ucType = pIcmpFrame[0];
  148.                                         uint8 ucCode = pIcmpFrame[1];
  149.                                         if (ucCode != 0x00 || ucType != 0x00)
  150.                                                 goto GO_ON;
  152.                                         //比对ID和序号
  153.                                         uint16 iRxID = pIcmpFrame[4] * 256 + pIcmpFrame[5];
  154.                                         uint16 iRxSequeNum = pIcmpFrame[6] * 256 + pIcmpFrame[7];
  155.                                         if (iRxID == m_iTxID && iRxSequeNum == m_iTxSequeNum)
  156.                                         {
  157.                                                 DWORD dwTimeTransmit = pIcmpFrame[8] * 256 * 256 * 256 + pIcmpFrame[9] * 256 * 256 + pIcmpFrame[10] * 256 + pIcmpFrame[11];
  159.                                                 auto now = std::chrono::system_clock::now();
  160.                                                 DWORD dwNowTime = std::chrono::duration_cast<std::chrono::milliseconds>(now.time_since_epoch()).count();
  162.                                                 timems = dwNowTime - dwTimeTransmit;
  163.                                         }
  164.                                         else
  165.                                                 goto GO_ON;
  167.                                 }
  168.                                 else
  169.                                 {
  170.                                         timems = -1;  //异常
  171.                                 }
  173.                                 m_iTxID++;
  174.                                 m_iTxSequeNum++;
  176.                                 break;
  177.                         }
  179.         GO_ON:
  180.                         auto current_clock = std::chrono::system_clock::now();  
  181.                         DWORD dwCurrentTime = std::chrono::duration_cast<std::chrono::milliseconds>(current_clock.time_since_epoch()).count();;
  182.                         if (dwCurrentTime - dwSendTime > 2000)
  183.                         {
  184.                                 timems = -2;  //超时
  185.                                 return;
  186.                         }
  187.                 }
  188.                 while (true);
  189.         }
  191. }
  194. void InitWinSockEnv()
  195. {
  196.         WSADATA wsaData;
  197.         WSAStartup(MAKEWORD(2, 2), &wsaData);
  198. }
  201. void CleanupWinSockEnv()
  202. {
  203.         WSACleanup();
  204. }
复制代码
③、 PING多线程接口封装

多线程采用 std::thread 实现，线程函数封装如下：
  1. /************************************************************************/
  2. /*                                                                      */
  3. /*  @WrapExecPing函数功能：  线程函数，调用PING接口                       */
  4. /*                                                                      */
  5. /*  @aipaddr, bipaddr参数： 监视的节点IPA和IPB地址                        */
  6. /*  @atimems, btimems参数： IPA地址和IPB地址PING响应时间                  */
  7. /*  @attl, bttl参数：       IPA地址和IPB地址PING响应TTL值                 */
  8. /*  @stopf 参数：           停止线程任务标志位                            */
  9. /*  @package_size 参数：    PING包大小                                   */
  10. /*  @asnd, bsnd参数：       IPA地址和IPB地址PING次数                      */
  11. /*  @f 参数：               线程结束标志位                                */
  12. /*                                                                      */
  13. /************************************************************************/
  14. void WrapExecPing(std::string aipaddr, std::string bipaddr, int& atimems, int& attl, int& btimems, int& bttl, bool& stopf,int package_size,int& asnd,int&bsnd, bool& f)
  15. {
  16.         IPing aping;
  17.         IPing bping;
  19.     //设置PING包大小
  20.         aping.SetPackSize(package_size);
  21.         bping.SetPackSize(package_size);
  23.         f = true;
  25.         while (!stopf)
  26.         {
  27.                 auto start = std::chrono::system_clock::now();
  28.                 DWORD dwStartTime = std::chrono::duration_cast<std::chrono::milliseconds>(start.time_since_epoch()).count();
  30.                 if (aipaddr.length() > 5)
  31.                 {
  32.             //执行IP地址A的PING
  33.                         aping.PingHost(aipaddr.c_str(), atimems, attl);
  34.                         asnd++;
  35.                 }
  36.                 else
  37.                         std::this_thread::sleep_for(std::chrono::milliseconds(500));
  38.                        
  39.                 if (bipaddr.length() > 5)
  40.                 {
  41.             //执行IP地址B的PING
  42.                         bping.PingHost(bipaddr.c_str(), btimems, bttl);
  43.                         bsnd++;
  44.                 }
  45.                 else
  46.                         std::this_thread::sleep_for(std::chrono::milliseconds(500));
  48.                 auto now = std::chrono::system_clock::now();
  49.                 DWORD dwNowTime = std::chrono::duration_cast<std::chrono::milliseconds>(now.time_since_epoch()).count();
  50.                 if (dwNowTime - dwStartTime < 500)
  51.                 {
  52.                         std::this_thread::sleep_for(std::chrono::milliseconds(800));
  53.                 }
  54.         }
  56.         f = false;
  57. }
复制代码
④、 QT主程序开辟

【1】、 界面初始化

  1. MainWindow::MainWindow(QWidget *parent) :
  2.     QMainWindow(parent),
  3.     ui(new Ui::MainWindow)
  4. {
  5.     ui->setupUi(this);
  7.         //初始化Windows套接字环境
  8.         InitWinSock();
  10.         glb_bStopF = false;
  11.        
  12.         //初始化表格控件;
  13.         initTableWidget();
  15.         //初始化PING包大小复选框;
  16.         initComboBox();
  18.         //初始化延迟超限报警阈值;
  19.         initLineEdit();
  20.        
  21.         ui->pushButtonStop->setEnabled(false);
  23.         //设置控件样式表QSS
  24.         setStyleSheet("QMainWindow{ background-color: #365a7a; } QLabel{ color:#E0E0E0; font-weight:bold; }");
  25.        
  26.         ui->pushButtonStart->setStyleSheet("QPushButton{ background-color: transparent;color: #f0f0f0; font-weight:bold;} QPushButton:hover{ background-color:white; color:gray; font-weight:thin; border-radius:4px;} QPushButton:disabled{ color:gray;}");
  27.         ui->pushButtonStop->setStyleSheet("QPushButton{ background-color: transparent;color: #f0f0f0; font-weight:bold;} QPushButton:hover{ background-color:white; color:gray; font-weight:thin; border-radius:4px;} QPushButton:disabled{ color:gray;}");
  28.         ui->lineEdit->setStyleSheet("QLineEdit{background-color:#D9D9D9; color:gray;}");
  29.         ui->comboBox->setStyleSheet("QComboBox{color:gray;}");
  31.         //信号槽定义;
  32.         connect(ui->pushButtonStart, SIGNAL(clicked()), this, SLOT(onButtonStart()));
  33.         connect(ui->pushButtonStop, SIGNAL(clicked()), this, SLOT(onButtonStop()));
  34. }
复制代码
表格控件初始化
  1. void MainWindow::initTableWidget()
  2. {
  3.         //加载nodecfg.ini文件
  5.         extern bool LoadNodeConfig(CHostInfoArray& arry);
  6.         if (false == LoadNodeConfig(arry) || arry.size() <= 0)
  7.         {
  8.                 QMessageBox::warning(this, QString::fromLocal8Bit("提示"), QString::fromLocal8Bit("《nodecfg.ini》打开失败!"));
  9.                 return;
  10.         }
  12.         //初始化表格列
  13.         ui->tableWidget->setEditTriggers(QAbstractItemView::NoEditTriggers);
  14.         ui->tableWidget->setColumnCount(MAX_COLUMN_NUM);
  16.         QStringList headerList;
  17.         headerList << QString::fromLocal8Bit("网络节点名称");
  18.         headerList << QString::fromLocal8Bit("A网IP地址");
  19.         headerList << QString::fromLocal8Bit("B网IP地址");
  20.         headerList << QString::fromLocal8Bit("A网延时");
  21.         headerList << QString::fromLocal8Bit("A网TTL");
  22.         headerList << QString::fromLocal8Bit("B网延时");
  23.         headerList << QString::fromLocal8Bit("B网TTL");
  24.         headerList << QString::fromLocal8Bit("PING次数");
  25.         ui->tableWidget->setHorizontalHeaderLabels(headerList);
  26.         ui->tableWidget->horizontalHeader()->setStyleSheet("QHeaderView::section {background-color: #365a7a; color: rgb(220,220,220); font-weight:bold;}");
  27.         ui->tableWidget->verticalHeader()->setStyleSheet("QHeaderView::section {background-color: #365a7a; color: rgb(220,220,220); font-weight:bold;}");
  28.         ui->tableWidget->setColumnWidth(0, 120);
  29.         ui->tableWidget->setColumnWidth(1, 140);
  30.         ui->tableWidget->setColumnWidth(2, 140);
  31.         ui->tableWidget->setColumnWidth(7, 160);
  34.         //行
  35.         int iSize = arry.size();
  36.         if (iSize > 0)
  37.         {
  38.                 ui->tableWidget->setRowCount(iSize);
  40.                 for (int ii = 0; ii < iSize;++ii)
  41.                 {
  42.                         ui->tableWidget->setItem(ii, 0, new QTableWidgetItem());    ui->tableWidget->item(ii, 0)->setText(QString::fromStdString(arry[ii].strHostName)); ui->tableWidget->item(ii, 0)->setData(Qt::DisplayRole, QString::fromStdString(arry[ii].strHostName));
  43.                         ui->tableWidget->setItem(ii, 1, new QTableWidgetItem());    ui->tableWidget->item(ii, 1)->setText(QString::fromStdString(arry[ii].strIPA));
  44.                         ui->tableWidget->setItem(ii, 2, new QTableWidgetItem());    ui->tableWidget->item(ii, 2)->setText(QString::fromStdString(arry[ii].strIPB));
  45.                         ui->tableWidget->setItem(ii, 3, new QTableWidgetItem());
  46.                         ui->tableWidget->setItem(ii, 4, new QTableWidgetItem());
  47.                         ui->tableWidget->setItem(ii, 5, new QTableWidgetItem());
  48.                         ui->tableWidget->setItem(ii, 6, new QTableWidgetItem());
  49.                         ui->tableWidget->setItem(ii, 7, new QTableWidgetItem());
  50.                 }
  51.         }
  52. }
复制代码
复选框控件初始化
  1. void MainWindow::initComboBox()
  2. {
  3.         ui->comboBox->addItem("32", 32);
  4.         ui->comboBox->addItem("128", 128);
  5.         ui->comboBox->addItem("256", 256);
  6.         ui->comboBox->addItem("512",512);
  7.         ui->comboBox->addItem("1024", 1024);
  8.         ui->comboBox->addItem("2048", 2048);
  9.         ui->comboBox->addItem("2500", 2500);
  10.         ui->comboBox->addItem("3000", 3000);
  11.         ui->comboBox->addItem("4096", 4096);
  12.         ui->comboBox->addItem("5000", 5000);
  13.         ui->comboBox->addItem("8000", 8000);
  14.         ui->comboBox->addItem("10000", 10000);
  15.         ui->comboBox->addItem("13000", 13000);
  16.         ui->comboBox->addItem("15000", 15000);
  17.         ui->comboBox->addItem("18000", 18000);
  18.         ui->comboBox->addItem("24000", 24000);
  19.         ui->comboBox->addItem("28000", 28000);
  20.         ui->comboBox->addItem("32000", 32000);
  21.         ui->comboBox->addItem("36000", 36000);
  23.         ui->comboBox->setCurrentIndex(0);
  24. }
复制代码
编辑框控件初始化
  1. void MainWindow::initLineEdit()
  2. {
  3.         ui->lineEdit->setText("200");
  4. }
复制代码
【2】、 启动多线程

使用 std::thread线程，
  1. void MainWindow::StartPingTask()
  2. {
  3.         int iSize = arry.size();
  4.         if (iSize <= 0)
  5.         {
  6.                 onButtonStop();
  7.                 return;
  8.         }
  10.         //报警阈值
  11.         int alarmval = ui->lineEdit->text().toInt();
  13.         //Ping包大小;
  14.         int index = ui->comboBox->currentIndex();
  15.         int package_size = ui->comboBox->itemData(index).toInt();
  17.         SPINGINFO* pPingInfo = new SPINGINFO[iSize];
  19.         for (int i = 0; i < iSize; i++)
  20.         {
  21.                 pPingInfo[i].host = arry[i];
  22.                 pPingInfo[i].attl = -1;
  23.                 pPingInfo[i].bttl = -1;
  24.                 pPingInfo[i].atimems = -1;
  25.                 pPingInfo[i].btimems = -1;
  26.                 pPingInfo[i].asnd = 0;
  27.                 pPingInfo[i].bsnd = 0;
  29.                 std::thread T1(WrapExecPing, pPingInfo[i].host.strIPA, pPingInfo[i].host.strIPB, std::ref(pPingInfo[i].atimems), std::ref(pPingInfo[i].attl), std::ref(pPingInfo[i].btimems), std::ref(pPingInfo[i].bttl), std::ref(glb_bStopF), package_size, std::ref(pPingInfo[i].asnd), std::ref(pPingInfo[i].bsnd), std::ref(pPingInfo[i].runf));
  32.                 pPingInfo[i].t = std::move(T1);
  34.                 std::this_thread::sleep_for(std::chrono::milliseconds(10));
  35.         }
  36. }
复制代码
【3】、 完整代码

  1. #include "mainwindow.h"#include "ui_mainwindow.h"#include "QMessageBox"#include "public.h"#include "IPing.h"#include <thread>#include <chrono>#define  MAX_COLUMN_NUM     8CHostInfoArray arry;bool glb_bStopF = false;MainWindow::MainWindow(QWidget *parent) :
  2.     QMainWindow(parent),
  3.     ui(new Ui::MainWindow)
  4. {
  5.     ui->setupUi(this);
  7.         //初始化Windows套接字环境
  8.         InitWinSock();
  10.         glb_bStopF = false;
  11.        
  12.         //初始化表格控件;
  13.         initTableWidget();
  15.         //初始化PING包大小复选框;
  16.         initComboBox();
  18.         //初始化延迟超限报警阈值;
  19.         initLineEdit();
  20.        
  21.         ui->pushButtonStop->setEnabled(false);
  23.         //设置控件样式表QSS
  24.         setStyleSheet("QMainWindow{ background-color: #365a7a; } QLabel{ color:#E0E0E0; font-weight:bold; }");
  25.        
  26.         ui->pushButtonStart->setStyleSheet("QPushButton{ background-color: transparent;color: #f0f0f0; font-weight:bold;} QPushButton:hover{ background-color:white; color:gray; font-weight:thin; border-radius:4px;} QPushButton:disabled{ color:gray;}");
  27.         ui->pushButtonStop->setStyleSheet("QPushButton{ background-color: transparent;color: #f0f0f0; font-weight:bold;} QPushButton:hover{ background-color:white; color:gray; font-weight:thin; border-radius:4px;} QPushButton:disabled{ color:gray;}");
  28.         ui->lineEdit->setStyleSheet("QLineEdit{background-color:#D9D9D9; color:gray;}");
  29.         ui->comboBox->setStyleSheet("QComboBox{color:gray;}");
  31.         //信号槽定义;
  32.         connect(ui->pushButtonStart, SIGNAL(clicked()), this, SLOT(onButtonStart()));
  33.         connect(ui->pushButtonStop, SIGNAL(clicked()), this, SLOT(onButtonStop()));
  34. }
  35. MainWindow::~MainWindow(){        CleanWinSock();    delete ui;}void MainWindow::InitWinSock(){    //初始化Windows套接字环境        InitWinSockEnv();}void MainWindow::CleanWinSock(){        CleanupWinSockEnv();}void MainWindow::initTableWidget(){        //加载网络节点设置文件nodecfg.ini        extern bool LoadNodeConfig(CHostInfoArray& arry);        if (false == LoadNodeConfig(arry) || arry.size() <= 0)        {                QMessageBox::warning(this, QString::fromLocal8Bit("提示"), QString::fromLocal8Bit("《nodecfg.ini》打开失败!"));                return;        }        //初始化表格列        ui->tableWidget->setEditTriggers(QAbstractItemView::NoEditTriggers);        ui->tableWidget->setColumnCount(MAX_COLUMN_NUM);        QStringList headerList;        headerList << QString::fromLocal8Bit("网络节点名称");        headerList << QString::fromLocal8Bit("A网IP地址");        headerList << QString::fromLocal8Bit("B网IP地址");        headerList << QString::fromLocal8Bit("A网延时");        headerList << QString::fromLocal8Bit("A网TTL");        headerList << QString::fromLocal8Bit("B网延时");        headerList << QString::fromLocal8Bit("B网TTL");        headerList << QString::fromLocal8Bit("PING次数");        ui->tableWidget->setHorizontalHeaderLabels(headerList);        ui->tableWidget->horizontalHeader()->setStyleSheet("QHeaderView::section {background-color: #365a7a; color: rgb(220,220,220); font-weight:bold;}");        ui->tableWidget->verticalHeader()->setStyleSheet("QHeaderView::section {background-color: #365a7a; color: rgb(220,220,220); font-weight:bold;}");        ui->tableWidget->setColumnWidth(0, 120);        ui->tableWidget->setColumnWidth(1, 140);        ui->tableWidget->setColumnWidth(2, 140);        ui->tableWidget->setColumnWidth(7, 160);        //行，插入记录        int iSize = arry.size();        if (iSize > 0)        {                ui->tableWidget->setRowCount(iSize);                for (int ii = 0; ii < iSize;++ii)                {                        ui->tableWidget->setItem(ii, 0, new QTableWidgetItem());    ui->tableWidget->item(ii, 0)->setText(QString::fromStdString(arry[ii].strHostName)); ui->tableWidget->item(ii, 0)->setData(Qt::DisplayRole, QString::fromStdString(arry[ii].strHostName));                        ui->tableWidget->setItem(ii, 1, new QTableWidgetItem());    ui->tableWidget->item(ii, 1)->setText(QString::fromStdString(arry[ii].strIPA));                        ui->tableWidget->setItem(ii, 2, new QTableWidgetItem());    ui->tableWidget->item(ii, 2)->setText(QString::fromStdString(arry[ii].strIPB));                        ui->tableWidget->setItem(ii, 3, new QTableWidgetItem());                        ui->tableWidget->setItem(ii, 4, new QTableWidgetItem());                        ui->tableWidget->setItem(ii, 5, new QTableWidgetItem());                        ui->tableWidget->setItem(ii, 6, new QTableWidgetItem());                        ui->tableWidget->setItem(ii, 7, new QTableWidgetItem());                }        }        }void MainWindow::initComboBox(){    //PING包大小选项        ui->comboBox->addItem("32", 32);        ui->comboBox->addItem("128", 128);        ui->comboBox->addItem("256", 256);        ui->comboBox->addItem("512",512);        ui->comboBox->addItem("1024", 1024);        ui->comboBox->addItem("2048", 2048);        ui->comboBox->addItem("2500", 2500);        ui->comboBox->addItem("3000", 3000);        ui->comboBox->addItem("4096", 4096);        ui->comboBox->addItem("5000", 5000);        ui->comboBox->addItem("8000", 8000);        ui->comboBox->addItem("10000", 10000);        ui->comboBox->addItem("13000", 13000);        ui->comboBox->addItem("15000", 15000);        ui->comboBox->addItem("18000", 18000);        ui->comboBox->addItem("24000", 24000);        ui->comboBox->addItem("28000", 28000);        ui->comboBox->addItem("32000", 32000);        ui->comboBox->addItem("36000", 36000);        ui->comboBox->setCurrentIndex(0);}void MainWindow::initLineEdit(){    //报警阈值，单元毫秒        ui->lineEdit->setText("200");}//开始检测void MainWindow::onButtonStart(){        ui->comboBox->setEnabled(false);        ui->lineEdit->setEnabled(false);        ui->pushButtonStart->setEnabled(false);        ui->pushButtonStop->setEnabled(true);        glb_bStopF = false;        ClearTableWidget();        StartPingTask();}void MainWindow::onButtonStop(){        glb_bStopF = true;}/************************************************************************//*                                                                      *//*  @WrapExecPing函数功能： 线程函数，调用PING接口                        *//*                                                                      *//*  @aipaddr, bipaddr参数： 监视的节点IPA和IPB地址                        *//*  @atimems, btimems参数： IPA地址和IPB地址PING响应时间                  *//*  @attl, bttl参数：       IPA地址和IPB地址PING响应TTL值                 *//*  @stopf 参数：           停止线程任务标志位                            *//*  @package_size 参数：    PING包大小                                   *//*  @asnd, bsnd参数：       IPA地址和IPB地址PING次数                      *//*  @f 参数：               线程结束标志位                                *//*                                                                      *//************************************************************************/void WrapExecPing(std::string aipaddr, std::string bipaddr, int& atimems, int& attl, int& btimems, int& bttl, bool& stopf,int package_size,int& asnd,int&bsnd, bool& f){        IPing aping;        IPing bping;        aping.SetPackSize(package_size);        bping.SetPackSize(package_size);        f = true;        while (!stopf)        {                auto start = std::chrono::system_clock::now();                DWORD dwStartTime = std::chrono::duration_cast<std::chrono::milliseconds>(start.time_since_epoch()).count();                if (aipaddr.length() > 5)                {                        aping.PingHost(aipaddr.c_str(), atimems, attl);                        asnd++;                }                else                         std::this_thread::sleep_for(std::chrono::milliseconds(500));                                        if (bipaddr.length() > 5)                {                        bping.PingHost(bipaddr.c_str(), btimems, bttl);                        bsnd++;                }                else                        std::this_thread::sleep_for(std::chrono::milliseconds(500));                auto now = std::chrono::system_clock::now();                DWORD dwNowTime = std::chrono::duration_cast<std::chrono::milliseconds>(now.time_since_epoch()).count();                if (dwNowTime - dwStartTime < 500)                {                        std::this_thread::sleep_for(std::chrono::milliseconds(800));                }        }        f = false;}void MainWindow::ClearTableWidget(){        int iRowCount = ui->tableWidget->rowCount();        for (int k = 0; k < iRowCount; ++k)        {                for (int i = 3; i < MAX_COLUMN_NUM;++i)                {                        ui->tableWidget->item(k, i)->setText(QString(""));                }        }}void MainWindow::StartPingTask(){        int iSize = arry.size();        if (iSize <= 0)        {                onButtonStop();                return;        }        //报警阈值        int alarmval = ui->lineEdit->text().toInt();        //Ping包大小;        int index = ui->comboBox->currentIndex();        int package_size = ui->comboBox->itemData(index).toInt();        SPINGINFO* pPingInfo = new SPINGINFO[iSize];        for (int i = 0; i < iSize; i++)        {                pPingInfo[i].host = arry[i];                pPingInfo[i].attl = -1;                pPingInfo[i].bttl = -1;                pPingInfo[i].atimems = -1;                pPingInfo[i].btimems = -1;                pPingInfo[i].asnd = 0;                pPingInfo[i].bsnd = 0;        //启动线程                std::thread T1(WrapExecPing, pPingInfo[i].host.strIPA, pPingInfo[i].host.strIPB, std::ref(pPingInfo[i].atimems), std::ref(pPingInfo[i].attl), std::ref(pPingInfo[i].btimems), std::ref(pPingInfo[i].bttl), std::ref(glb_bStopF), package_size, std::ref(pPingInfo[i].asnd), std::ref(pPingInfo[i].bsnd), std::ref(pPingInfo[i].runf));                pPingInfo[i].t = std::move(T1);                std::this_thread::sleep_for(std::chrono::milliseconds(10));        }    //界面更新        do         {                if (glb_bStopF) break;                int iRowCount = ui->tableWidget->rowCount();                for (int k = 0; k < iRowCount;++k)                {                        QString strHostName = ui->tableWidget->item(k, 0)->data(Qt::DisplayRole).toString();                        for (int n = 0; n < iSize;++n)                        {                                if (strHostName.toStdString() == pPingInfo[n].host.strHostName)                                {                                        if (pPingInfo[n].atimems == -1)                                                ui->tableWidget->item(k, 3)->setText(QString("---"));                                        else if (pPingInfo[n].atimems == -2)                                                ui->tableWidget->item(k, 3)->setText(QString::fromLocal8Bit("超时"));                                        else                                        {                                                ui->tableWidget->item(k, 3)->setText(QString("%1ms").arg(pPingInfo[n].atimems));                                                if (pPingInfo[n].atimems > alarmval)                                                        ui->tableWidget->item(k, 3)->setBackgroundColor(QColor(255, 0, 0));    //超限，红色提示                                                else                                                        ui->tableWidget->item(k, 3)->setBackgroundColor(QColor(255, 255, 255));                                        }                                                                                        if (pPingInfo[n].attl < 0)                                                ui->tableWidget->item(k, 4)->setText(QString("---"));                                        else                                                ui->tableWidget->item(k, 4)->setText(QString("%1").arg(pPingInfo[n].attl));                                        if (pPingInfo[n].btimems == -1)                                                ui->tableWidget->item(k, 5)->setText(QString("---"));                                        else if (pPingInfo[n].btimems == -2)                                                ui->tableWidget->item(k, 5)->setText(QString::fromLocal8Bit("超时"));                                        else                                        {                                                ui->tableWidget->item(k, 5)->setText(QString("%1ms").arg(pPingInfo[n].btimems));                                                if (pPingInfo[n].btimems > alarmval)                                                        ui->tableWidget->item(k, 5)->setBackgroundColor(QColor(255, 0, 0));     //超限，红色提示                                                else                                                        ui->tableWidget->item(k, 5)->setBackgroundColor(QColor(255, 255, 255));                                        }                                                                                        if (pPingInfo[n].bttl < 0)                                                ui->tableWidget->item(k, 6)->setText(QString("---"));                                        else                                                ui->tableWidget->item(k, 6)->setText(QString("%1").arg(pPingInfo[n].bttl));                                        QString strSndFrame = QString::fromLocal8Bit("A网:%1 | B网:%2").arg(pPingInfo[n].asnd, 3, 10, QLatin1Char('0')).arg(pPingInfo[n].bsnd, 3, 10, QLatin1Char('0'));                                        ui->tableWidget->item(k, 7)->setText(strSndFrame);                                        break;                                }                        }                }        }         while (true);        ui->pushButtonStop->setEnabled(false);        bool bRunningF = false;        do         {                bRunningF = false;                for (int ii = 0; ii < iSize; ++ii)                {                        if (pPingInfo[ii].runf == true)                        {                                ui->pushButtonStop->setText(QString::fromLocal8Bit("停止中..."));                                bRunningF = true;                                break;                        }                }        }         while (bRunningF);                for (int ii = 0; ii < iSize;++ii)        {                pPingInfo[ii].t.detach();        }        delete []pPingInfo;        ui->pushButtonStop->setText(QString::fromLocal8Bit("停止检测"));        ui->pushButtonStart->setEnabled(true);        ui->pushButtonStop->setEnabled(false);        ui->comboBox->setEnabled(true);        ui->lineEdit->setEnabled(true);}
复制代码
3、 运行结果



免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

汕尾海湾

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表