Qt/C++开源项目 TCP服务器调试助手（源码分享+发布链接下载）

🕗 发布于 2024-09-07 09:34 qt 开发语言

该TCP服务器调试助手是用于测试和监控基于TCP协议的网络通信工具，能够帮助开发者便捷地进行网络通信调试。通过简洁的界面设计，用户可以轻松配置、管理TCP端口的连接，收发消息并进行数据监控分析。以下是该工具的主要功能：

1. 端口管理

端口设置：用户可以在界面上设置服务器监听的端口号。在当前截图中，端口号被设置为123。
打开/关闭端口：用户可以通过点击“打开”或“关闭”按钮来启动或关闭指定端口。程序将监听该端口的TCP连接请求，并提供状态反馈。
清空信息：通过“清空信息”和“清空接收”按钮，用户可以快速清除当前界面上显示的日志信息和接收到的消息，方便调试过程中清理数据。

2. 数据交互

消息显示：程序可以显示详细的TCP通信记录，包括消息的发送时间、消息内容以及发送状态（发送成功或接收成功）。界面上区分了发送和接收消息，发送消息显示为橙色，接收消息显示为绿色。
通信消息格式：用户可选择以文本或HEX格式查看接收到的数据，并且可以通过界面勾选切换两种显示模式（例如：HEX显示和文本显示）。
收发统计：程序提供了“收到帧数”、“发送帧数”、“收到字节”、“发送字节”等统计信息，帮助用户实时监控通信的数据量。

3. 群发功能

定时群发：程序允许用户设置定时群发功能，用户可以向多个客户端定时发送消息。通过配置每个群发框，用户可以分别设置群发内容及时间间隔（以毫秒为单位）。截图中默认时间间隔为1000毫秒，即每秒发送一次。
HEX发送选项：在发送数据时，用户可以选择是否将消息以HEX格式发送，灵活满足不同的通信需求。

4. 消息提示

程序下方的提示窗口会显示实时的运行状态，例如：
- 成功启动服务器并监听端口的提示；
- 新客户端的连接信息（包含连接时间及客户端ID）。
这些提示信息帮助用户快速了解当前通信状态并排查可能存在的连接问题。

5. 客户端连接管理

连接显示：该工具不仅可以接收来自多个客户端的数据，还能显示每个客户端的唯一标识，如“客户端#1364”或“客户端#1380”，帮助用户有效管理多个连接。

6. 高度自定义

动态配置发送消息：用户可以在程序界面中动态输入或修改即将发送的消息内容，并且在必要时可通过“清空”按钮快速重置待发送的消息。
多消息通道：提供了多个消息发送输入框，方便用户针对不同的客户端或场景进行快速的消息群发操作。

发布软件下载链接

通过百度网盘分享的文件：TCP服务器调试助手.zip
链接：https://pan.baidu.com/s/1UF_fEztbQnk2UIJJUR7s3g?pwd=cedu
提取码：cedu

// tcpserver.h
#ifndef TCPSERVER_H
#define TCPSERVER_H

#include <QThread>
#include <QTcpServer>
#include <QTcpSocket>
#include <QMap>

#define tc(a) QString::fromLocal8Bit(a)

class TcpServer : public QThread
{
    Q_OBJECT

public:
    explicit TcpServer(QObject *parent = nullptr);
    void run() override;                          // 线程入口点
    bool startServer(int port);                   // 启动服务器
    void closeServer();
    void sendToAllClients(const QByteArray &message); // 群发消息
    void sendToClient(qintptr socketDescriptor, const QByteArray &message); // 发送消息给指定客户端

signals:
    void clientConnected(qintptr socketDescriptor);   // 新客户端连接信号
    void clientDisconnected(qintptr socketDescriptor); // 客户端断开信号
    void errors(int index, const QString &msg);      // 错误信号
    void warnings(int index, const QString &msg);    // 警告信号
    void informations(int index, const QString &msg); // 信息信号
    void ClientInfor(const long long socketDescriptor,const QByteArray &msg,const bool isRecv) ;  ///<接收客户端信息

private slots:
    void onNewConnection();                           // 新客户端连接时触发
    void onClientDisconnected();                      // 客户端断开时触发
    void onReadyRead();                               // 客户端有数据时触发

private:
    QTcpServer *tcpServer;                            // TCP服务器
    QMap<qintptr, QTcpSocket*> clients;               // 保存客户端列表
};
#endif // TCPSERVER_H

