Http и потоки, Ищу исходники Опции

[bo0blik]

Буду рад если кто-то поделится исходниками на эту тему, очень интересно посмотреть.

[ViGOur]

А что именно интересует?
В том, чтобы самому писать, ничего сложного нет!

[bo0blik]

Я просто из тех людей которые пока не увидят код, ничего не поймут.

Просто интересует распределенная много-поточная отправка http запросов.

[Elfinit]

Вот примерчик. Набор классов для выполнения разных типов запросов с разными параметрами. Примеры использования:
GET:

WebGetRequest *g = new WebGetRequest(QUrl("http://www.google.ru"),"./check_internet.xml");
connect(g,SIGNAL(done(WebReply)),this,SLOT(check_internet_done(WebReply)));
connect(g,SIGNAL(offline()),this,SLOT(internet_offline()));
g->run();

POST:

QFile file("C:/image.jpeg");
file.open(QIODevice::ReadOnly);
QByteArray data = file.readAll();
file.close();
WebPostRequest *p = new WebPostRequest(QUrl("http://send.photo.here.com"),"image/jpeg",data,data.size(),"answer.xml");
connect(p,SIGNAL(done(WebReply)),this,SLOT(send_image_done(WebReply)));
connect(p,SIGNAL(offline()),this,SIGNAL(not_connected()));
p->run();

Заботиться больше ни о чём (в т.ч. об удалении экзепляров) не нужно, в принципе, даже ответ обрабатывать необязательно, т.е. можно сразу после создания объекта вызывать run. Естественно, обработка любого числа запросов будет происходить параллельно. Плюс имеются сигналы разные (download/upload progress, errors, etc.). И пустые слоты, которые можно заполнить на свой вкус)

И ещё - НЕ используй QHttp. Мои классы написаны на основе QNetworkAccessManager

Сообщение отредактировал Elfinit - 1.10.2009, 21:58

Прикрепленные файлы

 pA_Web.zip ( 2,57 килобайт ) Кол-во скачиваний: 144

 

[bo0blik]

Elfinit, спасибо большое, про http я уже досконально изучил, просто интересно как это правильней всего с потоками выглядит.

Я посмотрел класс, очень интересный пример.

Если у кого еще есть что-нибудь буду очень благодарен.

[Elfinit]

Elfinit, спасибо большое, про http я уже досконально изучил, просто интересно как это правильней всего с потоками выглядит.

Я посмотрел класс, очень интересный пример.

Если у кого еще есть что-нибудь буду очень благодарен.

Ммм...А зачем вообще париться с потоками в данном случае, за тебя всё библиотека сделает..Главное-инициировать запрос и в нужное время отреагировать на ответ..

[rnd]

сегодня тоже провозился пол-дня. Пытался сделать из асинхронного режима запросов синхронный, для чего пускал qttp в отдельном потоке - так и не удалось победить - вешается зараза в WaitForMultipleObjects

[BRE]

сегодня тоже провозился пол-дня. Пытался сделать из асинхронного режима запросов синхронный, для чего пускал qttp в отдельном потоке - так и не удалось победить - вешается зараза в WaitForMultipleObjects

Как-то связи синхронного режима с отдельным потоком не понял?

Вот набросок кода, думаю идея должна быть понятна:

QByteArray loader()
{
        QHttp http;
        http.setHost( ... );
        http.get( ... );

        while( http.state() != QHttp::Closing )
                QApplication::processEvents();

        return http.readAll();
}

[BRE]

Для того, что бы сделать работу QHttp синхронной, нужно что бы отрабатывали QSocketNotifier. Для этого нужно крутить eventloop (именно там происходят необходимые действия). Предыдущий пример показывал саму идею, "боевой" код я бы сделал примерно таким:

QByteArray loader()
{
        QHttp http;
        QEventLoop loop;
        QObject::connect( &http, SIGNAL( done( bool ) ), &loop, SLOT( quit() ) );

        http.setHost( ... );
        http.get( ... );
        loop.exec();
    // выходим из цикла при получении сигнала QHttp::done

    // Проверили ошибки....
        qDebug() << http.state() << http.error() << http.bytesAvailable();
        return http.readAll();
}

Если необходимо сделать отдельный поток, который делает запрос и получает/обрабатывает ответ, то такой код можно использовать и в методе run потока.

[rnd]

BRE, то, что вы предлагаете - очень опасная практика. Начнут прокачиваться сообщения, т.е. вызываться слоты\обработчики, которые в данный момент времени (посреди работы функции) вызываться совершенно не должны.

Именно поэтому и создается отдельный поток, в который засовывается(moveToThread) объект QNetworkAccessManager там для него и идет прокачка сообщений, а вызывающий поток ждет.

Вчерашняя проблема решилась заменой QHttp на QNetworkAccessManager:)