阅读量:0
Boost::Beast::Http服务器
命名空间和类型定义
namespace beast = boost::beast; namespace http = beast::http; namespace net = boost::asio; using tcp = boost::asio::ip::tcp; 这些命名空间和类型定义简化了后续代码的书写。
命名空间 my_program_state
namespace my_program_state { std::size_t request_count() { static std::size_t count = 0; return ++count; } std::time_t now() { return std::time(0); } } 这个命名空间包含两个函数：
request_count()：返回请求计数，每次调用时递增。now()：返回当前时间。
类 http_connection
这个类处理每个HTTP连接，继承自 std::enable_shared_from_this 以便在异步操作中安全地创建 shared_ptr。
构造函数和 start 方法
http_connection(tcp::socket socket) : m_socket(std::move(socket)) { } void start() { read_request(); check_deadline(); } 构造函数接受一个TCP套接字。start 方法启动读取请求和超时检测。
私有成员变量
tcp::socket m_socket; beast::flat_buffer m_buffer{ 8192 }; http::request<http::dynamic_body> m_request; http::response<http::dynamic_body> m_response; net::steady_timer m_deadline{m_socket.get_executor(), std::chrono::seconds(60)}; 这些成员变量包括套接字、缓冲区、请求和响应对象，以及一个超时定时器。
read_request 方法
void read_request() { auto self = shared_from_this(); http::async_read(m_socket, m_buffer, m_request, self { if (!ec) { self->process_request(); } }); } 这个方法异步读取HTTP请求，并在读取完成后调用 process_request 方法。
check_deadline 方法
void check_deadline() { auto self = shared_from_this(); m_deadline.async_wait(self { if (!ec) { self->m_socket.close(ec); } }); } 这个方法设置一个超时定时器，如果超时则关闭套接字。
process_request 方法
void process_request() { m_response.version(m_request.version()); m_response.keep_alive(false); switch (m_request.method()) { case http::verb::get: m_response.result(http::status::ok); m_response.set(http::field::server, "Beast"); create_response(); break; case http::verb::post: m_response.result(http::status::ok); m_response.set(http::field::server, "Beast"); create_post_response(); break; default: m_response.result(http::status::bad_request); m_response.set(http::field::content_type, "text/plain"); beast::ostream(m_response.body()) << "Invalid request-method" << std::string(m_request.method_string()) << "`" << std::endl; break; } write_response(); } 这个方法处理HTTP请求，根据请求方法生成响应。
create_response 方法
void create_response() { if (m_request.target() == "/count") { m_response.set(http::field::content_type, "text/html"); beast::ostream(m_response.body()) << "<html>\n" << "<head><title>Request count</title></head>\n" << "<body>\n" << "<h1>Request count</h1>\n" << "<p>There have been " << my_program_state::request_count() << " requests so far.</p>\n" << "</body>\n" << "</html>\n"; } else if (m_request.target() == "/time") { m_response.set(http::field::content_type, "text/html"); beast::ostream(m_response.body()) << "<html>\n" << "<head><title>Current time</title></head>\n" << "<body>\n" << "<h1>Current time</h1>\n" << "<p>The current time is " << my_program_state::now() << " seconds since the epoch.</p>\n" << "</body>\n" << "</html>\n"; } else { m_response.result(http::status::not_found); m_response.set(http::field::content_type, "text/plain"); beast::ostream(m_response.body()) << "File not found\r\n"; } } 这个方法根据请求的目标生成不同的响应内容。
write_response 方法
void write_response() { auto self = shared_from_this(); m_response.content_length(m_response.body().size()); http::async_write(m_socket, m_response, self { self->m_socket.shutdown(tcp::socket::shutdown_send, ec); self->m_deadline.cancel(); }); } 这个方法异步写入HTTP响应，并在完成后关闭套接字。
create_post_response 方法
void create_post_response() { if (m_request.target() == "/email") { auto& body = this->m_request.body(); auto body_str = beast::buffers_to_string(body.data()); std::cout << "receive body is " << body_str << std::endl; this->m_response.set(http::field::content_type, "text/json"); Json::Value root; Json::Reader reader; Json::Value src_root; bool parse_success = reader.parse(body_str, src_root); if (!parse_success) { std::cout << "Failed to parse Json data" << std::endl; root["error"] = 1001; std::string jsonstr = root.toStyledString(); beast::ostream(m_response.body()) << jsonstr; return; } auto email = src_root["email"].asString(); std::cout << "email is" << email << std::endl; root["error"] = 0; root["email"] = src_root["email"]; root["msg"] = "receive email post success"; std::string jsonstr = root.toStyledString(); beast::ostream(m_response.body()) << jsonstr; } else { m_response.result(http::status::not_found); m_response.set(http::field::content_type, "text/plain"); beast::ostream(m_response.body()) << "File not found\r\n"; } } 这个方法处理POST请求，解析JSON数据并生成响应。
方法概述
create_post_response 方法根据请求的目标路径处理POST请求。如果目标路径是 /email，则解析请求体中的JSON数据，并生成相应的响应。如果目标路径不是 /email，则返回404 Not Found响应。
代码解析
检查请求目标
if (m_request.target() == "/email") 这行代码检查HTTP请求的目标路径是否为 /email。
获取请求体
auto& body = this->m_request.body(); auto body_str = beast::buffers_to_string(body.data()); std::cout << "receive body is " << body_str << std::endl; auto& body = this->m_request.body();获取请求体的引用。auto body_str = beast::buffers_to_string(body.data());将请求体转换为字符串。std::cout << "receive body is " << body_str << std::endl;打印接收到的请求体内容。
设置响应头
this->m_response.set(http::field::content_type, "text/json"); 设置响应的内容类型为 text/json。
解析JSON数据
Json::Value root; Json::Reader reader; Json::Value src_root; bool parse_success = reader.parse(body_str, src_root); if (!parse_success) { std::cout << "Failed to parse Json data" << std::endl; root["error"] = 1001; std::string jsonstr = root.toStyledString(); beast::ostream(m_response.body()) << jsonstr; return; } Json::Value root;和Json::Value src_root;定义两个JSON对象。Json::Reader reader;定义一个JSON解析器。bool parse_success = reader.parse(body_str, src_root);解析请求体中的JSON数据，并将结果存储在src_root中。- 如果解析失败，设置错误信息并返回响应。
处理解析后的数据
auto email = src_root["email"].asString(); std::cout << "email is" << email << std::endl; root["error"] = 0; root["email"] = src_root["email"]; root["msg"] = "receive email post success"; std::string jsonstr = root.toStyledString(); beast::ostream(m_response.body()) << jsonstr; auto email = src_root["email"].asString();获取解析后的JSON数据中的email字段。- 打印接收到的
email。 - 设置响应的JSON数据，包括
error、email和msg字段。 - 将响应的JSON数据转换为字符串，并写入响应体。
处理未找到的目标路径
else { m_response.result(http::status::not_found); m_response.set(http::field::content_type, "text/plain"); beast::ostream(m_response.body()) << "File not found\r\n"; } 如果请求的目标路径不是 /email，则返回404 Not Found响应，并设置响应体为 “File not found”。
总结
create_post_response 方法处理HTTP POST请求，解析请求体中的JSON数据，并生成相应的响应。如果请求的目标路径不是 /email，则返回404 Not Found响应。
http_server` 函数
void http_server(tcp::acceptor& acceptor, tcp::socket& socket) { acceptor.async_accept(socket, & { if (!ec) { std::make_shared<http_connection>(std::move(socket))->start(); } http_server(acceptor, socket); }); } 这个函数接受新的连接并创建 http_connection 对象来处理每个连接。
main 函数
int main() { try { auto const address = net::ip::make_address("127.0.0.1"); unsigned short port = static_cast<unsigned short>(8080); net::io_context ioc{1}; tcp::acceptor acceptor{ ioc,{address,port} }; tcp::socket socket{ ioc }; http_server(acceptor, socket); ioc.run(); } catch (const std::exception& e) { std::cerr << "Error: " << e.what() << std::endl; return EXIT_FAILURE; } } 这个函数设置服务器的IP地址和端口，创建 io_context、acceptor 和 socket，并启动服务器。