// tcpserver.cpp
#include "tcpserver.h"
#include <QHostAddress>
#include <QDebug>

TcpServer::TcpServer(QObject *parent)
    : QThread(parent), tcpServer(nullptr)
{
}

void TcpServer::run()
{
    exec();  // 启动线程事件循环
}

// 启动服务器并监听指定端口
bool TcpServer::startServer(int port)
{
    tcpServer = new QTcpServer();

    if (!tcpServer->listen(QHostAddress::Any, static_cast<quint16>(port)))
    {
        emit errors(1, tc("服务器启动失败:%1 端口: ").arg(tcpServer->errorString()) + QString::number(port));
        return false;
    }

    connect(tcpServer, &QTcpServer::newConnection, this, &TcpServer::onNewConnection);
    emit informations(1, tc("服务器启动成功，监听端口: ") + QString::number(port));

    return true;
}

void TcpServer::closeServer()
{
    tcpServer->close();
}

// 当有新客户端连接时
void TcpServer::onNewConnection()
{
    QTcpSocket *clientSocket = tcpServer->nextPendingConnection();
    qintptr socketDescriptor = clientSocket->socketDescriptor();

    clients.insert(socketDescriptor, clientSocket);  // 添加到客户端列表

    connect(clientSocket, &QTcpSocket::disconnected, this, &TcpServer::onClientDisconnected);
    connect(clientSocket, &QTcpSocket::readyRead, this, &TcpServer::onReadyRead);

    emit clientConnected(socketDescriptor);  // 触发客户端连接信号
    emit informations(2, tc("新的客户端连接，描述符: ") + QString::number(socketDescriptor));
}

// 当客户端断开连接时
void TcpServer::onClientDisconnected()
{
    QTcpSocket *clientSocket = qobject_cast<QTcpSocket*>(sender());
    if (clientSocket)
    {
        qintptr socketDescriptor=0;
        for (auto key : clients.keys()) {

            if(clients[key]==clientSocket)
                socketDescriptor = key;
        }
        clients.remove(socketDescriptor);  // 从客户端列表中移除
        emit clientDisconnected(socketDescriptor);  // 触发客户端断开信号
        emit warnings(1, tc("客户端断开连接，描述符: ") + QString::number(socketDescriptor));
        clientSocket->deleteLater();
    }
}

// 当有客户端发送数据时
void TcpServer::onReadyRead()
{
    QTcpSocket *clientSocket = qobject_cast<QTcpSocket*>(sender());
    if (clientSocket) {
        QByteArray data = clientSocket->readAll();
        emit ClientInfor(clientSocket->socketDescriptor(), data,true);
    }
}

// 群发消息
void TcpServer::sendToAllClients(const QByteArray &message)
{

    if(clients.keys().isEmpty())
    {
        emit errors(1, tc("未存在可发送的客户端 "));
        return;
    }

    for(auto key:clients.keys())
        sendToClient(key,message);
}

// 发送消息给指定客户端
void TcpServer::sendToClient(qintptr socketDescriptor, const QByteArray &message)
{
    QTcpSocket *clientSocket = clients.value(socketDescriptor, nullptr);
    if (clientSocket)
    {
        clientSocket->write(message);
        emit ClientInfor(clientSocket->socketDescriptor(), message,false);
    } else {
        emit errors(2, tc("无法找到指定的客户端，描述符: ") + QString::number(socketDescriptor));
    }
}

// mainwindow.h
#ifndef MAINWINDOW_H
#define MAINWINDOW_H

#include <QMainWindow>
#include <QStandardItemModel>
#include "tcpserver.h"

// 定义宏用于中文字符转换
#define tc(a) QString::fromLocal8Bit(a)

