基本信息

---

下载

   友情提示：（无需注册或充值，赞助后即可获取资源下载链接）

---

     嘿，亲！知识可是无价之宝呢，但咱这精心整理的资料也耗费了不少心血呀。小小地破费一下，绝对物超所值哦！如有下载和支付问题，请联系我们QQ(微信同号)：813200300

本次赞助数额为： 10 元　

支付宝支付

微信支付

   源码介绍

---

Qt下的TCP文件传输，支持发送大文件。

#pragma execution_character_set("utf-8")
#ifndef SENDFILECLIENT_H
#define SENDFILECLIENT_H

#include <QTcpSocket>

class SendFileClient : public QTcpSocket
{
    Q_OBJECT
public:
    explicit SendFileClient(QObject *parent = 0);
    ~SendFileClient();

    void SendFile(QString fileName, QString serverIP, int serverPort);

signals:
    void fileSize(qint64 size);
    void message(QString msg);

private slots:
    void SendData();
    void displaySocketError(QAbstractSocket::SocketError);

private:
    QString fileName;

};

#endif // SENDFILECLIENT_H

#include "sendfileclient.h"
#include "myhelper.h"

SendFileClient::SendFileClient(QObject *parent) : QTcpSocket(parent)
{
    connect(this, SIGNAL(connected()), this, SLOT(SendData()));
    connect(this, SIGNAL(error(QAbstractSocket::SocketError)),
            this, SLOT(displaySocketError(QAbstractSocket::SocketError)));
}

SendFileClient::~SendFileClient()
{

}

void SendFileClient::SendFile(QString fileName, QString serverIP, int serverPort)
{
    this->fileName = fileName;
    connectToHost(serverIP, serverPort);
}

void SendFileClient::SendData()
{
    emit message("与服务器建立连接成功");
    QFile file(fileName);
    if(!file.open(QIODevice::ReadOnly)) {
        emit message("文件不能打开进行读取");
        disconnectFromHost();
        return;
    } else {
        emit fileSize(file.size());
    }

    qint64 size;
    QByteArray block;
    QDataStream out(&block, QIODevice::WriteOnly);
    out.setVersion(QDataStream::Qt_5_5);
    QString name = myHelper::GetFileNameWithExtension(fileName);

    //写入开始符及文件名称
    emit message("发送开始符及文件名称");
    block.clear();
    out.device()->seek(0);
    out << 0x01 << name.toUtf8();
    size = block.size();
    write((char *)&size, sizeof(qint64));
    write(block.data(), size);

    if(!waitForBytesWritten(-1)) {
        emit message(QString("发送开始符数据发生错误:%1").arg(errorString()));
        disconnectFromHost();
        return;
    }

    //写入文件大小
    emit message("发送文件大小");
    block.clear();
    out.device()->seek(0);
    out << 0x02 << QString::number(file.size()).toUtf8();
    size = block.size();
    write((char *)&size, sizeof(qint64));
    write(block.data(), size);

    if(!waitForBytesWritten(-1)) {
        emit message(QString("发送文件大小数据发生错误:%1").arg(errorString()));
        disconnectFromHost();
        return;
    }

    //循环写入文件数据
    do {
        block.clear();
        out.device()->seek(0);
        //每次最多读取0xFFFF 即65535个字节发送,对于大文件如果一次性读取完内存不一定吃得消
        //每次发送的文件数据都带上一个0x02标识符
        out << 0x03 << file.read(0xFFFF);
        size = block.size();
        emit message(QString("当前发送数据大小:%1字节").arg(size));
        write((char *)&size, sizeof(qint64));
        write(block.data(), size);
        if(!waitForBytesWritten(-1)) {
            emit message(QString("发送文件数据发生错误:%1").arg(errorString()));
            disconnectFromHost();
            return;
        }
    } while(!file.atEnd());

    //写入结束符及文件名称
    emit message("发送结束符及文件名称");
    block.clear();
    out.device()->seek(0);
    out << 0x04 << name.toUtf8() ;
    size = block.size();
    write((char *)&size, sizeof(qint64));
    write(block.data(), size);

    if(!waitForBytesWritten(-1)) {
        emit message(QString("发送结束符数据发生错误:%1").arg(errorString()));
        disconnectFromHost();
        return;
    }

    emit message("发送文件完毕,等待服务器断开连接");
    waitForDisconnected();
    emit message("客户端主动断开连接");
    disconnectFromHost();
}

