实例介绍
【实例简介】
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;
}
}
相关软件
小贴士
感谢您为本站写下的评论，您的评论对其它用户来说具有重要的参考价值，所以请认真填写。
- 类似“顶”、“沙发”之类没有营养的文字，对勤劳贡献的楼主来说是令人沮丧的反馈信息。
- 相信您也不想看到一排文字/表情墙，所以请不要反馈意义不大的重复字符，也请尽量不要纯表情的回复。
- 提问之前请再仔细看一遍楼主的说明，或许是您遗漏了。
- 请勿到处挖坑绊人、招贴广告。既占空间让人厌烦，又没人会搭理，于人于己都无利。
关于好例子网
本站旨在为广大IT学习爱好者提供一个非营利性互相学习交流分享平台。本站所有资源都可以被免费获取学习研究。本站资源来自网友分享，对搜索内容的合法性不具有预见性、识别性、控制性，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，平台无法对用户传输的作品、信息、内容的权属或合法性、安全性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论平台是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二与二十三条之规定，若资源存在侵权或相关问题请联系本站客服人员，点此联系我们。关于更多版权及免责申明参见 版权及免责申明
网友评论
我要评论