在QT实现文件传输_qt 字节流复制文件

作者：笔触狂放9 | 2024-03-24 22:01:45

踩

qt 字节流复制文件

过程如下：

1、服务器端设置监听套接字，开始监听；

2、客户端在连接成功时开始传送文件，有connected()信号连接send()槽，send()发送文件头信息，包括文件名、文件总大小和文件名大小等；

3、传送完文件头信息时开始传送文件内容，有bytesWritten(qint64)信号连接到goOnSend(qint64)槽，前者是当想套接字写入数据时会出发的信号，即当已经想套接字写入数据，就继续传送数据，有send()传送文件头信息开始触发，直到文件传完为止。

4、在服务器端，首先接收文件头信息，然后读取文件名来用新建文件的方式打开一个文件，然后读取文件名即文件等大小信息，用来更新进度条和继续接收数据；

5、实现循环传输，在客户端，因为第一次send()是由connected()信号触发的，之后的每次传送应该手动调用send()；在服务器端，在有新数据到达时，会判断是否为头文件，因此在每次文件传完的时候将byteReceived重置为0，即下一次再接收到数据的时候依据byteReceived判断的结果就是一个新文件了。

客户端代码：

[cpp]view plaincopy 
   
 #ifndef WIDGET_H  
 #define WIDGET_H  
   
 #include <QWidget>  
 #include <QTcpSocket>  
 #include <QFile>  
 #include <string>  
   
 namespace Ui {  
 class Widget;  
 }  
   
 class Widget : public QWidget  
 {  
     Q_OBJECT  
   
 public:  
     explicit Widget(QWidget *parent = 0);  
     ~Widget();  
       
 private:  
     Ui::Widget *ui;  
   
     QTcpSocket *tcpClient;  
     QFile *localFile;  
     QString fileName;  //文件名  
   
     QByteArray outBlock;  //分次传  
     qint64 loadSize;  //每次发送数据的大小  
     qint64 byteToWrite;  //剩余数据大小  
     qint64 totalSize;  //文件总大小  
   
     int sendTimes;  //用来标记是否为第一次发送，第一次以后连接信号触发，后面的则手动调用  
   
 private slots:  
     void send();  //传送文件头信息  
     void goOnSend(qint64);  //传送文件内容  
     void on_openPushButton_clicked();  
     void on_sendPushButton_clicked();  
 };  
   
 #endif // WIDGET_H  

widget.cpp

[cpp]view plaincopy 
   
 #include "widget.h"  
 #include "ui_widget.h"  
 #include <QHostAddress>  
 #include <QTextCodec>  
 #include <QFileDialog>  
   
 Widget::Widget(QWidget *parent) :  
     QWidget(parent),  
     ui(new Ui::Widget)  
 {  
     ui->setupUi(this);  
   
     ui->progressLabel->hide();  
     QTextCodec::setCodecForLocale(QTextCodec::codecForName("UTF8"));
   
     tcpClient = new QTcpSocket(this);  
     sendTimes = 0;  
   
     connect(tcpClient, SIGNAL(connected()), this, SLOT(send()));  //当连接成功时，就开始传送文件  
     connect(tcpClient, SIGNAL(bytesWritten(qint64)), this, SLOT(goOnSend(qint64)));   
 }  
   
 void Widget::send()  //发送文件头信息  
 {  
     byteToWrite = localFile->size();  //剩余数据的大小  
     totalSize = localFile->size();  
   
     loadSize = 4*1024;  //每次发送数据的大小  
   
     QDataStream out(&outBlock, QIODevice::WriteOnly);  
     QString currentFileName = fileName.right(fileName.size() - fileName.lastIndexOf('/')-1);  
   
     out<<qint64(0)<<qint64(0)<<currentFileName;  
   
     totalSize += outBlock.size();  //总大小为文件大小加上文件名等信息大小  
     byteToWrite += outBlock.size();  
   
     out.device()->seek(0);  //回到字节流起点来写好前面连个qint64，分别为总大小和文件名等信息大小  
     out<<totalSize<<qint64(outBlock.size());  
   
     tcpClient->write(outBlock);  //将读到的文件发送到套接字  
   
     ui->progressLabel->show();  
     ui->sendProgressBar->setMaximum(totalSize);  
     ui->sendProgressBar->setValue(totalSize - byteToWrite);  
 }  
   
 void Widget::goOnSend(qint64 numBytes)  //开始发送文件内容  
 {  
     byteToWrite -= numBytes;  //剩余数据大小  
     outBlock = localFile->read(qMin(byteToWrite, loadSize));  
     tcpClient->write(outBlock);  
   
     ui->sendProgressBar->setMaximum(totalSize);  
     ui->sendProgressBar->setValue(totalSize - byteToWrite);  
   
     if(byteToWrite == 0)  //发送完毕  
         ui->sendStatusLabel->setText(tr("文件发送完毕!"));  
 }  
   
 Widget::~Widget()  
 {  
     delete ui;  
 }  
   
 void Widget::on_openPushButton_clicked()  //打开文件并获取文件名（包括路径）  
 {  
     ui->sendStatusLabel->setText(tr("正在打开文件..."));  
     ui->sendProgressBar->setValue(0);  //非第一次发送  
   
     loadSize = 0;  
     byteToWrite = 0;  
     totalSize = 0;  
     outBlock.clear();  
   
     fileName = QFileDialog::getOpenFileName(this);  
     localFile = new QFile(fileName);  
     localFile->open(QFile::ReadOnly);  
   
     ui->sendStatusLabel->setText(tr("已打开文件 %1").arg(fileName));  
 }  
   
 void Widget::on_sendPushButton_clicked()  
 {  
     if(sendTimes == 0)  //只有第一次发送的时候，是发生在连接产生信号connect时  
     {  
         tcpClient->connectToHost(QHostAddress("192.168.1.137"), 1000);  
         sendTimes = 1;    
     }  
     else  
         send();  //第一次发送的时候是由connectToHost出发connect信号才能调用send，第二次之后就需要调用send了  
   
     ui->sendStatusLabel->setText(tr("正在发送文件 %1").arg(fileName));  
 }  