void SendFileClient::displaySocketError(QAbstractSocket::SocketError )
{
    emit message(QString("发生错误:%1").arg(errorString()));
}

#pragma execution_character_set("utf-8")
#ifndef RECEIVEFILETHREAD_H
#define RECEIVEFILETHREAD_H

#include <QThread>
#include <QTcpSocket>
#include <QFile>

class ReceiveFileThread : public QThread
{
    Q_OBJECT
public:
    explicit ReceiveFileThread(int socketDescriptor, QObject *parent = 0);
    ~ReceiveFileThread();

    void proccessData(QByteArray &array);

protected:
    void run();

signals:
    void receiveFileName(QString name);
    void receiveFileSize(qint64 size);
    void message(QString msg);
    void receiveData(qint64 size);

private slots:
    void ReceiveData();
    void DisConnect();
    void displaySocketError(QAbstractSocket::SocketError);

private:
    QFile file;
    QString fileName;
    QTcpSocket *s;
    qint64 blockSize;
    qint64 blockNumber;

};

#endif // RECEIVEFILETHREAD_H

#include "receivefilethread.h"
#include "myhelper.h"

ReceiveFileThread::ReceiveFileThread(int socketDescriptor, QObject *parent) :
    QThread(parent)
{
    blockSize = 0;
    blockNumber  = 0;
    s = new QTcpSocket(this);
    s->setSocketDescriptor(socketDescriptor);
    connect(s, SIGNAL(readyRead()), this, SLOT(ReceiveData()));
    connect(s, SIGNAL(disconnected()), this, SLOT(DisConnect()));
    connect(s, SIGNAL(error(QAbstractSocket::SocketError)),
            this, SLOT(displaySocketError(QAbstractSocket::SocketError)));
}

ReceiveFileThread::~ReceiveFileThread()
{

}

void ReceiveFileThread::proccessData(QByteArray &array)
{
    QDataStream in(&array, QIODevice::ReadOnly);
    in.setVersion(QDataStream::Qt_5_5);

    int key;
    QByteArray data;
    in >> key >> data;
    blockNumber ;

    emit message(QString("已接收数据包:%1个").arg( blockNumber));
    emit message(QString("收到标识符:%1 当前数据包大小:%2字节").arg(key).arg(data.size()));

    switch(key) {
    case 0x01:
        fileName = fileName.fromUtf8(data.data(), data.size());
        file.setFileName(qApp->applicationDirPath() "/" fileName);
        emit receiveFileName(file.fileName());
        if(file.exists()) {
            file.remove();
        }
        if(!file.open(QIODevice::WriteOnly)) {
            emit message("不能打开文件进行写入");
            break;
        }
        break;
    case 0x02: {
        QString size = QString::fromUtf8(data.data(), data.size());
        emit receiveFileSize(size.toUInt());
        break;
    }
    case 0x03:
        file.write(data.data(), data.size());
        file.flush();
        break;
    case 0x04:
        file.close();
        s->disconnectFromHost();
        break;
    }
}

void ReceiveFileThread::run()
{
    emit message(QString("收到新连接请求 IP:%1[%2]")
                 .arg(s->peerAddress().toString())
                 .arg(s->peerPort()));
    exec();
}

void ReceiveFileThread::DisConnect()
{
    exit(0);
}

void ReceiveFileThread::ReceiveData()
{
    while(s->bytesAvailable() >= sizeof(quint64)) {
        if(blockSize == 0) {
            if(s->bytesAvailable() < sizeof(qint64)) {
                return;
            }
            s->read((char *)&blockSize, sizeof(qint64));
        }
        if(s->bytesAvailable() < blockSize) {
            return;
        }
        emit receiveData(blockSize sizeof(qint64));
        QByteArray data = s->read(blockSize);
        proccessData(data);
        blockSize = 0;
    }
}

void ReceiveFileThread::displaySocketError(QAbstractSocket::SocketError)
{
    emit message(QString("接收文件遇到错误:%1[%2]").arg(s->errorString()));
    emit message(QString("正在移除文件:%1").arg(file.fileName()));
    if(file.isOpen()) {
        file.close();
    } else {
        return;
    }
    if(!file.fileName().isEmpty()) {
        file.remove(fileName);
    } else {
        return;
    }
}