Пишем синхронный http сервер с нуля на boost::asio -> Форум на Исходниках.Ру

	Наши проекты: Журнал · Discuz!ML · Wiki · DRKB · Помощь проекту

Здравствуйте, Гость ! [3.21.248.119]

Правила раздела по сетевому программированию

Пишем синхронный http сервер с нуля на boost::asio , не полуачается отправить страничку клиенту

iSherhan

Сообщ. #1 , 14.10.13, 00:34

Unregistered

Здравствуйте. Решил написать самый простой http сервер на asio.

#include <boost/asio.hpp>

#include <thread>

using boost::asio::ip::tcp;

const char data[]="HTTP/1.0 200 OK\r\n"

"Content-Length: 67\r\n"

"Content-Type: text/html\r\n"

"\r\n"

"<html><body>The quick brown fox jumps over the lazy dog<br/><body/>";

void session(tcp::socket sock)

{

sock.send(boost::asio::buffer(data, sizeof(data));

}

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

{

boost::asio::io_service io_service;

tcp::acceptor a(io_service, tcp::endpoint(tcp::v4(), 80));

for (;;)

{

tcp::socket sock(io_service);

a.accept(sock);

std::thread(session, std::move(sock)).detach();

}

return 0;

}

Запускаю браузер. И страничка то отображается, то нет. В чем проблема -не могу понять. Когда у клинта происходит ошибка,то пишет, Sockert Error 1024. Connection reset by peer.

Помогите пожалуйста разобраться.

UncleBob	Сообщ. #2 , 14.10.13, 05:01
Wizard Профиль · PM Поощрения: 24 Dgm Рейтинг (т): 683	сокет разрушается быстрее, чем успевает выполниться send

Mr.Delphist

Сообщ. #3 , 14.10.13, 11:22

Profi

Профиль · PM

Рейтинг (т): 68

Кстати да, дропать сокет сразу после отсылки - не самая лучшая идея. Исходя хотя бы из того, что некоторые HTTP-соединения будут keep-alive (всё ж версия HTTP 1.1 уже давно стала стандартом де-факто, поэтому вполне возможен вариант, что никто не проверяет Ваш HTTP/1.0).
http://www.lib.ru/WEBMASTER/rfc2068/section-8.html

Oleg2004

Сообщ. #4 , 14.10.13, 12:10

Master

Профиль · PM

Поощрения: 8 Dgm

Рейтинг (т): 215

Клиент и сервер - на одной машине?

Цитата UncleBob @ 14.10.13, 05:01

сокет разрушается быстрее, чем успевает выполниться send

Такое возможно, и в API это решается с помощью SO_LINGER.
Правда данные слишком маленькие.
Поэтому может дело в алгоритме Nagle?

Сообщение отредактировано: Oleg2004 - 14.10.13, 12:12

UncleBob

Сообщ. #5 , 21.10.13, 14:13

Wizard

Профиль · PM

Поощрения: 24 Dgm

Рейтинг (т): 683

Цитата Oleg2004 @ 14.10.13, 12:10

Такое возможно, и в API это решается с помощью SO_LINGER.

Да там же объект сокета убивается сразу после запуска потока... Если поток успел отработать, то есть шанс, что данные послались, а если продолжилось выполнение главного - пока-пока...

Oleg2004	Сообщ. #6 , 21.10.13, 18:04
Master Профиль · PM Поощрения: 8 Dgm Рейтинг (т): 215	Цитата UncleBob @ 21.10.13, 14:13 Да там же объект сокета убивается сразу после запуска потока. Я не особенный поклонник буста, потому в коде почему то этого не вижу Ткните, где это - буду очень признателен. Век живи, век учись

UncleBob

Сообщ. #7 , 21.10.13, 18:29

Wizard

Профиль · PM

Поощрения: 24 Dgm

Рейтинг (т): 683

Цитата iSherhan @ 14.10.13, 00:34

tcp::socket sock(io_service);

здесь создается с++ объект sock типа tcp::socket

он будет удален при выходе за область видимости, то есть при завершении шага цикла.

далее, я не уверен, что именно делает std::move, это какая-то новая фишка с++, которым я уже не занимаюсь много лет, но по тому что я вычитал, не похоже, чтобы она каким-то образом могла помешать удалению объекта sock, а как я подозреваю, удаление объекта влечет закрытие содержащегося в нем сокета.

Oleg2004

Сообщ. #8 , 21.10.13, 19:56

Master

Профиль · PM

Поощрения: 8 Dgm

Рейтинг (т): 215

Мне кажется что если бы было в точности так, то у автора не было бы возможности вообще что получить хоть раз.

Цитата iSherhan @ 14.10.13, 00:34

Запускаю браузер. И страничка то отображается, то нет.

Кроме того, при возврате к началу бесконечного цикла он снова создает сокет - правда уже другой
Впрочем, автор замолчал... <_<

Сообщение отредактировано: Oleg2004 - 21.10.13, 20:00

UncleBob

Сообщ. #9 , 22.10.13, 01:38

Wizard

Профиль · PM

Поощрения: 24 Dgm

Рейтинг (т): 683

Цитата Oleg2004 @ 21.10.13, 19:56

Мне кажется что если бы было в точности так, то у автора не было бы возможности вообще что получить хоть раз.

Как раз описанное автором подтверждает мое предположение, потому как все зависит от того, успеет ли сработать поток до завершения цикла (что вполне возможно), или нет. И если успевает - то все ок, а если нет, то сокет закрывается до send. А дальше - как шедулеру заблагорассудится.

Oleg2004	Сообщ. #10 , 22.10.13, 06:37
Master Профиль · PM Поощрения: 8 Dgm Рейтинг (т): 215	Кажется я начинаю что-то понимать. Вы хотите сказать, что вызов std::thread(session, std::move(sock)).detach(); приводит к созданию асинхронного по отношению к основному процессу потока... Ну вот, если это так, то ваше предположение вполне...

UncleBob	Сообщ. #11 , 22.10.13, 10:47
Wizard Профиль · PM Поощрения: 24 Dgm Рейтинг (т): 683	Цитата Oleg2004 @ 22.10.13, 06:37 Вы хотите сказать

MyNameIsIgor

Сообщ. #12 , 22.10.13, 17:57

Unregistered

Цитата UncleBob @ 21.10.13, 18:29

далее, я не уверен, что именно делает std::move, это какая-то новая фишка с++, которым я уже не занимаюсь много лет, но по тому что я вычитал, не похоже, чтобы она каким-то образом могла помешать удалению объекта sock

Но как раз это и происходит

Это перемещение. Т.е. созданный в цикле сокет оказывается в функции

void session(tcp::socket sock)

В данном вопросе всё валидно.

Добавлено 22.10.13, 18:11
Ну, а проблема, очевидно, в этом

Цитата

Remarks

The send operation may not transmit all of the data to the peer. Consider using the write function if you need to ensure that all data is written before the blocking operation completes.

Oleg2004

Сообщ. #13 , 22.10.13, 18:52

Master

Профиль · PM

Поощрения: 8 Dgm

Рейтинг (т): 215

Цитата MyNameIsIgor @ 22.10.13, 17:57

Ну, а проблема, очевидно, в этом

Наврядли. Функция send()ничего не шлет в сеть, она лишь копирует из своего буфера в передающий буфер сокета модуля TCP. Приемный буфер сокета в модуле TCP по умолчанию достаточно велик в разных ОС - В Беркли-реализациях по умолчанию используются буфера отправки и приема размером в 4096 байт, более современные системы используют буфера размером от 8192 до 61 440 байт.
А потому send() не сможет отправить свой буфер только тогда, когда буфер отправки сокета не может вместить данные из буфера приложения. В данном случае send() отправляет настолько мало данных, что этот вопрос даже и не встает. И они уходят совершенно спокойно без блокировки..

MyNameIsIgor	Сообщ. #14 , 22.10.13, 18:58
Unregistered	Цитата Oleg2004 @ 22.10.13, 18:52 Наврядли. Зачем предполагать, если ТС может легко проверить?

Oleg2004

Сообщ. #15 , 22.10.13, 19:07

Master

Профиль · PM

Поощрения: 8 Dgm

Рейтинг (т): 215

Цитата MyNameIsIgor @ 22.10.13, 18:58

Зачем предполагать, если ТС может легко проверить?

А шо такое TC? Total Commander? :blink:

И если легко, то почему топикстартер не смог?
А насчет предположений...
Видите ли - все, что имеет коммерческое происхождение - как правило 100% работает.
А вот любительский код - он таким и остается.
Теоретические и практические консидерации по поводу send() известны уже лет 20 не менее.. и абсолютно детерминированы. А топикстартеру я бы порекомендовал сюда
Насчет ТС...круто :lool:

А бы не догадался никогда... :wall:

Сообщение отредактировано: Oleg2004 - 22.10.13, 19:33

0 пользователей читают эту тему (0 гостей и 0 скрытых пользователей)

0 пользователей:

Страницы: (2) [1] 2 все

[ Script execution time: 0,0752 ] [ 16 queries used ] [ Generated: 27.04.24, 09:06 GMT ]