Мне нужно приложение С++ для HTTP-сервера, и я решил сделать свой собственный, который корректно работает при отправке запросов HTTP Get, но имеет некоторые проблемы при чтении запросов HTTP Post.
Проблема заключается в том, что при отправке запросов HTTP-сообщений последний заголовок не читается должным образом, поэтому я не могу получить почтовый запрос.
Это мой код:
void HttpSession::readHeaders(std::shared_ptr<HttpSession> pThis) {
boost::asio::async_read_until(pThis->socket_, pThis->buff_, '\r\n\r\n',
[pThis](const boost::system::error_code &e, std::size_t s) {
std::istream headersStream(&pThis->buff_);
std::string header;
while(std::getline(headersStream, header, '\n')) {
if(header != "\r") {
if(header.back() == '\r') header = header.substr(0, header.length() - 1);
qDebug() << QString::fromStdString(header);
//Some stuff to get content-length to contentLength_
}
}
if(contentLength_ > 0) {
qDebug() << "Reading:";
readBody(pThis);
}
std::shared_ptr<std::string> str = std::make_shared<std::string>(pThis->headers_.getResponse());
boost::asio::async_write(pThis->socket_, boost::asio::buffer(str->c_str(), str->length()),
[pThis, str](const boost::system::error_code &e, std::size_t s) {
qDebug() << "Written";
});
}
void HttpSession::readBody(std::shared_ptr<HttpSession> pThis) {
boost::asio::async_read(pThis->socket_, pThis->data_, boost::asio::transfer_at_least(1),
[pThis](const boost::system::error_code &e, std::size_t s) {
std::istream body(&pThis->data_);
std::string line;
body >> line;
qDebug() << QString::fromStdString(line);
});
}
Переменные buff_ и data_ объявляются как: boost::asio::streambuf. А класс HttpSession - это тот, который хранит заголовки и обрабатывает всю веб-страницу. Я не включил код этого класса, так как это не проблема.
Вывод HTTP-запроса на /url следующий:
"POST /url HTTP/1.1"
"Host: 192.168.1.41:8080"
"Connection: keep-alive"
"Content-Length: 10"
"Cache-Control: max-age=0"
"Origin: http://192.168.1.41:8080"
"Upgrade-Insecure-Requests: 1"
"User-Agent: Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/52.0.2743.116 Safari/537.36"
"Content-Type: application/x-www-form-urlencoded"
"Accept: text/html,application/xhtml+xml,application/xml;q=0.9,image/webp,*/*;q=0.8"
"Referer: http://192.168.1.41:8080/"
"Accept-Encoding: gzip, deflate"
"Accept-Langua"
Reading:
"ge:"
Итак, как вы можете видеть, заголовок Accept-Language не читается правильно, хотя на этом изображении вы можете увидеть, что запрос POST выполнен правильно. 
Обратите внимание, что при отправке запросов GET все работает правильно. Поэтому я предполагаю, что он имеет какое-то отношение к чтению асинхронно, поскольку async_read_until не блокируется, поэтому async_read функции readBody читает перед этим. Должен ли я читать синхронно? Смогу ли я обрабатывать более одного клиента в любом случае, если я создам один класс HttpSession для каждого клиента? (Мне действительно не нужно поддерживать более одного пользователя, но все равно было бы неплохо).
Для обработки клиента мне это нравится:
void HttpServer::run() {
using namespace boost::asio;
io_service io_service;
ip::tcp::endpoint endpoint{ip::tcp::v4(), 8080};
ip::tcp::acceptor acceptor{io_service, endpoint};
acceptor.listen();
runServer(acceptor, io_service);
io_service.run();
while(true) QThread::msleep(5000);
}
void HttpServer::runServer(boost::asio::ip::tcp::acceptor& acceptor, boost::asio::io_service& io_service) {
std::shared_ptr<HttpSession> ses = std::make_shared<HttpSession>(io_service);
acceptor.async_accept(ses->socket_,
[ses, &acceptor, &io_service](const boost::system::error_code& accept_error) {
runServer(acceptor, io_service);
if(!accept_error) HttpSession::interact(ses);
});
}
Всякая помощь будет оценена! Если у вас есть какие-либо улучшения кода, пожалуйста, скажите мне. Спасибо!
Я думаю, проблема в '\r\n\r\n'. Это не строка, а char.
Компилятор должен предупредить вас об этом, например:
warning: implicit conversion from 'int' to 'char' changes value from 218762506 to 10 [-Wconstant-conversion]
Попробуйте заменить это на "\r\n\r\n".