服务端代码：

widget.h

[cpp]view plaincopy 
   
 #ifndef WIDGET_H  
 #define WIDGET_H  
   
 #include <QWidget>  
 #include <QtNetwork/QTcpServer>  
 #include <QtNetwork/QTcpSocket>  
 #include <QFile>  
 #include <QString>  
   
 namespace Ui {  
 class Widget;  
 }  
   
 class Widget : public QWidget  
 {  
     Q_OBJECT  
       
 public:  
     explicit Widget(QWidget *parent = 0);  
     ~Widget();  
       
 private:  
     Ui::Widget *ui;  
   
     QTcpServer *server;  
     QTcpSocket *receivedSocket;  
     QFile *newFile;  
   
     QByteArray inBlock;  
     QString fileName;  
     qint64 totalSize;  //总共需要发送的文件大小（文件内容&文件名信息）  
     qint64 byteReceived;  //已经发送的大小  
   
 private slots:  
     void acceptConnection();  
     void readClient();  
     void on_pushButton_clicked();  
 };  
   
 #endif // WIDGET_H  

widget.cpp

[cpp]view plaincopy 
   
 #include "widget.h"  
 #include "ui_widget.h"  
 #include <QTextCodec>  
   
 Widget::Widget(QWidget *parent) :  
     QWidget(parent),  
     ui(new Ui::Widget)  
 {  
     ui->setupUi(this);  
     ui->progressLabel->hide();   
      QTextCodec::setCodecForLocale(QTextCodec::codecForName("UTF8")); 
 }  
   
 void Widget::acceptConnection()  
 {  
     ui->receivedStatusLabel->setText(tr("已连接，正在准备接收文件!"));  
   
     receivedSocket = server->nextPendingConnection();  
     connect(receivedSocket, SIGNAL(readyRead()), this, SLOT(readClient()));  
 }  
   
 void Widget::readClient()  
 {  
     ui->receivedStatusLabel->setText(tr("正在接收文件..."));  
   
     if(byteReceived == 0)  //才刚开始接收数据，此数据为文件信息  
     {  
         ui->receivedProgressBar->setValue(0);  
   
         QDataStream in(receivedSocket);  
         in>>totalSize>>byteReceived>>fileName;    
         newFile = new QFile(fileName);  
         newFile->open(QFile::WriteOnly);  
     }  
     else  //正式读取文件内容  
     {  
         inBlock = receivedSocket->readAll();  
   
         byteReceived += inBlock.size();  
         newFile->write(inBlock);  
         newFile->flush();  
     }   
     ui->progressLabel->show();  
     ui->receivedProgressBar->setMaximum(totalSize);  
     ui->receivedProgressBar->setValue(byteReceived);  
   
     if(byteReceived == totalSize)  
     {  
         ui->receivedStatusLabel->setText(tr("%1接收完成").arg(fileName));  
   
         inBlock.clear();  
         byteReceived = 0;  
         totalSize = 0;  
     }  
 }  
   
 Widget::~Widget()  
 {  
     delete ui;  
 }   
 void Widget::on_pushButton_clicked()  
 {  
     totalSize = 0;  
     byteReceived = 0;  
   
     server = new QTcpServer(this);  
     server->listen(QHostAddress("192.168.1.137"), 1000);  
   
     connect(server, SIGNAL(newConnection()), this, SLOT(acceptConnection()));  
   
     ui->receivedProgressBar->setValue(0);  
     ui->receivedStatusLabel->setText(tr("开始监听..."));  
 } 
 
  
  
 

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/笔触狂放9/article/detail/305149?site