class FileSend : public QWidget
{
? ? Q_OBJECT
?
public:
? ? explicit FileSend(QWidget *parent = nullptr);
? ? ~FileSend();
private slots:
? ? void on_selectBt_clicked();
? ? void on_sendBt_clicked();
? ? void send_file_head();
? ? void send_file_text();
private:
? ? Ui::FileSend *ui;
? ? QTcpSocket msocket;
? ? QFile file;
? ? QString filename;
? ? quint64 filesize;
? ? quint64 sendsize;
};

#include "filesend.h"
#include "ui_filesend.h"
#include <QFileDialog>
#include <QFileInfo>
#include <QDataStream>
?
FileSend::FileSend(QWidget *parent) :
? ? QWidget(parent),
? ? ui(new Ui::FileSend)
{
? ? ui->setupUi(this);
? ? //當(dāng)客戶端連接成功會發(fā)送connected信號， 當(dāng)客戶端掉線會發(fā)送disconnected信號
? ? connect(&msocket, &QTcpSocket::connected, this, &FileSend::send_file_head);
?
? ? //當(dāng)套接字發(fā)送完畢會發(fā)送一個信號bytesWritten
? ? connect(&msocket, &QTcpSocket::bytesWritten, this, &FileSend::send_file_text);
?
}
?
FileSend::~FileSend()
{
? ? delete ui;
}
?
void FileSend::on_selectBt_clicked()
{
? ? //通過文件對話框獲取文件路徑
? ? QString filepath = QFileDialog::getOpenFileName(this);
? ? ui->fileEdit->setText(filepath);
}
?
void FileSend::on_sendBt_clicked()
{
? ? //連接服務(wù)器
? ? msocket.connectToHost(ui->ipedit->text(), ui->portedit->text().toUShort());
?
? ? //發(fā)送文件信息
? ? qDebug()<<"connect";
?
? ? //初始化
? ? filesize = 0;
? ? sendsize = 0;
}
?
//發(fā)送文件頭信息
void FileSend::send_file_head()
{
? ? //發(fā)送文件名，文件大小
? ? QFileInfo info(ui->fileEdit->text());//文件信息對象
? ? filename = info.fileName();
? ? filesize = info.size();
?
? ? QByteArray array; //空間
? ? //把array與數(shù)據(jù)流綁定
? ? QDataStream stream(&array, QIODevice::WriteOnly);
? ? stream<<filesize<<filename;
?
? ? //設(shè)置進度條最大值
? ? ui->progressBar->setMaximum(filesize);
?
? ? //打開文件準(zhǔn)備讀取數(shù)據(jù)發(fā)送
? ? file.setFileName(ui->fileEdit->text());
? ? file.open(QIODevice::ReadOnly);
?
? ? //發(fā)送
? ? msocket.write(array);
}
?
void FileSend::send_file_text()
{
? ? if(sendsize < filesize)
? ? {
? ? ? ? QByteArray array = file.read(1024*10);//讀取一段內(nèi)容
? ? ? ? msocket.write(array);//發(fā)送一段內(nèi)容
? ? ? ? sendsize += array.size();
? ? ? ? //設(shè)置進度條
? ? ? ? ui->progressBar->setValue(sendsize);
? ? }
? ? if(sendsize == filesize)
? ? {
? ? ? ? file.close();//關(guān)閉文件
? ? }
}

#ifndef FILERECV_H
#define FILERECV_H
?
#include <QWidget>
#include <QTcpServer>
#include <QTcpSocket>
#include <QFile>
?
namespace Ui {
class FileRecv;
}
?
class FileRecv : public QWidget
{
? ? Q_OBJECT
?
public:
? ? explicit FileRecv(QWidget *parent = nullptr);
? ? ~FileRecv();
protected slots:
? ? void read_data();
? ? void new_client();
private:
? ? Ui::FileRecv *ui;
? ? QTcpServer mserver;
? ? QFile file;
? ? QString filename;
? ? quint64 filesize;
? ? quint64 recvsize;
};
?
#endif // FILERECV_H

#include "filerecv.h"
#include "ui_filerecv.h"
#include <QDataStream>
FileRecv::FileRecv(QWidget *parent) :
? ? QWidget(parent),
? ? ui(new Ui::FileRecv)
{
? ? ui->setupUi(this);
? ? //關(guān)聯(lián)客戶端連接信號
? ? connect(&mserver, &QTcpServer::newConnection, this, &FileRecv::new_client);
? ? //啟動服務(wù)器
? ? mserver.listen(QHostAddress::Any,8080);
}
?
FileRecv::~FileRecv()
{
? ? delete ui;
}
void FileRecv::new_client()
{
? ? //創(chuàng)建與客戶端通信的套接字
? ? QTcpSocket *msocket = mserver.nextPendingConnection();
? ? //關(guān)聯(lián)讀數(shù)據(jù)信號readyRead
? ? connect(msocket, &QTcpSocket::readyRead, this, &FileRecv::read_data);
? ? filesize = 0;
? ? recvsize = 0;
}
?
void FileRecv::read_data()
{
? ? QTcpSocket *msocket = dynamic_cast<QTcpSocket*>(sender());
? ? if(filesize == 0) //表達第一次讀取數(shù)據(jù)--讀文件信息
? ? {
? ? ? ? QByteArray array = msocket->readAll();
? ? ? ? QDataStream stream(&array, QIODevice::ReadOnly);//把套接字與數(shù)據(jù)流綁定
? ? ? ? stream>>filesize>>filename;//獲取文件大小， 文件名
?
? ? ? ? //設(shè)置進度條最大值
? ? ? ? ui->progressBar->setMaximum(filesize);
?
? ? ? ? //打開文件
? ? ? ? file.setFileName(filename);
? ? ? ? file.open(QIODevice::WriteOnly);
?
? ? ? ? //顯示進度條
? ? ? ? this->show();
? ? }
?
? ? //讀文件內(nèi)容
? ? if(recvsize < ?filesize)
? ? {
? ? ? ? //讀取一段寫一段
? ? ? ? QByteArray array = msocket->readAll();
? ? ? ? file.write(array);
? ? ? ? recvsize += array.size();
? ? ? ? //更新進度條
? ? ? ? ui->progressBar->setValue(recvsize);
? ? }
?
? ? if(recvsize == filesize)
? ? {
? ? ? ? //讀完，關(guān)閉文件
? ? ? ? file.close();
? ? ? ? //關(guān)閉套接字
? ? ? ? msocket->disconnectFromHost();
? ? ? ? //隱藏進度條
? ? ? ? this->hide();
? ? }
}