QFTP 命令完成发送得太早

Question

QT 版本 5.4。

我正在尝试使用 QFtp 从特定目录下载所有文件。

有时信号命令 Done（int， bool） 发送得太早。

我使用信号 dataTransferProgress（qint64， qint64） 来检查我的下载进度。

当它工作时，我有一个输出，例如：

Download 1
dataTransferProgress 0/150
dataTransferProgress 150/150
commandFinished
Dowload 2
dataTransferProgress 0/250
dataTransferProgress 250/250
commandFinished

我的文件还可以

当它不起作用时，我有：

Download 1
dataTransferProgress 0/150
commandFinished
Dowload 2
150/150
0/250
commandFinished

文件 1 为空。文件 2 包含文件 1 的数据。

我的 FTP 对象

class ActionFTP : public QFtp
{
Q_OBJECT
public:

ParamConnexion parametres;
QString FTP_export="exportX3_OFT/";
QString FTP_import="exportOFT_X3/";
QString FTP_historique="historique/";
QString OFT_export;
QString OFT_import;
QString OFT_historique;
QString ficConfig;
QFile *file;
QSettings *settings;
ActionFTP(QObject *parent = 0, QString fichierConfig = "config.ini", int detail = 0);
~ActionFTP();
bool recupFichier_X3_OFT(const QString&); // Function to download the File
bool ftpestdeconnecte(); // Check if my ftp is deconnected
void connecter(); // Connect me to the FTP
void deconnecter(); // Disconnect me from the FTP
void ContenuRepertoireFTP(); // List all the files in the FTP directory
bool getCommandEnCours(){return commandEnCours;} // Check if a command is already running
QList<QUrlInfo> getListePrete(){return listeFichiers;} // Return if the list of the 
bool commandEnCours;
private :
int idEnCours;
QList<QUrlInfo> listeFichiers;
private slots:
void slot_append(QString info); // Get some informations
void ftpCommandFinished(int id, bool err);
void ftpCommandStarted(int id);
void remplirList(QUrlInfo);
void ftpdatatransferprogress(qint64, qint64);
signals :
void signal_connexionFaite(bool); // Send when I'm connected
void signal_deconnexionFaite(bool); // Send when I'm disconnected
void signal_append(QString infos); // Send some informations
void signal_listePrete(bool); // List ready 
void fintransfertfichierrecup(); // When the get command is finished.
};
#endif // ACTIONFTP_H

。.cpp

// I use a QSettings to get the different Path and the FTP Username/Login/Port/Host/TransferMode
ActionFTP::ActionFTP(QObject *parent, QString fichierConfig, int detail ) : QFtp(parent)
{
    settings = new QSettings(fichierConfig, QSettings::IniFormat);
    OFT_export=settings->value("Echange/DossierOFT").toString();
    OFT_import=settings->value("Echange/DossierX3").toString();
    OFT_historique=settings->value("Echange/DossierHistorique").toString();
    connect(this, SIGNAL(signal_append(QString)),this,SLOT(slot_append(QString)));
    connect(this, SIGNAL(commandFinished(int, bool)),this, SLOT(ftpCommandFinished(int, bool)));
    connect(this,SIGNAL(commandStarted(int)), this, SLOT(ftpCommandStarted(int)));
    connect(this, SIGNAL(listInfo(QUrlInfo)), this, SLOT(remplirList(QUrlInfo)));
    connect(this, SIGNAL(dataTransferProgress(qint64,qint64)), this, SLOT(ftpdatatransferprogress(qint64, qint64)));
    ficConfig=fichierConfig;
    majParametres();
}


void ActionFTP::ftpdatatransferprogress(qint64 un, qint64 deux){
    qDebug()<<un<<deux;
}
ActionFTP::~ActionFTP()
{
}
bool ActionFTP::recupFichier_X3_OFT(const QString &fichier){
    if(commandEnCours){ // A command is already running
        QString infos = "Une commande est déjà en cours.";
        emit signal_append(infos);
    }
    else{
     file = new QFile(OFT_import+fichier);
     if(file->exists())file->remove();
     QString infos = "Demande de r�cup�ration du fichier " + FTP_export+fichier;
     emit signal_append(infos);
     qDebug()<<"return de file->open "<<file->open(QIODevice::ReadWrite); // Always return TRUE
     get(FTP_export+fichier, file, Binary); // Get command
    }
    return true;
}

void ActionFTP::slot_append(QString info){
    qDebug()<<info;
}
bool ActionFTP::ftpestdeconnecte()
{
    if (state()==QFtp::Unconnected)
        return true;
    return false;
}

