Qt Загрузка файлов из QThread на основе примера Qt не работает

Привет, я создаю простой пример с чередованием всего нерелевантного кода, и в целом остается только проблемный код. У меня есть приложение, которое выполняет поток, и внутри этого работника потока я разместил код загрузки, который должен загрузить более 30 файлов, это основано на примере загрузки. Qt дает , проблема в том, что слот QNetworkAccessManager никогда не вызывается.
не могли бы вы сказать мне, что я здесь делаю неправильно?

class MainWindowContainer : public QMainWindow 
{
    Q_OBJECT

public:
    MainWindowContainer(QWidget *parent = 0);


 public slots:
    void InvokeDownloadThread();

 private:
    QPushButton *pushButtonInvokeThread;
    PhotosDownloadWorker* pm_hotosDownloadWorker;
  };

#include <QtGui>
#include "MainWindowContainer.h"

MainWindowContainer::MainWindowContainer(QWidget* parent) : 
                                    QMainWindow(parent) 
{
    pushButtonInvokeThread  = new QPushButton(this); 
    QHBoxLayout *layout = new QHBoxLayout;
    layout->addWidget(pushButtonInvokeThread);
    setLayout(layout);
    QObject::connect(pushButtonInvokeThread,SIGNAL(clicked()),this, SLOT(InvokeDownloadThread()));

}
void MainWindowContainer::InvokeDownloadThread()
{
     pm_hotosDownloadWorker = new PhotosDownloadWorker(this);
     pm_hotosDownloadWorker->Execute();
}

class PhotosDownloadWorker : public QThread 
{
    Q_OBJECT

 public :
    PhotosDownloadWorker(QObject *parent);
    ~PhotosDownloadWorker();
    void  Execute();
    void append(const QStringList &urlList);
    bool saveToDisk(const QString &filename, QIODevice *data);
    QString saveFileName(const QUrl &url);

 protected:
    void run();

private:
    bool m_abort;
     QList<QNetworkReply *> currentDownloads;
     QFile output;
     QNetworkAccessManager* networkMgr ;  

  public slots:
     void downloadFinished(QNetworkReply *reply);
     void startNextDownload(const QUrl &url);



};

#include "PhotosDownloadWorker.h"
PhotosDownloadWorker::PhotosDownloadWorker(QObject *parent)
    : QThread(parent)
{
    m_abort = false;
    networkMgr = new QNetworkAccessManager(this);
    connect(networkMgr, SIGNAL(finished(QNetworkReply*)), this, SLOT(downloadFinished(QNetworkReply*)));
 }

 PhotosDownloadWorker::~PhotosDownloadWorker()
{
   m_abort = true; 
    wait();
}

void PhotosDownloadWorker::Execute()
{
    m_abort = false;
    start();
}
void PhotosDownloadWorker::run()
{
    QStringList m_urlList;

    m_urlList.append("http://....xxxx......jpg");
    m_urlList.append("http://....xxxx......jpg");
    m_urlList.append("http://....xxxx......jpg");
    m_urlList.append("http://....xxxx......jpg");
    m_urlList.append("http://....xxxx......jpg");
    m_urlList.append("http://....xxxx......jpg");
    m_urlList.append("http://....xxxx......jpg");
    m_urlList.append("http://....xxxx......jpg");
    m_urlList.append("http://....xxxx......jpg");
    m_urlList.append("http://....xxxx......jpg");
    m_urlList.append("http://....xxxx......jpg");
    m_urlList.append("http://....xxxx......jpg");
    m_urlList.append("http://....xxxx......jpg");

    // x 30 
    append(m_urlList);
}


void PhotosDownloadWorker::append(const QStringList &urlList)
{
    foreach (QString url, urlList)
    {
         startNextDownload(QUrl::fromEncoded(url.toLocal8Bit()));
    }
 }

