2

ファイルがサーバーに 2 回アップロードされるという問題があります。

Windows XP で C++ Qt の QFileSystemWatcher クラスを使用して、フォルダーが変更されたときにファイルを送信しています。ファイルは小さい (1 ～ 12kb)。

アプリケーションは、フォルダーが変更されるたびに (directoryChanged シグナルで) フォルダーをスキャンしてファイルを送信し、ファイルをループして必要なファイルを送信します。サーバーは、別のアプリケーションが処理するために同じフォルダーに返される xml ファイルで応答します。

どうやら、一部のシステムでは、2 つの非常に高速な directoryChanged シグナルがほぼ同時に発生し、2 つの非常に高速なファイル アップロードが発生しているようです。

サーバーはApacheとPHPを実行しており、PHP側には単純なMUTEXがありますが、Qt側にあると思われる問題の根本に到達したかっただけです. 私は別のクラス、別のライブラリ、またはストレート C++ を使用することにオープンです。

ここにいくつかのコードがあります。無関係なコンテンツをすべて取り除きました。

this->w = new QFileSystemWatcher();
this->w->addPath("C:/POSERA/MaitreD/DATA/INT");

QStringList directoryList = w->directories();
Q_FOREACH(QString directory, directoryList)
{
    qDebug() << "Watching Main Directory name: " << directory << endl;
}

DirectoryWatcher* dw = new DirectoryWatcher;

QObject::connect( this->w, SIGNAL(directoryChanged(const QString&)),
                  dw, SLOT(directoryChanged(const QString&)));

および DirectoryWatcher.cpp:

DirectoryWatcher::DirectoryWatcher(QWidget* parent) : QWidget(parent)
{
    lockSend = false;
}

void DirectoryWatcher::directoryChanged(const QString& str)
{
    directoryLastChanged = str;

    QByteArray byteArray = str.toUtf8();
    const char* cString = byteArray.constData();

    sendChangedFiles(cString);
}

void DirectoryWatcher::sendChangedFiles(const char* path)
{
    DIR *dir;
    struct dirent *ent;
    if ((dir = opendir (path)) != NULL)
    {
        QString str;

        while ((ent = readdir (dir)) != NULL)
        {
            str = QString("%1/%2").arg(path, ent->d_name);

            QFileInfo info(str);

            if (lockSend == false &&
               (info.completeSuffix() == "xml" || info.completeSuffix() == "XML") &&
               (info.baseName() != "") &&
               (!info.baseName().startsWith("REDM")) &&
               (!info.baseName().startsWith("REFT")))
            {
                // reset the counter.
                this->resendCounter = 0;

                sendFileAndAccept(str.toUtf8().constData());
            }
        }
        closedir (dir);
    }
    else
    {
        qDebug() << "Could not open directory" << endl;
    }
}

class QNetworkRequest;
class QNetworkReply;

void DirectoryWatcher::sendFileAndAccept(const char* path)
{
    // increment the resend counter
    this->resendCounter++;

    QFileInfo fileInfo(path);

    QNetworkAccessManager * mgr = new QNetworkAccessManager(this);
    connect(mgr,SIGNAL(finished(QNetworkReply*)),
            this,SLOT(saveResponse(QNetworkReply*)));
    connect(mgr,SIGNAL(finished(QNetworkReply*)),
            mgr,SLOT(deleteLater())); // @todo delete later

    QHttpMultiPart *multiPart = new QHttpMultiPart(QHttpMultiPart::FormDataType);

    QHttpPart filePart;
    filePart.setHeader(QNetworkRequest::ContentTypeHeader, QVariant("text/xml")); // @todo test
    filePart.setHeader(QNetworkRequest::ContentDispositionHeader, QVariant("form-data; name=\"someFile\"; filename=\"" + fileInfo.baseName() + ".xml\""));

    currentFileSent = fileInfo.baseName();

    QFile *file = new QFile(path);
    file->open(QIODevice::ReadOnly);
    filePart.setBodyDevice(file);
    file->setParent(multiPart); // we cannot delete the file now, so delete it with the multiPart

    multiPart->append(filePart);

    // POST request
    QNetworkReply *reply = mgr->post(QNetworkRequest(QUrl(XXXXXX)), multiPart);

    multiPart->setParent(reply); // delete the multiPart with the reply

    // lock
    lockSend = true;
}

void DirectoryWatcher::saveResponse(QNetworkReply *rep) {

    // get the response
    QByteArray bts = rep->readAll();
    QString str(bts);

    // compute new path
    QString partName = currentFileSent.mid(1, currentFileSent.length());
    QString newPath = QString("%1/A%2.xml").arg(directoryLastChanged, partName);

    qDebug() << "new path: " << newPath << endl;

    switch (rep->error()) {
        case QNetworkReply::NoError: {
            qDebug() << "NO ERROR" << endl;

            // save response to a file.

            QFile file(newPath);
            file.open(QIODevice::WriteOnly | QIODevice::Text);
            QTextStream out(&file);
            out << str;

            file.close();

            break;
        }
        default:

//        case QNetworkReply::TimeoutError :
//        case QNetworkReply::HostNotFoundError :
            qDebug() << "NETWORK REPLY ERROR" << endl;
            // resend the file if the counter is < 10
            if (this->resendCounter < 5) {

                // delay by n sec
                QTime dieTime = QTime::currentTime().addSecs(1);
                while( QTime::currentTime() < dieTime )
                    QCoreApplication::processEvents(QEventLoop::AllEvents, 100);

                sendFileAndAccept(this->lastPathSent.toStdString().c_str());
            } else {

                // after 10 attempts, we're probably sure that the network is down
                // save the file somewhere and generate a default one to prevent timeouts.

                qDebug() << "Saving file for later..." << endl;
                if (!saveFileForLater(lastPathSent.toStdString().c_str())) {
                    qDebug() << "ERROR SAVING FILE, CHECK IF FOLDER EXISTS AND THE PERMISSIONS." << endl;
                }

                // generate a default one to prevent timeouts.
                qDebug() << "Generate a default file..." << endl;
                // ...
            }

            break;
    }

    // unlock
    lockSend = false;

    rep->deleteLater(); // prevent memory leak
}

bool DirectoryWatcher::saveFileForLater(const char* pathToRequestFile) {

    QFile file(pathToRequestFile);
    if (!file.open(QIODevice::ReadOnly | QIODevice::Text)) {
        qDebug() << "readonly and text" << endl;
        return false;
    }

    QString path(pathToRequestFile);
    QFileInfo fileinfo(path);

    QString newPath = "C:\\data\\offline\\" + fileinfo.fileName();

    return file.copy(newPath);

}

ご協力いただきありがとうございます。

4

1 に答える 1

2

directoryChanged が 2 回発行される最も考えられる理由は、通常のエディターが変更を保存するときにファイルの新しいバージョンを削除してディスクに書き込むことです。そのため、ファイルが削除されたときに 1 つのシグナルがあり、再作成されたときに 1 つのシグナルがあります。

于 2014-05-20T12:41:22.207 に答える