QT开发中文网

qt 写一个自测的tcp连接收发文件

下面是一个简单的自测程序,可以用于测试 TCP 连接并收发文件:

#include <QCoreApplication>
#include <QTcpServer>
#include <QTcpSocket>
#include <QFile>

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);

    // 创建本地服务器
    QTcpServer server;
    if (!server.listen(QHostAddress::AnyIPv4, 2074)) {
        qDebug() << "Failed to start server";
        return -1;
    }
    qDebug() << "Server started";

    // 监听新连接
    QObject::connect(&server, &QTcpServer::newConnection, [&](){
        qDebug() << "New connection accepted";
        QTcpSocket *socket = server.nextPendingConnection();

        // 接收数据包
        QByteArray packet;
        qint64 bytes_available = socket->bytesAvailable();
        while (bytes_available > 0) {
            packet.append(socket->readAll());
            bytes_available = socket->bytesAvailable();
            QThread::msleep(10); // 等待一段时间再读取下一批数据
        }

        // 解析数据包
        if (packet.size() <= 3) { // 数据包太短,无法解析
            qDebug() << "Invalid packet size";
            return;
        }
        char head = packet.at(0);
        char tail = packet.at(packet.size()-1);
        if (head != char(0xCD) || tail != char(0xDC)) { // 协议头或协议尾不正确
            qDebug() << "Invalid protocol header or footer";
            return;
        }
        int name_size = packet.at(1);
        QString file_name(packet.mid(2, name_size));
        QByteArray content = packet.mid(name_size+2, packet.size()-name_size-3);
        qDebug() << "Received file:" << file_name;

        // 保存文件到本地
        QFile file(file_name);
        if (!file.open(QIODevice::WriteOnly)) {
            qDebug() << "Failed to open file";
            return;
        }
        qint64 bytes_written = file.write(content);
        if (bytes_written != content.size()) {
            qDebug() << "Failed to write data";
            return;
        }
        file.close();
        qDebug() << "File saved:" << file_name;

        // 发送响应消息
        QString response("OK");
        socket->write(response.toUtf8());
    });

    // 创建客户端并连接服务器
    QTcpSocket socket;
    if (!socket.waitForConnected(3000)) {
        qDebug() << "Failed to connect to server";
        return -1;
    }

    // 打开文件并读取内容
    QFile file("test.txt");
    if (!file.open(QIODevice::ReadOnly)) {
        qDebug() << "Failed to open file";
        return -1;
    }
    QByteArray content = file.readAll();
    QString file_name = file.fileName();
    file.close();

    // 构造数据包
    QByteArray packet;
    packet.append(char(0xCD));  // 协议头
    packet.append(file_name.length());
    packet.append(file_name);
    packet.append(content.length());
    packet.append(content);
    packet.append(char(0xDC));  // 协议尾

   // 发送数据包
   qint64 bytes_written = socket.write(packet);
   if (bytes_written != packet.size()) {
       qDebug() << "Failed to send data";
       return -1;
   }

   // 等待服务器响应
   if (!socket.waitForReadyRead(5000)) {
       qDebug() << "Failed to receive response";
       return -1;
   }

   // 读取并打印服务器响应
   QByteArray response = socket.readAll();
   qDebug() << "Server response:" << response;

    return a.exec();
}

程序分为两部分:服务端和客户端。服务端监听本地 2074 端口,接收客户端上传的文件并保存到本地。客户端连接服务端,并发送指定文件到服务端。

数据包格式如下:

+-----+--------+----------------------+--------+------------+------+
| 头字节 | 文件名长度 | 文件名 | 内容长度 | 内容 | 尾字节 |
| (1 字节) | (1 字节) | (n 字节, n <= 255) | (4 字节) | (m 字节) | (1 字节) |
+-----+--------+----------------------+--------+------------+------+

其中,头字节和尾字节分别为 0xCD 和 0xDC,用于标识协议的开始和结束。文件名长度是一个字节,限制了文件名最长为 255 个字符。内容长度是四个字节,可以支持传输超过 4GB 的大文件。

你需要在此基础上进行修改和完善,以满足自己的需求。

本站部分文章来源于网络,版权归原作者所有,如有侵权请联系站长删除。
转载请注明出处:https://qt.0voice.com/?id=1782

分享:
扫描分享到社交APP
上一篇
下一篇
发表列表
游客 游客
此处应有掌声~
评论列表

还没有评论,快来说点什么吧~

联系我们

在线咨询: 点击这里给我发消息

微信号:3007537140

上班时间: 10:30-22:30

关注我们
x

注册

已经有帐号?