使用QFtp rawcommand存储上传到服务器

Question

#include "client.h"
#include <QDebug>
#include <QNetworkAccessManager>
#include <QFileInfo>
QString ConvertSize(qint64 size){
QString output("0 Bytes");
if(size<1024){
output=QString::number(size)+" Bytes";
return output;
}else if(size>1024 && size <1048576){
double newNumber=size/1024.0;
output=QString::number(newNumber)+" KBs";
return output;
}else if(size >1048576){
double newNumber=size/1048576.0;
output=QString::number(newNumber)+" MBs";
return output;
}else if(size >1073741824){
double newNumber=size/1073741824.0;
output=QString::number(newNumber)+" GBs";
return output;
}else{
return output;
}
}
Client::Client(QObject *parent)
: QObject{parent}
{
qInfo()<<this<<"constructed on: "<<QThread::currentThread();
connect(&ftp,&QFtp::commandStarted,this,&Client::commandStarted);
connect(&ftp,&QFtp::commandFinished,this,&Client::commandFinished);
connect(&ftp,&QFtp::dataTransferProgress,this,&Client::dataProgress);
connect(&ftp,&QFtp::done,this,&Client::done);
connect(&ftp,&QFtp::listInfo,this,&Client::listInfo);
connect(&ftp,&QFtp::stateChanged,this,&Client::stateChanged);
connect(&ftp,&QFtp::rawCommandReply,this,&Client::rawCommandReply);

}
Client::~Client()
{
qInfo()<<this<<"deConstructed on: "<<QThread::currentThread();
}
void Client::connectToHost(QString ip, quint16 port)
{
qInfo()<<"connecting to    "<<ip<<":"<<port;
ftp.connectToHost(ip,port);
qInfo()<<"loging in";
ftp.login("testuser","123456");
}
void Client::commandStarted(int id)
{
//qInfo()<<"command start:"<<id;
quint8  command=ftp.currentCommand();
switch (command){
case 0:qInfo()<<"command start: "<<"None";break;
case 1:qInfo()<<"command start: "<<"SetTransferMode";break;
case 2:qInfo()<<"command start: "<<"SetProxy";break;
case 3:qInfo()<<"command start: "<<"ConnectToHost";break;
case 4:qInfo()<<"command start: "<<"Login";break;
case 5:qInfo()<<"command start: "<<"Close";break;
case 6:qInfo()<<"command start: "<<"List";break;
case 7:qInfo()<<"command start: "<<"Cd";break;
case 8:qInfo()<<"command start: "<<"Get";break;
case 9:qInfo()<<"command start: "<<"Put";break;
case 10:qInfo()<<"command start: "<<"Remove";break;
case 11:qInfo()<<"command start: "<<"Mkdir";break;
case 12:qInfo()<<"command start: "<<"Rmdir";break;
case 13:qInfo()<<"command start: "<<"Rename";break;
case 14:qInfo()<<"command start: "<<"RawCommand";break;
}
}
void Client::commandFinished(int id)
{
qInfo()<<"command finished: "<<id;
if(ftp.error()){
qInfo()<<ftp.errorString();
}else{
qInfo()<<"no error";
}
if(ftp.currentCommand()==9){
myfile->flush();
myfile->close();
myfile->deleteLater();
myfile=NULL;
qInfo()<<"put command ended.closing open file.";
}
}
void Client::rawCommandReply(int code, QString detail)
{

qInfo()<<"reply code: "<<code<<"detail: "<<detail;
if (code==226){
qInfo()<<"transmission ended";
}
if (code==150){
qInfo()<<"serverReady";
dataChanel();
}
if(code==227){
QString ip1=detail.split("(")[1];
QString ip2=ip1.split(")")[0];
qInfo()<<ip2;
QStringList data=ip2.split(",");
QStringList ip;
QStringList ports;
for (int i=0;i<data.size();i++){
if(i<4){
ip.append(data[i]);
}else {
ports.append(data[i]);
}
}
qInfo()<<"ip:"<<ip.join(".");
IpPorts.append(ip.join("."));
qInfo()<<"port:"<<ports.join("-");
for(int i=0;i<ports.size();i++){

IpPorts.append(ports[i]);
}
}
}
void Client::dataProgress(quint64 now, quint64 all)
{
qInfo()<<"now:t"<<ConvertSize(now)<<"t from:t"<<ConvertSize(all);
}
void Client::done(bool error)
{
if (error){
qInfo()<<"error occured when done:"<<ftp.errorString();
}
//ftp.close();
qInfo()<<"ftp connection closed";

}
void Client::listInfo(const QUrlInfo &i)
{
qInfo()<<"dir found:"<<i.name();
}
void Client::stateChanged(int state)
{
switch(state){
case 0:qInfo()<<"state changed: "<<"Unconnected";break;
case 1:qInfo()<<"state changed: "<<"HostLookup";break;
case 2:qInfo()<<"state changed: "<<"Connecting";break;
case 3:qInfo()<<"state changed: "<<"Connected";break;
case 4:qInfo()<<"state changed: "<<"LoggedIn";break;
case 5:qInfo()<<"state changed: "<<"Closing";break;
}
}