void PhotosDownloadWorker::startNextDownload(const QUrl &url)
{
    QNetworkRequest request(url);
    QNetworkReply *reply = networkMgr->get(request);
    currentDownloads.append(reply);
}
 bool PhotosDownloadWorker::saveToDisk(const QString &filename, QIODevice *data)
{
    QFile file(filename);
    if (!file.open(QIODevice::WriteOnly)) {
        fprintf(stderr, "Could not open %s for writing: %s\n",
                qPrintable(filename),
                qPrintable(file.errorString()));
        return false;
    }

    file.write(data->readAll());
    file.close();

    return true;
}

void PhotosDownloadWorker::downloadFinished(QNetworkReply *reply)
{
    QUrl url = reply->url();
    if (reply->error()) {
        fprintf(stderr, "Download of %s failed: %s\n",
                url.toEncoded().constData(),
                qPrintable(reply->errorString()));
    } else {
        QString filename = saveFileName(url);
        if (saveToDisk(filename, reply))
            printf("Download of %s succeeded (saved to %s)\n",
                   url.toEncoded().constData(), qPrintable(filename));
    }

     reply->deleteLater();
     currentDownloads.removeAll(reply);
     if (currentDownloads.isEmpty())
     {

         this->exit();
     }

}
 QString PhotosDownloadWorker::saveFileName(const QUrl &url)
{
    QString path = url.path();
    QString basename = QFileInfo(path).fileName();

    if (basename.isEmpty())
        basename = "download";

    if (QFile::exists(basename)) {
        // already exists, don't overwrite
        int i = 0;
        basename += '.';
        while (QFile::exists(basename + QString::number(i)))
            ++i;

        basename += QString::number(i);
    }

    return basename;
}

//main

#include "MainWindowContainer.h"

 int main(int argc, char *argv[])
 {

     QApplication app(argc, argv);
     MainWindowContainer mainWindowContainer;
     mainWindowContainer.show();
     return app.exec();
 }

person user63898    schedule 13.04.2011    source источник
comment
Какой пример вы использовали? Можете ли вы указать нам онлайн-ссылку?   -  person Derick Schoonbee    schedule 13.04.2011


Ответы (2)


Несмотря на то, что вы вызываете «networkMgr->get(request)» в своем коде, ваш поток, вероятно, завершается до того, как начнется фактическая загрузка. Попробуйте поместить вызов "exec()" в самый низ вашего метода "QThread::run()", чтобы войти в цикл событий в вашем потоке, который требуется для работы QNetworkAccessManager. Кроме того, это предотвратит преждевременное завершение потока. Ваш код будет выглядеть так:

void PhotosDownloadWorker::run()
{
  QStringList m_urlList;

  m_urlList.append("http://....xxxx......jpg");
  m_urlList.append("http://....xxxx......jpg");    
  // x 30 
  append(m_urlList);

  exec();
}
person Barbaris    schedule 13.04.2011
comment
да, это ответ, спасибо, последний вопрос .. как я могу завершить поток, как лучше всего после вызова exec()? - person user63898; 13.04.2011
comment
Вы можете использовать QThread::quit() или QThread::exit(). С последним вы можете передать код результата для возврата из вашего вызова QThread::exec(). Обычно я использую QThread::quit(). Таким образом, вы даже можете подключить сигнал завершения загрузки (finished()) к слоту QThread::quit(). - person Barbaris; 14.04.2011
comment
можешь привести пример я не понял - person user63898; 14.04.2011
comment
когда я помещаю this-›quit в currentDownloads.isEmpty(), он никогда туда не попадает. - person user63898; 14.04.2011
comment
Не уверен, что вы имеете в виду. Вы можете объяснить ? - person Barbaris; 14.04.2011

Я думаю, что он даже не подключит сигнал к слоту, если списки параметров не совпадают. См. вывод отладчика для предупреждения об этом во время выполнения (вкладка вывода приложения).

Итак, вместо

connect(networkMgr, SIGNAL(readyRead()), this, SLOT(downloadFinished(QNetworkReply*)));

do

connect(networkMgr, SIGNAL(finished(QNetworkReply*)), this, SLOT(downloadFinished(QNetworkReply*)));

Обработка ошибок осуществляется с помощью error сигнала QNetworkReply. Сразу после того, как вы get сможете подключиться к сигналу.

person Tamás Szelei    schedule 13.04.2011