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

Qt网络编程小项目-基于Tcp协议的文件传输项目_qt中网络编程怎样发送与接收文件

作者：从前慢现在也慢 | 2024-03-24 22:05:21

赞

踩

qt中网络编程怎样发送与接收文件

目录

项目描述

Qt下Tcp服务器端和客户端流程：

具体流程：

客户端：

服务器端：

源码：

服务器端：

服务器头文件：

服务器源文件：

服务器端ui

客户端：

客户端头文件：

客户端源文件：

客户端ui：

项目描述

利用Tcp协议实现服务器端和客户端数据的传输，客户端向服务器端传输文件（音频、视频、文本）类似客户端上传文件

Qt下Tcp服务器端和客户端流程：

具体流程：

客户端：

头文件：

#include <QWidget>

#include <QTcpSocket>

#include <QFileDialog>//显示文件对话框

#include <QFileInfo>//获取文件信息

#include <QTimer>

  1. 客户端连接服务器

客户端只需一个接收套接字 tcpSocket = new QTcpSocket(this);

tcpSocket->connectToHost(Ip，port);连接到服务器端

开辟一个QByteArray array内存空间，通过信号与槽connect

  1. 1选择要传输的文件

QString filePath = QFileDialong::getOpenFileName(this);

QFileInfo FileData(filePath);//获取文件信息

filename = FileData.fileName();//获得文件名字

filesize = FileData.size();//获得文件大小 字节

  1.  2文件操作

QFile file创建一个文件描述符，

  1. 3文件发送

文件的发送分为两个部分：

        a.先发送一个包含文件信息的字符串类型为" filename**filesize "

QString head = filename + "**" + QString::number(filename); 
qint64 length = tcpSocket->write(head.toutf8); 
if(length>0)//发送成功 
        myTimer->start(20);//设置一个定时器 防止内容粘包 
else //发送不成功 
        file.close();

        b.防止粘包发送成功后设置一个延迟 设置一个定时器myTimer 开始发送文件本身

 myTimer = new QTimer(this); 