void Client::abort()
{
ftp.abort();
qInfo()<<"ftp connection aborted";
}
void Client::ended()
{
qInfo()<<"ftp connection ended";
}
void Client::upload(QString &location)
{
myfile=new QFile(location);
if(myfile->open(QIODevice::ReadOnly)){
ftp.rawCommand("PASV");
ftp.rawCommand("TYPE I");
QFileInfo fileinfo(myfile->fileName());
qInfo()<<"size: "<<fileinfo.size();
qInfo()<<"name: "<<fileinfo.fileName();
qInfo()<<"uploading : "<<location;
//qInfo()<<"file name is:"<<myfile->fileName();
//ftp.put(myfile,fileinfo.fileName());
QString text="STOR "+fileinfo.fileName();
qInfo()<<text;
ftp.rawCommand(text);
//client.rawCommand("PASV");
//client.rawCommand("TYPE I");
//client.rawCommand("STAT");
//client.rawCommand("STOR test.txt");
}

}
void Client::list(QString &dir)
{
qInfo()<<"listing dir:"<<dir;
ftp.list(dir);
}
void Client::dataChanel()
{
for(int i=0;i<IpPorts.size();i++){
qInfo()<<IpPorts[i];
}
QTcpSocket* socket=new QTcpSocket(this);
socket->connectToHost(IpPorts[0],IpPorts[1].toInt());
QByteArray data;
data=myfile->readAll();
socket->waitForConnected();
socket->write(data);
}

我需要上传文件到服务器，并使其可恢复，我需要用户的原始命令和REST。

我使用QFtp原始命令存储，当它返回代码227时，我解析数据并获得ip和打开端口，然后当我收到代码150时，我打开tcp端口作为数据套接字发送数据，但几秒钟后它返回错误"数据通道超时。rn Win32错误:网络连接被本地系统终止。"我哪里做错了?我该如何使用这个命令?

Answer 1

所以我正在阅读它，某处说使用PASV不聪明，而是使用EPSV打开端口。我像这样改变了我的代码，并解析了新的端口，并将本地FTP服务器的用户权限更改为所有用户，它工作了!

myfile=new QFile(location);
if(myfile->open(QIODevice::ReadOnly)){
ftp.setTransferMode(QFtp::TransferMode::Passive);
ftp.rawCommand("TYPE I");
ftp.rawCommand("EPSV");
ftp.rawCommand("STAT");
QFileInfo fileinfo(myfile->fileName());
qInfo()<<"size: "<<fileinfo.size();
qInfo()<<"name: "<<fileinfo.fileName();
qInfo()<<"uploading : "<<location;
qInfo()<<"file name is:"<<myfile->fileName();
ftp.rawCommand("REST 1000");
ftp.rawCommand("PWD");
QString text="STOR "+fileinfo.fileName();
qInfo()<<text;
ftp.rawCommand(text);