void ActionFTP::connecter() {
        setTransferMode((QFtp::TransferMode)parametres.TransfertMode);
        if(!commandEnCours)
            connectToHost(parametres.Hostname, parametres.Port);
        else{
            QString infos = "Une commande est déjà en cours.";
            emit signal_append(infos);
        }
}
void ActionFTP::deconnecter() {
    if(commandEnCours){
        QString infos = "Une commande est déjà en cours.";
        emit signal_append(infos);
    }
    else{
     close();
    }
}
void ActionFTP::remplirList(QUrlInfo t){
    listeFichiers.push_back(t);
}
void ActionFTP::ContenuRepertoireFTP(){ //Ask the list of files name in the directory
    if(commandEnCours){
        QString infos = "Une commande est déjà en cours.";
        emit signal_append(infos);
    }
    else{
        listeFichiers.clear();
        list(FTP_export);
    }
}
void ActionFTP::ftpCommandStarted(int id){
    idEnCours = id;
    commandEnCours=true;
    qDebug()<<"dans commandStarted "<<id;
}
void ActionFTP::ftpCommandFinished(int id, bool err) {
    qDebug()<<"dans ftpCommandFinished"<<id<<err;
    QString infos;
    if(err) {
        infos = QString(" Erreur lors de la commande %i de type %i").arg(id, currentCommand());
        erreurFTP(infos);
    }
    else {
        infos += " OK";
    }
    emit signal_append(infos);
    if(idEnCours==id){
        QString infos;
        switch(currentCommand()) {
        case QFtp::None :
            break;
        case QFtp::SetTransferMode :
            break;
        case QFtp::SetProxy :
            break;
        case QFtp::ConnectToHost :
            if(!err)
                login(parametres.UserName, parametres.Password);
            else
                 emit signal_connexionFaite(err);
            break;
        case QFtp::Login :
            commandEnCours = false;
            emit signal_connexionFaite(err);
            break;
        case QFtp::Close :
            commandEnCours = false; // Signifier qu'il n'y a plus de transfert en cours
            emit signal_deconnexionFaite(err);
            break;
        case QFtp::List :
            commandEnCours=false;
            emit signal_listePrete(err);
            break;
        case QFtp::Cd :
            break;
        case QFtp::Get :
            file->close();
            file = 0;
            commandEnCours = false; // Signifier qu'il n'y a plus de transfert en cours
            emit fintransfertfichierrecup();
            qDebug()<<"signal get emit";
            break;
        case QFtp::Put :
            commandEnCours = false; // Signifier qu'il n'y a plus de transfert en cours
            emit fintransfertfichierenvoi();
            break;
        case QFtp::Remove :
            commandEnCours = false;
            emit fintransfertfichiersuppr();
            break;
        case QFtp::Mkdir :
            break;
        case QFtp::Rmdir :
            break;
        case QFtp::Rename :
            break;
        case QFtp::RawCommand :
            break;
        default :
            infos = "Commande inconnue !!";
        }
        idEnCours = 0;
    }
}

调用我的 FTP 对象的对象

  class TacheEchanges : public QTimer
  {
      Q_OBJECT
  public:
  explicit TacheEchanges(QObject *parent = 0);
  signals:
  public slots:
  private slots:
  virtual void slot_check();
  protected:
  private:
  ActionFTP *ftp; // My FTP object
  QList<QUrlInfo> listDownload; // List of the files name
  int indiceDownload; // Iterator

  private slots:
  void continuerDownload();  // When one file is downloaded
  void connexionFaite(bool); // When I am connected to the FTP
  void listePrete(bool); // When my command list is done
  };
  #endif // TACHEECHANGES_H

。.cpp

TacheEchanges::TacheEchanges(GestionBdD_Hizkia* bdd, QObject *parent)
    : QTimer(parent)
{
        settings =new QSettings(FICHIERCONFIG, QSettings::IniFormat);

try{
        path_fichiersreference="";
        path_poursage="";
        path_historique="";
        jobs = QList<Job>();
        ftp = new ActionFTP(this, FICHIERCONFIG);
        connect(this, SIGNAL(timeout()), this, SLOT(slot_check()));
        connect(ftp,SIGNAL(fintransfertfichierenvoi()),this,SLOT(continuerUpload()));
        connect(ftp, SIGNAL(signal_connexionFaite(bool)), this, SLOT(connexionFaite(bool)));
        connect(ftp, SIGNAL(signal_listePrete(bool)), this, SLOT(listePrete(bool)));

     //Differente path
     path_fichiersreference =settings->value("Echange/DossierX3").toString();
     path_historique =settings->value("Echange/DossierHistorique").toString();
     path_poursage=settings->value("Echange/DossierOFT").toString();
     indiceDownload=0;
  }
        catch(ErreurGeneriqueException &e) {
        desc.message = "TacheEchangesn"+ e.what();
        desc.niveau = NIVEAU_CRITIQUE;
        InterfaceBdD::historiser(desc);
        qDebug() << desc.message;
        }
        catch(...) {
     //   QDebug() << "TacheEchangesn" << e.get_message();

        desc.message = "TacheEchanges ERREUR INCONNUE";
        desc.niveau = NIVEAU_CRITIQUE;
        InterfaceBdD::historiser(desc);
        qDebug() << desc.message;
        }
}
// If i am connected, i try to get the list of files name
void TacheEchanges::connexionFaite(bool err){
    if(err)
        throw new ErreurGeneriqueException("Impossible de se connecter");
    else
        ftp->ContenuRepertoireFTP();
}
void TacheEchanges::slot_check()
{
        ftp->connecter();
}
// I take the list and start the download
void TacheEchanges::listePrete(bool err){ 
    if(!err){
        listDownload = ftp->getListePrete();
        continuerDownload();
    }
    else{
        throw new ErreurBasiqueException("Un problème est survenu lors de la récupération de la liste des fichiers présents sur le FTP.");
    }
}
void TacheEchanges::continuerDownload(){
    if(indiceDownload==listDownload.size()){
        indiceDownload=0;
        continuerSuppression();
        return;
    }
    else{
        ftp->recupFichier_X3_OFT(listDownload.at(indiceDownload).name());
        indiceDownload++;
    }
}

Answer 1

也可以在这里查看主动和被动之间的区别

Answer 2

好的

，当我尝试连接到我使用的FTP时

setTransferMode(QFtp::TransferMode);

我使用了默认值 QFtp：：Active，如果我输入 QFtp：:P assive，它可以工作。