connect(myTimer,&QTimer::timeout, this ,[&](){ 
myTimer->stop(); 
qint64 len; 
qint64 sendSize = 0;//已经发送文件大小 
do{ char buf[4*1024] = {0};//一次读取char这么大 
len = 0; 
len = file.read(buf,sizeof(buf));//从file中读取4096放到buf中 
tcpSocket->write(buf,len);//写入 
sendSize += len; ui->progressBar->setValue(sendSize/1024);//设置进度条 }while(len>0); 
if(sendSize == filesize)//发送内存大小和实际文件内存大小相等传输完毕 
{ file.close(); 
tcpSocket->disconnectFromHost();//断开连接 
tcpSocket->close();
 } });

服务器端：

头文件：

#include <QTcpServer>监听套接字

#include <QTcpSocket>通信套接字

QTcpServer *tcpserver;监听套接字对象

QTcpSocket *clientConnection = nullptr;通信套接字对象

        1. 监听对象开辟空间

tcpserver = new QTcpServer(this);

调用listen（）监听 这里使用的是本地主机127.0.0.1的Ip地址

tcpserver ->listen(QHostAddress::LocalHost,ui->lineEdit->text().toInt());

        2.连接客户端 接受文件

  • 采用信号与槽的方式

connect(tcpserver,&QTcpServer::newConnection,this,[&](){
        clientConnection = tcpserver->nextPendingConnection();
        clientConnection->write("Welcome to connect to the server!");//连接成功向客户端发送成功连接字样

        //接收端
        connect(clientConnection, QTcpSocket::readyRead,this,[&](){
            QByteArray array = clientConnection->readAll();
            if(headInfo){ //第一次读出的信息应该是head文件信息
                 headInfo = false;
                 recvSize = 0;
                 filename = QString(array).section("**",0,0); //分割出需要的信息
                 filesize = QString(array).section("**",1,1).toInt();

                 file.setFileName(filename);
                 file.open(QIODevice::WriteOnly);//发送端只读打开

                 //设置进度条
                 ui->progressBar->setMinimum(0);
                 ui->progressBar->setMaximum(filesize/1024);
                 ui->progressBar->setValue(0);//初始为0
            }
            else{//这里收到的文件是文件本身
                qint64 length = file.write(array);
                if(length >0)
                    recvSize += length;
                 ui->progressBar->setValue(recvSize/1024);
                 if(recvSize == filesize)
                 {
                     //文件接受完毕
                     QMessageBox::information(this,"完成","文件接受完成");
                     file.close();
                 }
            }
        });
    } );

源码：

服务器端：

服务器头文件：

  1. #ifndef WIDGET_H
  2. #define WIDGET_H
  3.  
  4. #include <QWidget>
  5. #include <QTcpServer>
  6. #include <QTcpSocket>
  7. #include <QFileDialog>
  8. #include <QFile>
  9. #include <QMessageBox>
  10.  
  11.  
  12. namespace Ui {
  13. class Widget;
  14. }
  15.  
  16. class Widget : public QWidget
  17. {
  18.     Q_OBJECT
  19.  
  20. public:
  21.     explicit Widget(QWidget *parent = 0);
  22.     ~Widget();
  23.  
  24. private slots:
  25.     void on_pushButton_clicked();
  26.  
  27. private:
  28.     Ui::Widget *ui;
  29.     QTcpServer *tcpserver;//监听服务器端套接字
  30.     QTcpSocket *clientConnection = nullptr;//通信套接字
  31.  
  32.     bool headInfo = true;
  33.     QString filename;
  34.     qint64 filesize;
  35.     qint64 recvSize;//收到文件的大小
  36.     QFile file;
  37. };
  38.  
  39. #endif // WIDGET_H

服务器源文件：

  1. #include "widget.h"
  2. #include "ui_widget.h"
  3. #include <QDebug>
  4.  
  5. Widget::Widget(QWidget *parent) :
  6.     QWidget(parent),
  7.     ui(new Ui::Widget)
  8. {
  9.     ui->setupUi(this);
  10.     setWindowTitle("服务器");
  11.     ui->lineEdit->setText("8080");//初始端口号值
  12.  
  13.     tcpserver = new QTcpServer(this);
  14.  
  15. }
  16.  
  17. Widget::~Widget()
  18. {
  19.     delete ui;
  20. }
  21.  
  22. void Widget::on_pushButton_clicked()
  23. {
  24.  
  25.  
  26.     tcpserver ->listen(QHostAddress::LocalHost,ui->lineEdit->text().toInt());//(LocalHost本机环回地址)
  27.  
  28.     connect(tcpserver,&QTcpServer::newConnection,this,[&](){
  29.         clientConnection = tcpserver->nextPendingConnection();
  30.         clientConnection->write("Welcome to connect to the server!");
  31.  
  32.         //接收端
  33.         connect(clientConnection, QTcpSocket::readyRead,this,[&](){
  34.             QByteArray array = clientConnection->readAll();
  35.             if(headInfo){ //第一次读出的信息应该是head文件信息
  36.                  headInfo = false;
  37.                  
  38.  
  39.                  recvSize = 0;
  40.                  filename = QString(array).section("**",0,0); //分割出需要的信息
  41.                  filesize = QString(array).section("**",1,1).toInt();
  42.  
  43.                  file.setFileName(filename);
  44.                  file.open(QIODevice::WriteOnly);//发送端只读打开
  45.  
  46.                  //设置进度条
  47.                  ui->progressBar->setMinimum(0);
  48.                  ui->progressBar->setMaximum(filesize/1024);
  49.                  ui->progressBar->setValue(0);//初始为0
  50.             }
  51.             else{//这里收到的文件是文件本身
  52.                 qint64 length = file.write(array);
  53.                 if(length >0)
  54.                     recvSize += length;
  55.                  ui->progressBar->setValue(recvSize/1024);
  56.                  if(recvSize == filesize)
  57.                  {
  58.                      //文件接受完毕
  59.                      QMessageBox::information(this,"完成","文件接受完成");
  60.                      file.close();
  61.                  }
  62.  
  63.             }
  64.         });
  65.     } );
  66.     ui->pushButton->setEnabled(false);
  67. }

服务器端ui

客户端：

客户端头文件：

  1. #ifndef WIDGET_H
  2. #define WIDGET_H
  3.  
  4. #include <QWidget>
  5. #include <QTcpServer>
  6. #include <QTcpSocket>
  7. #include <QFileDialog>//显示文件对话框
  8. #include <QFileInfo>//获取文件信息
  9. #include <QTimer>
  10.  
  11. namespace Ui {
  12. class Widget;
  13. }
  14.  
  15. class Widget : public QWidget
  16. {
  17.     Q_OBJECT
  18.  
  19. public:
  20.     explicit Widget(QWidget *parent = 0);
  21.     ~Widget();
  22.  
  23. private slots:
  24.     void on_pushButton_clicked();
  25.  
  26.     void on_pushButton_2_clicked();
  27.  
  28.     void on_pushButton_3_clicked();
  29.  
  30. private:
  31.     Ui::Widget *ui;
  32.     QTcpSocket *tcpSocket; //客户端只需要一个接受套接字
  33.     QString filename;
  34.     qint64 filesize;
  35.     QFile file;     //文件描述符
  36.     QTimer *myTimer; //定时器
  37. };
  38.  
  39. #endif // WIDGET_H

客户端源文件：

  1. #include "widget.h"
  2. #include "ui_widget.h"
  3. #include <QDebug>
  4.  
  5. Widget::Widget(QWidget *parent) :
  6.     QWidget(parent),
  7.     ui(new Ui::Widget)
  8. {
  9.     ui->setupUi(this);
  10.     setWindowTitle("客户端");
  11.  
  12.     tcpSocket = new QTcpSocket(this);
  13.  
  14.     connect(tcpSocket, &QTcpSocket::readyRead,this,[&](){
  15.         QByteArray array = tcpSocket->readAll();
  16.         qDebug()<<"服务器： "<<array;
  17.     });
  18.  
  19.     myTimer = new QTimer(this);
  20.     connect(myTimer,&QTimer::timeout, this ,[&](){
  21.         myTimer->stop();
  22.  
  23.         qint64 len;
  24.         qint64 sendSize = 0;//已经发送文件大小
  25.  
  26.         do{
  27.             char buf[4*1024] = {0};//一次读取char这么大
  28.             len = 0;
  29.             len = file.read(buf,sizeof(buf));
  30.             tcpSocket->write(buf,len);
  31.             sendSize += len;
  32.             ui->progressBar->setValue(sendSize/1024);
  33.         }while(len>0);
  34.         if(sendSize == filesize )
  35.         {
  36.             file.close();
  37.             tcpSocket->disconnectFromHost();//断开连接
  38.             tcpSocket->close();
  39.         }
  40.     });
  41.  
  42. }
  43.  
  44. Widget::~Widget()
  45. {
  46.     delete ui;
  47. }
  48.  
  49. void Widget::on_pushButton_clicked()//连接按钮
  50. {
  51.     //连接服务器
  52.     tcpSocket->connectToHost(ui->lineEdit->text(),ui->lineEdit_2->text().toInt());
  53. }
  54.  
  55. void Widget::on_pushButton_2_clicked()//打开按钮
  56. {
  57.    QString filePath =  QFileDialog::getOpenFileName(this);
  58.  
  59.    //发送文件时先发送一个文件名字和文件大小，如果两端文件大小相同说明发送完毕
  60.    QFileInfo FileData(filePath);//获取文件信息
  61.    filename = FileData.fileName();//获得文件名字
  62.    filesize = FileData.size();//获得文件大小
  63.  
  64.    qDebug()<<"文件名："<<filename;
  65.    qDebug()<<"文件大小："<<filesize;
  66.  
  67.     if(!filePath.isEmpty())
  68.     {
  69.         ui->label_3->setText(filePath);//显示文件名字
  70.         file.setFileName(filePath);
  71.         file.open(QIODevice::ReadOnly);//发送端只读打开
  72.     }
  73.  
  74.     //设置进度条
  75.     ui->progressBar->setMinimum(0);
  76.     ui->progressBar->setMaximum(filesize/1024);
  77.     ui->progressBar->setValue(0);//初始为0
  78. }
  79.  
  80. void Widget::on_pushButton_3_clicked()
  81. {
  82.    //头信息
  83.   QString head = filename + "**" + QString::number(filesize);  //强制类型转换成字符串
  84.   //发送head文件
  85.   qint64 length = tcpSocket->write(head.toUtf8());
  86.   if(length>0)//发送成功
  87.       myTimer->start(20);//设置一个定时器 防止内容粘包
  88.  
  89.   else        //发送不成功
  90.       file.close();
  91. }

客户端ui：

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

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

  

闽ICP备14008679号