QT_BEGIN_NAMESPACE
namespace Ui { class MainWindow; }
QT_END_NAMESPACE
enum RunTimeStatus
{
    Error,            ///< 错误信息
    Warning,          ///< 警告信息
    Information,     ///< 常规信息
};
class MainWindow : public QMainWindow
{
    Q_OBJECT

public:
    MainWindow(QWidget *parent = nullptr);
    ~MainWindow();
    void initStyle();



    //创建发送框
    void createSendLinEdit();

private slots:
    void on_startServerButton_clicked();              // 点击启动服务器按钮
    void on_stopserverButton_clicked();
    void onClientConnected(qintptr socketDescriptor); // 客户端连接信号槽
    void onClientDisconnected(qintptr socketDescriptor); // 客户端断开信号槽
    void handleErrors(int index, const QString &msg);      // 处理错误信号槽
    void handleWarnings(int index, const QString &msg);    // 处理警告信号槽
    void handleInformations(int index, const QString &msg); // 处理信息信号槽
    void handlerClientInfor(const long long id,const QByteArray &data,const bool isRecv);
    void writeRunTimeMsgs(const QString &msg, const int level); // 输出运行时消息




    void on_clearRunTimeutton_clicked();

    void on_clearRecvButton_clicked();

    void on_closeTip_clicked();

private:
    Ui::MainWindow *ui;
    TcpServer *server;                     // TCP服务器
    QStandardItemModel *model; // 共享数据模型
};
#endif // MAINWINDOW_H

// mainwindow.cpp
#include "mainwindow.h"
#include "ui_mainwindow.h"
#include <QDateTime>
#include <QTextEdit>
#include <QFile>
#include "timesendwidget.h"
MainWindow::MainWindow(QWidget *parent)
    : QMainWindow(parent)
    , ui(new Ui::MainWindow)
    , server(new TcpServer())  // 初始化服务器
{
    ui->setupUi(this);


    // 连接服务器信号槽
    connect(server, &TcpServer::clientConnected, this, &MainWindow::onClientConnected);
    connect(server, &TcpServer::clientDisconnected, this, &MainWindow::onClientDisconnected);
    connect(server, &TcpServer::errors, this, &MainWindow::handleErrors);
    connect(server, &TcpServer::warnings, this, &MainWindow::handleWarnings);
    connect(server, &TcpServer::informations, this, &MainWindow::handleInformations);
    connect(server, &TcpServer::ClientInfor, this, &MainWindow::handlerClientInfor);



    // 创建共享的数据模型
    model = new QStandardItemModel(this);

    QStandardItem *item = new QStandardItem(tc("群发"));
    item->setData(-1,Qt::UserRole);
    model->appendRow(item);

    createSendLinEdit();
    initStyle();
}

MainWindow::~MainWindow()
{
    delete ui;
    server->quit();  // 退出服务器线程
    server->wait();  // 等待线程结束
    delete server;
}

void MainWindow::initStyle()
{
    //加载样式表
    QString qss;
    QFile file(":/qss/psblack.css");
    if (file.open(QFile::ReadOnly)) {
#if 1
        //用QTextStream读取样式文件不用区分文件编码 带bom也行
        QStringList list;
        QTextStream in(&file);
        //in.setCodec("utf-8");
        while (!in.atEnd()) {
            QString line;
            in >> line;
            list << line;
        }

        qss = list.join("\n");
#else
        //用readAll读取默认支持的是ANSI格式,如果不小心用creator打开编辑过了很可能打不开
        qss = QLatin1String(file.readAll());
#endif
        QString paletteColor = qss.mid(20, 7);
        qApp->setPalette(QPalette(paletteColor));
        qApp->setStyleSheet(qss);
        file.close();
    }
}

void MainWindow::createSendLinEdit()
{
    for(int i=0;i<10;i++)
    {
        TimeSendWidget *sendWidget=new TimeSendWidget;
        sendWidget->setComBoxModel(model);
        connect(sendWidget,&TimeSendWidget::sendLineData,[=](const qintptr socketDescriptor,const QByteArray &data )
        {

            if(data.isEmpty())
            {
                writeRunTimeMsgs(tc("信息为空,拒绝发送"),Warning);
                return ;
            }

            ((socketDescriptor<0)? server->sendToAllClients(data): server->sendToClient(socketDescriptor, data));




        });
        ui->verticalLayout->addWidget(sendWidget);
    }
}


// 启动服务器按钮
void MainWindow::on_startServerButton_clicked()
{
    int port = ui->portspinBox->value();
    if (port > 0) {
        if (server->startServer(port))
        {
            writeRunTimeMsgs(tc("服务器成功启动，监听端口：") + QString::number(port), 2);
            ui->startServerButton->setEnabled(false);
        } else {
            writeRunTimeMsgs(tc("服务器启动失败！"), 0);
        }
    } else {
        writeRunTimeMsgs(tc("无效的端口号！"), 1);
    }
}
// 关闭服务器按钮
void MainWindow::on_stopserverButton_clicked()
{
    server->closeServer();
    ui->startServerButton->setEnabled(true);

}
// 处理客户端连接的槽函数
void MainWindow::onClientConnected(qintptr socketDescriptor)
{
    writeRunTimeMsgs(tc("客户端连接，描述符: ") + QString::number(socketDescriptor), 2);

    QStandardItem *item = new QStandardItem(tc("客户端#%1").arg(socketDescriptor));
    item->setData(socketDescriptor,Qt::UserRole);
    model->appendRow(item);


}

// 处理客户端断开的槽函数
void MainWindow::onClientDisconnected(qintptr socketDescriptor)
{
    writeRunTimeMsgs(tc("客户端断开连接，描述符: ") + QString::number(socketDescriptor), 1);

    // 从客户端列表中移除
    for (int i = 0; i < model->rowCount(); ++i)
    {
        QStandardItem *item = model->item(i);
        if (item && item->data(Qt::UserRole).toLongLong() == socketDescriptor)
        {

            model->removeRow(i);  // 删除找到的行
            break;  // 如果只想删除第一个匹配的项，删除后直接跳出循环
        }
    }
}

// 处理错误信号
void MainWindow::handleErrors(int index, const QString &msg)
{
    Q_UNUSED(index);
    writeRunTimeMsgs(msg, Error);
}

// 处理警告信号
void MainWindow::handleWarnings(int index, const QString &msg)
{
    Q_UNUSED(index);
    writeRunTimeMsgs( msg, Warning);
}

// 处理信息信号
void MainWindow::handleInformations(int index, const QString &msg)
{
    Q_UNUSED(index);
    writeRunTimeMsgs(msg, Information);
}

void MainWindow::handlerClientInfor(const long long id, const QByteArray &data, const bool isRecv)
{

    QString prefix;
    QString color;
    QString msg=tc("%1客户端#%2: %3").arg(isRecv?tc("接收←"):tc("发送→")).arg(id).arg(ui->isShowHexButton->isChecked()? data.toHex(' ').toUpper():QString::fromLocal8Bit(data));

    if(isRecv)
    {

        //更新显示信息
        ui->recvByte->setValue(ui->recvByte->value()+data.size());
        ui->recvFram->setValue(ui->recvFram->value()+1);

        if(!ui->isShowRecvButton->isChecked())
            return;
        prefix = tc("【接收】");
        color = "#00ff00";
    }
    else
    {

        ui->sendByte->setValue(ui->sendByte->value()+data.size());
        ui->sendFram->setValue(ui->sendFram->value()+1);

        if(!ui->isShowSendButton->isChecked())
            return;

        prefix = tc("【发送】");
        color = "orange";


    }


    // 获取当前时间
    QString timestamp = ui->isShowTimeButton->isChecked()?QDateTime::currentDateTime().toString("hh:mm:ss(zzz)"):"";
    // 将消息插入到QTextEdit中并改变颜色
    // 将消息插入到QTextEdit中并改变颜色
    QString formattedMsg = QString("<span style='color:%1;'>%2 %3: %4</span>").arg(color, prefix, timestamp,msg);
    ui->receiveTextEdit->append(formattedMsg);
}

// 输出运行时消息
void MainWindow::writeRunTimeMsgs(const QString &msg, const int level)
{
    QString prefix;
    QString color;

    // 获取当前时间
    QString timestamp = QDateTime::currentDateTime().toString("yyyy-MM-dd hh:mm:ss");

    switch (level) {
    case 0: // 异常
        prefix = tc("【异常】");
        color = "red";
        break;
    case 1: // 警报
        prefix = tc("【警报】");
        color = "orange";
        break;
    case 2: // 提示
        prefix = tc("【提示】");
        color = "#00ff00";
        break;
    }
    // 将消息插入到QTextEdit中并改变颜色
    QString formattedMsg = QString("<span style='color:%1;'>%2 %3: %4</span>").arg(color, prefix, timestamp, msg);
    ui->outputTextEdit->append(formattedMsg);

}




void MainWindow::on_clearRunTimeutton_clicked()
{
    ui->outputTextEdit->clear();
}

void MainWindow::on_clearRecvButton_clicked()
{
      ui->receiveTextEdit->clear();
}

void MainWindow::on_closeTip_clicked()
{
    ui->groupBox->setVisible(!ui->groupBox->isVisible());
}

原文地址：https://blog.csdn.net/chenai886/article/details/141950190

免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！

上一篇：linux线程cp模型，posix信号量，线程池，线程封装，单例模型，懒汉饿汉实现方式，自旋锁，读者写者模型
下一篇：vue3整合antv x6实现图编辑器快速入门

excel如何快速选中某个数字或者某串数字
鼠标光标放在某个数字或者某串数字的末尾，进行双击鼠标左键即可（就会选中当前鼠标光标前相邻的所有数字）：
阅读更多2024-09-17
面试官问：请描述一次你成功解决问题的经历？
面试官为什么要这么问？面试官问你描述一次成功解决问题的经历，主要是为了评估你的几个关键方面：问题解决能力：了解你在面对挑战时的思维方式和应对策略。决策能力：考察你在压力下做出明智决定的能力。沟通技巧：
阅读更多2024-09-17
VLMEvalKit 评测实践:InternVL2 VS Qwen2VL
多模态技术的突破，正在改变我们理解和交互世界的方式。无论是强大的感知能力、复杂的推理分析，还是图文融合的创新应用，InternVL2 与 Qwen2-VL 展现了大模型的无限可能。
阅读更多2024-09-17
mybatis开启日志
步骤很详细，直接上教程……
阅读更多2024-09-17
MySQL——数据库的高级操作（一）数据备份与还原（1）数据的备份
MySQL——数据库的高级操作（一）数据备份与还原（1）数据的备份
阅读更多2024-09-17
Blender渲染太慢怎么办？blender云渲染已开启
此次，渲染101云渲染农场正式加入了对Blender的全面支持，涵盖Blender的所有版本，不论是较新的Blender 4.0还是早期版本，都可轻松对接渲染101平台服务。不论是小型独立项目还是大型
阅读更多2024-09-17
ubuntu安装mysql 8.0忘记root初始密码，如何重新修改密码
修改my.cnf文件，在文件新增 skip-grant-tables，在启动mysql时不启动grant-tables，授权表。5.注释掉skip-grant-tables后重启mysql。2、修改m
阅读更多2024-09-17
JVM面试真题总结（十一）
总的来说，Java内存模型主要解决了多线程环境下共享数据的一致性、可见性等问题，是Java并发编程的基础。这种模型的好处是，由于启动类加载器是最顶部的加载器，因此它加载的都是最可信任的类库（Java的
阅读更多2024-09-17
Ubuntu 软件仓库镜像使用帮助
选择镜像。
阅读更多2024-09-17
用于稀疏自适应深度细化的掩码空间传播网络 CVPR2024
图像引导的深度补全是一项通过利用稀疏深度测量和RGB图像来估计密集深度图的任务；它通过估算深度来填充未测量的区域。由于许多深度传感器（如LiDAR和飞行时间相机（ToF））只能提供稀疏的深度图，这项任
阅读更多2024-09-17