{"id":445438,"date":"2025-01-19T15:01:16","date_gmt":"2025-01-19T15:01:16","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=445438"},"modified":"-0001-11-30T00:00:00","modified_gmt":"2025-01-19T15:01:16","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=445438","title":{"rendered":"\u041d\u0435\u043e\u0447\u0435\u0432\u0438\u0434\u043d\u044b\u0435 \u043f\u043b\u044e\u0441\u044b \u044f\u0437\u044b\u043a\u0430 \u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f<\/span>"},"content":{"rendered":"
<\/div>\n
\n
\n
\n
\n

\u0420\u0430\u0441\u0442 \u0445\u043e\u0440\u043e\u0448, \u0432\u0441\u0435 \u044d\u0442\u043e \u0437\u043d\u0430\u044e\u0442. \u0418\u043d\u0432\u0435\u0441\u0442\u0438\u0440\u0443\u0435\u0448\u044c \u0432\u0440\u0435\u043c\u044f \u0432 \u044f\u0437\u044b\u043a \u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f, \u043a\u0430\u0439\u0444\u0443\u0435\u0448\u044c, \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0448\u044c c \u0440\u0438\u0441\u043a\u0430\u043c\u0438, \u0437\u0430\u0434\u0430\u0435\u0448\u044c\u0441\u044f \u0432\u043e\u043f\u0440\u043e\u0441\u043e\u043c — \u0430 \u043c\u043e\u0436\u0435\u0442, \u0440\u0430\u0441\u0442 \u0435\u0449\u0435 \u043a\u0440\u0443\u0447\u0435? \u041f\u043e\u0447\u0435\u043c\u0443 \u0431\u044b, \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u043d\u0435 \u0438\u0437\u0443\u0447\u0438\u0442\u044c \u0441\u043e\u043b\u0438\u0434\u043d\u044b\u0439 \u043f\u0440\u043e\u0435\u043a\u0442 \u043d\u0430 \u043f\u043b\u044e\u0441\u0430\u0445 (5k \u0437\u0432\u0435\u0437\u0434 \u043d\u0430 \u0433\u0438\u0442\u0445\u0430\u0431\u0435) — \u0438 \u043c\u0438\u0433\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0435\u0433\u043e. \u0412\u0440\u043e\u0434\u0435, \u0432\u0441\u0435 \u0442\u0430\u043a \u0434\u0435\u043b\u0430\u044e\u0442, \u043d\u043e \u043c\u043e\u0436\u0435\u0442, \u0441\u0443\u0442\u044c \u0432 \u043c\u0438\u0433\u0440\u0430\u0446\u0438\u0438 \u0438\u0434\u0435\u0439, \u0430 \u043d\u0435 \u043a\u043e\u0434\u0430. \u0411\u044b\u0442\u044c \u043c\u043e\u0436\u0435\u0442, \u043c\u044b \u043d\u0430\u0439\u0434\u0435\u043c \u043e\u0442\u0432\u0435\u0442\u044b \u043e \u0432\u044b\u0440\u0430\u0437\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u0438 \u044f\u0437\u044b\u043a\u0430, \u0447\u0438\u0442\u0430\u0435\u043c\u043e\u0441\u0442\u0438 \u0438 \u0441\u043a\u043e\u0440\u043e\u0441\u0442\u0438 \u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c\u044b. \u0412\u043e\u0437\u043c\u043e\u0436\u043d\u043e, \u043d\u0430\u043c \u0441\u0442\u0430\u043d\u0435\u0442 \u044f\u0441\u043d\u043e — \u0430 \u0434\u0440\u0443\u0433 \u043b\u0438 \u043d\u0430\u0448 \u043a\u043e\u043c\u043f\u0438\u043b\u044f\u0442\u043e\u0440, \u043d\u043e \u0441\u043a\u043e\u0440\u0435\u0435 \u0432\u0441\u0435\u0433\u043e, \u043c\u044b \u043d\u0430\u0441\u043b\u0430\u0434\u0438\u043c\u0441\u044f \u044d\u0441\u0442\u0435\u0442\u0438\u043a\u043e\u0439 \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0430 \u043f\u0440\u043e\u0435\u043a\u0442\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f \u043d\u0430 \u0440\u0430\u0441\u0442e.<\/p>\n

\u0421\u0442\u0440\u0430\u043d\u0430 \u0431\u043e\u0433\u0430\u0442\u0430 \u0438\u0434\u0435\u044f\u043c\u0438, \u043a\u0430\u043a \u0447\u0438\u0442\u0430\u0442\u044c \u043a\u043e\u0434: \u0431\u043b\u043e\u043a-\u0441\u0445\u0435\u043c\u044b, \u043a\u043e\u043d\u0446\u0435\u043f\u0442\u0443\u0430\u043b\u044c\u043d\u044b\u0435 \u043c\u043e\u0434\u0435\u043b\u0438, \u0444\u0430\u0439\u043b \u0447\u0435\u0440\u0435\u0437 \u0444\u0430\u0439\u043b \u0438 \u0442.\u0434. \u041a \u0441\u043e\u0436\u0430\u043b\u0435\u043d\u0438\u044e, \u0440\u0430\u0431\u043e\u0447\u0438\u0439 \u0434\u043b\u044f \u043c\u0435\u043d\u044f \u043c\u0435\u0442\u043e\u0434 — \u044d\u0442\u043e \u0447\u0442\u0435\u043d\u0438\u0435 \u0432\u0441\u0435\u0433\u043e \u043f\u043e\u0434\u0440\u044f\u0434. \u042f \u0432\u044b\u0431\u0440\u0430\u043b \u0442\u0435\u043c\u0443, \u043e \u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u0431\u043e\u043b\u044c\u0448\u0438\u043d\u0441\u0442\u0432\u043e \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a\u043e\u0432 \u0441\u043b\u044b\u0448\u0430\u043b\u0438 \u0442\u043e\u0447\u043d\u043e (\u0445\u043e\u0442\u044f \u0431\u044b \u043a\u0440\u0430\u0435\u043c \u0443\u0445\u0430): \u0432\u0435\u0431-\u0441\u0435\u0440\u0432\u0435\u0440\u0430. \u0414\u0430\u043b\u0435\u0435 \u0432 \u0442\u0435\u043a\u0441\u0442\u0435 \u0431\u0443\u0434\u0435\u043c \u0430\u043d\u0430\u043b\u0438\u0437\u0438\u0440\u043e\u0432\u0430\u0442\u044c, \u043a\u0430\u043a \u0443\u0441\u0442\u0440\u043e\u0435\u043d \u0432\u0435\u0431 \u0441\u0435\u0440\u0432\u0435\u0440 crowCpp (\u0441\u0441\u044b\u043b\u043a\u0430 \u0431\u0443\u0434\u0435\u0442 \u043d\u0438\u0436\u0435) \u0438 \u043c\u0438\u0433\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c (\u0441\u043a\u043e\u0440\u0435\u0435 \u0432\u043e\u043f\u043b\u043e\u0449\u0430\u0442\u044c \u0435\u0433\u043e \u0438\u0434\u0435\u0438) \u043d\u0430 \u044f\u0437\u044b\u043a \u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f \u0440\u0430\u0441\u0442.<\/p>\n

\u041e\u0447\u0435\u043d\u044c \u043a\u0440\u0430\u0442\u043a\u043e \u0437\u0430\u043c\u0435\u0442\u043a\u0438 \u043d\u0430 \u043f\u043e\u043b\u044f\u0445 \u043f\u043e \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u044e (https:\/\/github.com\/CrowCpp\/Crow<\/a>):<\/p>\n

http_request.h — \u043f\u0440\u0435\u043a\u0440\u0430\u0441\u043d\u044b\u0439 \u043a\u043e\u0434, \u043a\u043e\u0440\u043e\u0442\u043a\u0438\u0435 \u0444\u0443\u043d\u043a\u0446\u0438\u0438\/\u043c\u0435\u0442\u043e\u0434\u044b, \u043c\u043d\u043e\u0433\u043e \u0434\u043e\u043a\u0443\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u0438 (\u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u0431\u0435\u0437 \u0434\u043e\u043a\u043e\u0432 \u0444\u0438\u0433 \u0440\u0430\u0437\u0431\u0435\u0440\u0435\u0448\u044c, \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u043c\u0435\u0442\u043e\u0434 \u0438\u043b\u0438 \u043d\u0435\u0442).<\/p>\n

http_response.h — \u043c\u043d\u043e\u0433\u043e \u0432\u044b\u0437\u043e\u0432\u043e\u0432 std::move, \u043f\u0440\u0438 \u0441\u043b\u0443\u0447\u0430\u044f\u0445 \u043d\u0435 \u043f\u0440\u0435\u0434\u0443\u0441\u043c\u043e\u0442\u0440\u0435\u043d\u043d\u044b\u0445 \u043b\u043e\u0433\u0438\u043a\u043e\u0439 \u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c\u044b — \u043b\u043e\u0433\u0438\u0440\u0443\u0435\u043c \u0438 \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u043c \u0434\u0435\u0444\u043e\u043b\u0442\u043d\u043e\u0435 \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u0435, \u043c\u043d\u043e\u0433\u043e \u043c\u0443\u0442\u0430\u0431\u0435\u043b\u044c\u043d\u043e\u0433\u043e \u043a\u043e\u0434\u0430, \u0444\u043b\u0430\u0433\u043e\u0432\u043e\u0435 \u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435 \u0438 \u0442.\u0434.<\/p>\n

http_connection.h — \u043f\u0440\u0438\u0432\u0435\u0442, \u0440\u0435\u043a\u0443\u0440\u0441\u0438\u044f (\u0432 \u043f\u0440\u0438\u0440\u043e\u0434\u0435 \u043f\u043e\u043a\u0430 \u0435\u0449\u0435 \u043d\u0435\u0442 \u043f\u0440\u043e\u0435\u043a\u0442\u0430 \u0431\u0435\u0437 \u0440\u0435\u043a\u0443\u0440\u0441\u0438\u0438 \ud83d\ude42<\/p>\n

http_server.h — \u043f\u0435\u0440\u0435\u0438\u0437\u043e\u0431\u0440\u0435\u0442\u0435\u043d\u0438\u0435 \u0430\u043b\u0433\u043e\u0440\u0438\u0442\u043c\u043e\u0432 \u0431\u0430\u043b\u0430\u043d\u0441\u0438\u0440\u043e\u0432\u043a\u0438 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438 (load balancing) \u0441 \u043a\u043e\u043c\u043c\u0435\u043d\u0442\u0430\u0440\u0438\u0435\u043c «\u0442\u0443\u0434\u0443», \u043a\u0430\u043a \u043c\u043e\u0436\u043d\u043e \u0441\u044d\u043a\u043e\u043d\u043e\u043c\u0438\u0442\u044c \u0435\u0449\u0435 \u043f\u0430\u0440\u0443 \u0431\u0430\u0439\u0442.<\/p>\n

app.h — \u0442\u043e\u0447\u043a\u0430 \u0432\u0445\u043e\u0434\u0430 \u0438 \u043c\u0430\u043a\u0440\u043e\u0441\u044b.
socket_adaptors.h — \u043e\u0431\u0435\u0440\u0442\u043a\u0430 \u043d\u0430\u0434 \u0441\u043e\u043a\u0435\u0442\u043e\u043c.<\/p>\n

routing.h — \u043f\u043e\u043a\u0430\u0437\u0430\u043b\u0441\u044f \u0438\u043d\u0442\u0435\u0440\u0435\u0441\u043d\u044b\u043c \u0444\u0440\u0430\u0433\u043c\u0435\u043d\u0442 \u043a\u043e\u0434\u0430:<\/p>\n

void handle_upgrade(...) override {     max_payload_ = max_payload_override_ ? max_payload_ : app_->websocket_max_payload();     new crow::websocket::Connection<SocketAdaptor, App>(req, std::move(adaptor), app_, max_payload_, ...); } <\/code><\/pre>\n
\u041d\u0430\u043f\u043e\u043c\u0438\u043d\u0430\u0435\u0442 \u044f\u0432\u0443, \u043d\u043e \u043a\u043e\u043d\u0441\u0442\u0440\u0443\u043a\u0442\u043e\u0440 websocket::Connection \u0441\u0430\u043c \u0441\u0435\u0431\u044f \u0438 \u043f\u043e\u0434\u0447\u0438\u0449\u0430\u0435\u0442<\/p>\n
... adaptor_.close(); handler_->remove_websocket(this); delete this; <\/code><\/pre>\n
\u0435\u0449\u0435_\u043c\u043d\u043e\u0433\u043e_\u0444\u0430\u0439\u043b\u043e\u0432.h — \u043c\u043d\u043e\u0433\u043e \u043a\u043e\u0434\u0430 \u0438 \u0440\u0430\u0437\u043d\u044b\u0445 \u0444\u0438\u0447\u0435\u0439, \u043d\u043e \u0432 \u043f\u0440\u0438\u043d\u0446\u0438\u043f\u0435, \u0443\u0436\u0435 \u043c\u043e\u0436\u043d\u043e \u043f\u043e\u0441\u0442\u0440\u043e\u0438\u0442\u044c \u043f\u0435\u0440\u0432\u044b\u0439 \u043f\u0440\u043e\u0442\u043e\u0442\u0438\u043f \u0440\u0430\u0431\u043e\u0447\u0435\u0433\u043e \u0441\u0435\u0440\u0432\u0435\u0440\u0430.<\/p>\n
\u0427\u0430\u0441\u0442\u044c 1: \u041f\u0438\u043d\u0433-\u041f\u043e\u043d\u0433<\/h3>\n
\u041f\u043e\u0441\u043b\u0435 \u0434\u043e\u043b\u0433\u043e\u0433\u043e \u0438 \u0443\u043f\u043e\u0440\u043d\u043e\u0433\u043e \u0440\u0430\u0441\u043f\u0438\u0442\u0438\u044f \u043a\u0440\u0435\u043f\u043a\u043e\u0433\u043e \u043a\u043e\u0444\u0435, \u043d\u043e\u0432\u043e\u0441\u0442\u0435\u0439 \u043e \u0434\u043e\u0442\u0435, \u0448\u0430\u0445\u043c\u0430\u0442\u0430\u0445 \u0438 \u0441\u043d\u0443\u043a\u0435\u0440\u0435, \u0435\u0449\u0435 \u0438 \u0442\u0435\u043b\u0435\u0433\u0438 (\u0442\u0443\u0442 \u043d\u0438\u043a\u0443\u0434\u0430) — \u0434\u0438\u0437\u0430\u0439\u043d\u0438\u043c \u043d\u0430 \u0441\u0430\u043b\u0444\u0435\u0442\u043a\u0435 \u043f\u0440\u043e\u0435\u043a\u0442: \u0441\u043e\u043a\u0435\u0442 -> \u043a\u043e\u043d\u043d\u0435\u043a\u0448\u0435\u043d -> \u0441\u0435\u0440\u0432\u0435\u0440 -> \u0430\u043f\u043f (\u0440\u0435\u0441\u043f\u043e\u043d\u0441 \u0438 \u0440\u0435\u043a\u0432\u0435\u0441\u0442 \u0433\u0434\u0435-\u0442\u043e \u0441\u0431\u043e\u043a\u0443, \u0440\u043e\u0443\u0442\u0435\u0440 \u043f\u0440\u043e\u043a\u0438\u0434\u044b\u0432\u0430\u0435\u043c \u0447\u0435\u0440\u0435\u0437 \u0430\u043f\u043f).<\/p>\n
\u041a\u0430\u043a-\u0442\u043e \u0442\u0430\u043a, \u0435\u0449\u0435 \u0440\u0430\u0437: \u0430\u043f\u043f\u043b\u0438\u043a\u0435\u0439\u0448\u043d -> \u0441\u0435\u0440\u0432\u0435\u0440 -> \u043a\u043e\u043d\u043d\u0435\u043a\u0448\u0435\u043d -> \u0441\u043e\u043a\u0435\u0442. \u0412 \u043a\u043e\u043d\u0446\u0435 \u043a\u043e\u043d\u0446\u043e\u0432, \u043c\u044b \u0445\u043e\u0442\u0438\u043c \u0432\u0438\u0434\u0435\u0442\u044c \u0442\u0430\u043a\u043e\u0439 \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441:<\/p>\n
route![app, \"\/\", || \"Hello world\".to_owned()]; route![app, \"\/measure\/<float>\/and\/<int>\", |x,y,_req| format!(\"{:?} and {:?}\" x, y)]; <\/code><\/pre>\n
\u0425\u043e\u0434\u044f\u0442 \u0441\u043b\u0443\u0445\u0438, \u0447\u0442\u043e \u043c\u0438\u0433\u0440\u0430\u0446\u0438\u044e \u043a\u043e\u0434\u0430 \u0432\u044b\u043f\u043e\u043b\u043d\u044f\u044e\u0442 \u0441\u0442\u0440\u043e\u0447\u043a\u0430 \u0437\u0430 \u0441\u0442\u0440\u043e\u0447\u043a\u043e\u0439 \u0441pp -> rust, \u0430 \u043c\u043e\u0436\u043d\u043e \u0438 \u043c\u0438\u0433\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0441 \u043d\u0443\u043b\u044f, \u0445\u043e\u0442\u044f, \u043a\u0430\u043a \u0441\u043a\u0430\u0437\u0430\u043b \u0431\u044b \u0414\u0436\u043e\u044d\u043b\u044c \u0421\u043f\u043e\u043b\u044c\u0441\u043a\u0438 — \u0431\u0443\u0434\u0443\u0442 \u0431\u0430\u0433\u0438, \u0434\u0430 \u0438 \u0444\u0438\u0433 \u0441 \u043d\u0438\u043c\u0438, \u043f\u0440\u043e\u0435\u043a\u0442-\u0442\u043e \u0443\u0447\u0435\u0431\u043d\u044b\u0439. \u0422\u0430\u043a\u0436\u0435 \u0432\u0435\u0431\u0441\u043e\u043a\u0435\u0442\u044b \u0432 \u043f\u0435\u0440\u0432\u043e\u0439 \u0432\u0435\u0440\u0441\u0438\u0438 \u0438\u043c\u043f\u043b\u0435\u043c\u0435\u043d\u0442\u0438\u0442\u044c \u043d\u0435 \u0431\u0443\u0434\u0435\u043c\/\u0445\u043e\u0442\u0438\u043c, \u0438 \u0432\u0435\u0440\u0441\u0438\u044e \u0445\u0442\u0442\u043f \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b\u0430 \u0432\u043e\u0437\u044c\u043c\u0435\u043c \u0442\u043e\u043b\u044c\u043a\u043e 1.1. \u0412\u0441\u0435 \u043f\u043e\u043a\u0430\u0437\u044b\u0432\u0430\u044e\u0442 \u0432\u0435\u043b\u0438\u043a\u043e\u043b\u0435\u043f\u043d\u044b\u0435 \u0433\u0440\u0430\u0444\u0438\u043a\u0438 \u0441 \u0431\u0435\u0447\u043c\u0430\u0440\u043a\u0430\u043c\u0438, \u043d\u043e \u0445\u043e\u0442\u044c \u043a\u0442\u043e-\u043d\u0438\u0431\u0443\u0434\u044c \u0441\u043a\u0430\u0437\u0430\u043b \u0431\u044b — \u0437\u043d\u0430\u0435\u0442\u0435, \u0431\u0435\u0447\u043c\u0430\u0440\u043a\u0438 \u0443 \u043d\u0430\u0441 \u043d\u043e\u0440\u043c\u0443\u043b\u044c, \u0430 \u043a\u043e\u0434 \u0435\u0449\u0435 \u043b\u0443\u0447\u0448\u0435 — \u0442\u0443\u043f\u043e \u0447\u0438\u0442\u0430\u0435\u043c, \u0434\u0430 \u0438 \u0441 \u0444\u043b\u0430\u0433\u0430\u043c\u0438 (\u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0437\u0430 300) \u043c\u044b \u043d\u0435 \u0431\u0430\u043b\u0443\u0435\u043c\u0441\u044f.<\/p>\n
\u041a\u043e\u043d\u043d\u0435\u043a\u0448\u043d.\u0440\u0441<\/p>\n
\/\/\/ connection.rs  pub struct Connection { socket: Socket, }  impl Connection { pub fn new(stream: TcpStream) -> Self { Connection { socket: Socket::new(stream), } } }  impl Connection{ pub async fn start(&mut self, app: &App) -> Result<(), Box<dyn Error>> { let s = self.socket.read_all().await?; if !s.is_empty() { let req = Parser::new(s).parse().ok_or(\"failed to parse\")?; let resp = app.handle(req).await;         self.socket.write_all(resp).await?;     }     Ok(()) } } <\/code><\/pre>\n
\u0414\u043b\u044f \u0442\u0435\u0445, \u043a\u0442\u043e \u043d\u0435 \u0437\u043d\u0430\u043a\u043e\u043c \u0441 \u0440\u0430\u0441\u0442\u043e\u043c: 1) \u0444\u044c\u044e\u0447\u0435\u0440\u0441\u044b \u0431\u0435\u0437 await \u043d\u0438\u0447\u0435\u0433\u043e \u043d\u0435 \u0434\u0435\u043b\u0430\u044e\u0442, 2) \u0437\u043d\u0430\u043a\u0438 \u0432\u043e\u043f\u0440\u043e\u0441\u0430 — \u0435\u0441\u0442\u044c \u043d\u0435\u044f\u0432\u043d\u0430\u044f \u0440\u0430\u0441\u043f\u0430\u043a\u043e\u0432\u043a\u0430 Result \u0438\u043b\u0438 Option.<\/p>\n
\u041f\u0440\u043e\u0441\u0442\u0435\u0439\u0448\u0438\u0439 \u0438\u0437 \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u044b\u0445 \u043f\u0430\u0440\u0441\u0435\u0440\u043e\u0432 \u0445\u0442\u0442\u043f \u0437\u0430\u043f\u0440\u043e\u0441\u0430<\/p>\n
\/\/\/ parser.rs  pub struct Parser<'a> { s: &'a str, }  impl <'a> Parser<'a> { pub fn new(s: &'a str) -> Self { Parser { s } } }  impl Parser<'_> { pub fn parse(self) -> Option<Request> { let (mut info, mut headers) = (vec![], vec![]);  let mut iter = self.s.split(\"\\r\\n\"); for x in iter.next()?.split(' ') {  info.push(x);  } for x in iter.by_ref() { if x.is_empty() { break; } let mut b = x.split(\": \"); headers.push(( b.next()?.to_owned(),  b.next()?.to_owned() )); } let body = iter.next()?.to_owned();  Request::build(info, headers, body) } }  <\/code><\/pre>\n
\u0414\u0432\u0430 \u043c\u043e\u043c\u0435\u043d\u0442\u0430: 1) \u043c\u0435\u0442\u043e\u0434 parse \u043f\u043e\u0433\u043b\u043e\u0442\u0438\u0442 \u043e\u0431\u044c\u0435\u043a\u0442 (self \u0431\u0435\u0437 \u0430\u043c\u043f\u0435\u0440\u0441\u0430\u043d\u0434\u0430) — \u0433\u0443\u0434 \u043f\u0440\u0438 \u043f\u0440\u043e\u0435\u043a\u0442\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0438; 2) lifetime (\u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0430\u043f\u043e\u0441\u0442\u0440\u043e\u0444) \u043d\u0435 \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u0437\u0430\u044e\u0437\u0430\u0442\u044c \u0441\u0441\u044b\u043b\u043a\u0443 \u043d\u0430 \u0431\u0443\u0444\u0435\u0440 \u0441\u043e\u043a\u0435\u0442\u0430 (\u0447\u0435\u0440\u0435\u0437 \u0441\u0441\u044b\u043b\u043a\u0443 \u043d\u0430 \u0441\u0442\u0440\u043e\u043a\u0443) \u043f\u043e\u0441\u043b\u0435 \u0435\u0433\u043e (\u0431\u0443\u0444\u0435\u0440\u0430) \u0443\u0434\u0430\u043b\u0435\u043d\u0438\u044f.<\/p>\n
\u0420\u0435\u043a\u0432\u0435\u0441\u0442.pc — \u0441\u043e\u0431\u0441\u0442\u0432\u0435\u043d\u043d\u043e, \u043e\u0441\u043d\u043e\u0432\u043d\u0430\u044f \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u044f, \u043a\u043e\u0442\u043e\u0440\u0443\u044e \u043c\u044b \u0445\u043e\u0442\u0438\u043c \u043f\u0435\u0440\u0435\u0434\u0430\u0442\u044c \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u043e\u043c\u0443 \u043a\u043e\u0434\u0443.<\/p>\n
\/\/\/ request.rs  #[derive(Default, Debug, Clone)] pub struct Request { pub method: String, pub url: String, pub version: String, pub query: String, pub headers: Vec<(String, String)>, pub body: String,   }  fn parse_url(s: &str) -> (String, String) { if let Some(i) = s.find('?') { (s[..i].to_owned(), s[i+1..].to_owned()) } else { (s.to_owned(), \"\".to_owned()) } }  impl Request { pub fn build(mut info: Vec<&str>, headers: Vec<(String, String)>, body: String) -> Option<Self> { let version = info.pop()?.to_owned(); let (url, query) = parse_url(info.pop()?); let method = info.pop()?.to_owned(); Some(Request {method, url, query, version, headers, body}) } } <\/code><\/pre>\n
\u0420\u0435\u0441\u043f\u043e\u043d\u0441 \u0434\u043b\u044f \u043f\u0440\u043e\u0441\u0442\u043e\u0442\u044b \u0438\u043c\u043f\u043b\u0435\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u0438 \u0441\u0434\u0435\u043b\u0430\u0435\u043c \u0441\u0442\u0440\u0438\u043d\u0433\u043e\u043c (String).<\/p>\n
\u0412\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u043c\u0441\u044f \u043a \u0441\u043e\u043a\u0435\u0442\u0430\u043c — \u0421\u043e\u043a\u0435\u0442.\u0440\u0441<\/p>\n
\/\/\/ socket.rs  pub struct Socket { stream: TcpStream, buf: [u8; 1024], }  impl Socket { pub fn new(stream: TcpStream) -> Self {     Socket { stream, buf: [0; 1024] } } }  impl Socket {  pub async fn read_all(&mut self) -> Result<&str, Box<dyn Error>> { let n = self.stream.read(&mut self.buf).await?; Ok(std::str::from_utf8(&self.buf[..n])?) }  pub async fn write_all(&mut self, s: String) -> Result<(), Box<dyn Error>> { let x = format!(\"HTTP\/1.1 200 OK\\r\\nContent-Length: {}\\r\\n\\n\", s.len()); self.stream.write_all(&x.into_bytes()).await?; self.stream.write_all(&s.into_bytes()).await?; Ok(()) } } <\/code><\/pre>\n
\u041f\u0430\u0440\u0443 \u043c\u043e\u043c\u0435\u043d\u0442\u043e\u0432: 1) \u0434\u043e\u043f\u0443\u0441\u043a\u0430\u0435\u043c, \u0447\u0442\u043e \u0431\u0443\u0444\u0435\u0440 \u0432\u043c\u0435\u0441\u0442\u0438\u0442 \u0432\u0435\u0441\u044c \u0440\u0435\u043a\u0432\u0435\u0441\u0442 \u0432 \u0431\u0430\u0439\u0442\u0430\u0445, 2) \u0440\u0430\u0437\u043c\u0435\u0449\u0430\u0435\u043c \u0431\u0443\u0444\u0435\u0440 \u0432\u043c\u0435\u0441\u0442\u0435 \u0441 \u0441\u043e\u043a\u0435\u0442\u043e\u043c \u0438\u0437-\u0437\u0430 \u043f\u0440\u043e\u0441\u0442\u043e\u0442\u044b \u0438\u043c\u043f\u043b\u0435\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u0438, 3) \u0440\u0430\u0437\u043c\u0435\u0440 \u0431\u0443\u0444\u0435\u0440\u0430 \u0444\u0438\u043a\u0441\u0438\u0440\u043e\u0432\u0430\u043d \u0442\u0430\u043a\u0436\u0435 \u0434\u043b\u044f \u043f\u0440\u043e\u0441\u0442\u043e\u0442\u044b, 4) \u043c\u0438\u043d\u0438\u043c\u0430\u043b\u044c\u043d\u044b\u0435 \u0445\u0435\u0434\u0435\u0440\u0430.<\/p>\n
\u0421\u0430\u043c\u043e\u0435 \u0438\u043d\u0442\u0435\u0440\u0435\u0441\u043d\u043e\u0435 \u043d\u0430 \u0441\u0435\u0440\u0432\u0435\u0440\u0435 — \u0421\u0435\u0440\u0432\u0435\u0440.\u0440\u0441<\/p>\n
\/\/\/ server.rs  pub struct Server { listener: TcpListener, }  impl Server { pub async fn bind(addr: &str) -> Result<Server, Box<dyn Error>> { let listener = TcpListener::bind(&addr).await?;     println!(\"Listening on: {addr}\");     Ok(Server{listener}) }  pub async fn accept(&mut self, app: &'static App) -> Result<(), Box<dyn Error>> { loop { let (stream, _) = self.listener.accept().await?; tokio::spawn(async move { let mut p = Connection::new(stream); p.start(app).await.unwrap(); }); } } } <\/code><\/pre>\n
\u0420\u0435\u0431\u044f\u0442\u0430 \u0438\u0437 CrowCpp \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043b\u0438 \u0441\u0432\u043e\u0439 (\u043d\u0430 \u0431\u0430\u0437\u0435 boost::asio) \u0431\u0430\u043b\u0430\u043d\u0441\u0438\u0440\u043e\u0432\u0449\u0438\u043a \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438, \u0443 \u0440\u0430\u0441\u0442\u0430 \u043d\u0435\u043c\u043d\u043e\u0433\u043e \u0432\u0435\u0441\u0435\u043b\u0435\u0435 — \u0435\u0441\u0442\u044c tokio \u0440\u0430\u043d\u0442\u0430\u0439\u043c. \u042d\u0442\u043e \u0442\u0430\u043a\u043e\u0439 \u0440\u0430\u043d\u0442\u0430\u0439\u043c, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0431\u0435\u0440\u0435\u0442 \u043d\u0430 \u0441\u0435\u0431\u044f \u043a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0446\u0438\u044e \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0445 \u0442\u0430\u0441\u043a\u043e\u0432, \u0431\u0430\u043b\u0430\u043d\u0441\u0438\u0440\u043e\u0432\u043a\u0443 (\u0441\u0430\u043c\u0443\u044e \u0431\u0430\u0437\u043e\u0432\u0443\u044e) \u0438 \u0442.\u0434.<\/p>\n
\u0418\u0437 \u0434\u043e\u043a\u043e\u0432 tokio::spawn
 Spawning a task enables the task to execute concurrently to other tasks. The spawned task may execute on the current thread, or it may be sent to a different thread to be executed.<\/code><\/p>\n
\u0415\u0449\u0435 \u0434\u043e\u043a\u0438 \u043e \u0442\u043e\u043a\u0438\u0439\u0441\u043a\u043e\u043c \u0440\u0430\u043d\u0442\u0430\u0439\u043c\u0435:
 The multi-thread scheduler executes futures on a\u00a0thread pool, using a work-stealing strategy. By default, it will start a worker thread for each CPU core available on the system. This tends to be the ideal configuration for most applications.<\/code><\/p>\n
\u0422\u0430\u0441\u043a\u0438 \u0440\u0430\u043d\u0442\u0430\u0439\u043c\u0430 \u043d\u0435 \u043b\u044e\u0431\u044f\u0442 \u0431\u0440\u0430\u0442\u044c \u0434\u0430\u043d\u043d\u044b\u0435 \u0438\u0437\u0432\u043d\u0435, \u0438 \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u0430\u043f\u043f\u0435 \u043d\u0443\u0436\u043d\u043e \u043f\u0440\u0438\u0442\u0432\u043e\u0440\u0438\u0442\u044c\u0441\u044f \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u0435\u043c (\u0441\u043c. \u0432 \u043a\u043e\u0434\u0435 — \u0441\u0442\u0430\u0442\u0438\u043a \u0441\u0441\u044b\u043b\u043a\u0430 \u043f\u0440\u0438\u0431\u043b\u0438\u0437\u0438\u0442\u0435\u043b\u044c\u043d\u043e \u0440\u0430\u0432\u043d\u0430 \u0432\u044d\u043b\u044c\u044e \u0441 \u0442\u043e\u0447\u043a\u0438 \u0437\u0440\u0435\u043d\u0438\u044f \u0442\u0438\u043f\u043e\u0432) \u0438 \u043f\u0435\u0440\u0435\u043f\u0440\u044b\u0433\u043d\u0443\u0442\u044c \u0432 \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u0443\u044e \u0442\u0430\u0441\u043a\u0443. \u0418\u043c\u0435\u043d\u043e\u0432\u0430\u043d\u0438\u0435 \u043f\u0435\u0440\u0435\u043c\u0435\u043d\u043d\u043e\u0439 \u0434\u043b\u044f \u043d\u043e\u0432\u043e\u0433\u043e \u043a\u043e\u043d\u043d\u0435\u043a\u0448\u0435\u043d\u0430 \u0432\u0437\u044f\u043b \u0443 \u0440\u0435\u0431\u044f\u0442 \u0438\u0437 CrowCpp, \u043f\u043e\u0447\u0435\u043c\u0443-\u0442\u043e \u0442\u0430\u043a \u0438 \u043d\u0435 \u0441\u043c\u043e\u0433 \u043f\u0440\u0438\u0434\u0443\u043c\u0430\u0442\u044c \u043d\u0438\u0447\u0435\u0433\u043e \u043b\u0443\u0447\u0448\u0435 \ud83d\ude42<\/p>\n
\u0426\u0435\u043d\u0442\u0440\u0430\u043b\u044c\u043d\u0430\u044f \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u043a\u0430 — a\u043f\u043f.\u0440\u0441<\/p>\n
\/\/\/ app.rs  #[derive(Default)] pub struct App { map: Trie<fn(Request, Vec<RouteTokens>) -> String>, }  unsafe fn make_static<T>(t: &T) -> &'static T {     std::mem::transmute(t) }  impl App { pub async fn start(&self, addr: &str) -> Result<(), Box<dyn Error>> {     let mut server = Server::bind(addr).await?;     \/\/ safe: app should be alive before termination     server.accept(unsafe { make_static(self) }).await?;     Ok(()) }  pub async fn handle(&self, req: Request) -> String { let b = req.url.split('\/').filter(|s| !s.is_empty()); self.map.get(b) .map(|(fun, args)| fun(req, args)) .unwrap_or(\"Not found\".to_owned()) }  pub fn service(&mut self, key: &'static str, fun: fn(Request, Vec<RouteTokens>) -> String) { let b = key.split('\/').filter(|s| !s.is_empty()); self.map.insert(b, fun); } } <\/code><\/pre>\n
\u0422\u0443\u0442 \u044e\u0437\u0430\u0435\u043c \u043f\u0440\u0435\u0444\u0438\u043a\u0441\u043d\u043e\u0435 \u0434\u0435\u0440\u0435\u0432\u043e (Trie, \u043d\u0443\u0436\u043d\u043e\u0435 \u0434\u043b\u044f \u0440\u043e\u0443\u0442\u0435\u0440\u043e\u0432), \u0447\u0443\u0442\u044c-\u0447\u0443\u0442\u044c unsafe \u043a\u043e\u0434\u0430 (\u0438 \u043a\u043e\u043c\u043c\u0435\u043d\u0442, \u043f\u043e\u0447\u0435\u043c\u0443 \u044d\u0442\u043e OK) \u0438 \u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0435\u043d\u0438\u044f, \u0434\u043e\u0431\u0430\u0432\u043b\u0435\u043d\u043d\u044b\u0435 \u0441\u0438\u0441\u0442\u0435\u043c\u043e\u0439 \u0442\u0438\u043f\u043e\u0432: 1) fn(…) — \u0435\u0441\u0442\u044c non-capturing\u00a0closures, \u0442\u043e \u0435\u0441\u0442\u044c \u043b\u0430\u043c\u0431\u0434\u0435 \u043d\u0435 \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0442 \u0437\u0430\u0445\u0432\u0430\u0442\u0438\u0442\u044c \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442 \u0438\u0437\u0432\u043d\u0435, 2) key &’static str — \u043f\u0443\u0442\u044c \u0432 \u0440\u043e\u0443\u0442\u0435\u0440\u0435 \u043f\u0438\u0448\u0435\u043c (\u0432 \u0431\u043e\u043b\u044c\u0448\u0438\u043d\u0441\u0442\u0432\u0435 \u0441\u043b\u0443\u0447\u0430\u0435\u0432) \u0440\u0443\u0447\u043a\u0430\u043c\u0438 (\u0445\u0437, \u0445\u043e\u0440\u043e\u0448\u043e \u044d\u0442\u043e \u0438\u043b\u0438 \u043f\u043b\u043e\u0445\u043e, \u043d\u043e \u0434\u043b\u044f \u043f\u0440\u0438\u043c\u0435\u0440\u0430).<\/p>\n
\u041f\u0440\u0435\u0444\u0438\u043a\u0441\u043d\u043e\u0435 \u0434\u0435\u0440\u0435\u0432\u043e (\u043e\u043f\u044f\u0442\u044c \u0436\u0435, \u043f\u0440\u043e\u0441\u0442\u0435\u0439\u0448\u0430\u044f \u0438\u043c\u043f\u043b\u0435\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u044f)<\/p>\n
\/\/\/ trie.rs  pub struct Trie<T> { head: Node<T>,  }  struct Node<T> { value: Option<T>, map: HashMap<&'static str, Node<T>>  }  impl<T> Default for Trie<T> { fn default() -> Self { let head = Node { value: None, map: HashMap::new() }; Trie { head } } }  impl<T> Trie<T> { pub fn insert(&mut self, v: impl IntoIterator<Item = &'static str>, elem: T) { let mut node = &mut self.head; for s in v { if node.map.contains_key(s) {  node = node.map.get_mut(s).unwrap(); } else { let next = Node { value: None, map: HashMap::new() }; node.map.insert(s, next); node = node.map.get_mut(s).unwrap();  } } node.value = Some(elem); }  pub fn get<'a>(&self, v: impl IntoIterator<Item = &'a str>) -> Option<(&T, Vec<RouteTokens>)> { let mut node = &self.head; let mut args = vec![]; for s in v { let (s, token) = mapping(s); if node.map.contains_key(s) {  node = node.map.get(s).unwrap(); } else { return None; } if token != RouteTokens::NaN { args.push(token); } } node.value.as_ref().map(|elem| (elem, args)) } }  #[derive(Debug, PartialEq, Copy, Clone)] pub enum RouteTokens { Int(i32), Usize(usize), Float(f32), NaN }  fn mapping(s: &str) -> (&str, RouteTokens) { use RouteTokens::{ Int, Usize, Float, NaN }; let is_usize = s.starts_with(|c: char| c.is_ascii_digit()); \/\/ bug: fix me -> is_int let is_int = s.starts_with('-') && s[1..].starts_with(|c: char| c.is_ascii_digit()); let is_float = (is_usize || is_int) && s.contains('.'); match [is_float, is_usize, is_int] { [true, _, _] => (\"<float>\", Float(s.parse::<f32>().unwrap())), [_, true, _] => (\"<usize>\", Usize(s.parse::<usize>().unwrap())), [_, _, true] => (\"<int>\", Int(s.parse::<i32>().ok().unwrap())), _ => (s, NaN), } } <\/code><\/pre>\n
\u041f\u0440\u043e RouteTokens \u0431\u0443\u0434\u0435\u0442 \u0447\u0443\u0442\u044c \u043d\u0438\u0436\u0435. \u0421\u043e\u0431\u0438\u0440\u0430\u0435\u043c \u0434\u0430\u043d\u043d\u044b\u0435 (int, float \u0438 \u0442.\u0434.) \u0438\u0437 \u0443\u0440\u043b\u0430 \u0438 \u043f\u0435\u0440\u0435\u0434\u0430\u0435\u043c \u0432 \u0440\u0443\u0447\u043a\u0443. \u0420\u0435\u0431\u044f\u0442\u0430 \u0438\u0437 CrowCpp \u043f\u0440\u0438\u043c\u0435\u043d\u044f\u044e\u0442 \u0438\u043d\u0442\u0435\u0440\u0435\u0441\u043d\u0443\u044e \u043e\u043f\u0442\u0438\u043c\u0438\u0437\u0430\u0446\u0438\u044e: \u0441\u0436\u0438\u043c\u0430\u044e\u0442 \u043f\u0443\u0442\u044c \u0432 \u0434\u0435\u0440\u0435\u0432\u0435, \u0435\u0441\u043b\u0438 \u043d\u0430 \u043f\u0443\u0442\u0438 \u0443 \u043a\u0430\u0436\u0434\u043e\u0439 \u043d\u043e\u0434\u044b \u0442\u043e\u043b\u044c\u043a\u043e \u043e\u0434\u0438\u043d \u0447\u0430\u0439\u043b\u0434. \u0422\u043e \u0435\u0441\u0442\u044c \u043f\u043e\u043b\u0443\u0447\u0430\u0435\u043c \u0432\u0441\u0435\u0433\u043e \u043e\u0434\u0438\u043d \u0437\u0430\u043f\u0440\u043e\u0441 \u0432 \u0445\u0435\u0448\u0442\u0430\u0439\u0431\u043b \u043f\u043e \u043f\u043e\u043b\u043d\u043e\u043c\u0443 \u043f\u0443\u0442\u0438. (\u0412 \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u0438 \u0421rowCpp \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u0435\u0442\u0441\u044f \u0432\u0435\u043a\u0442\u043e\u0440 \u0432\u043c\u0435\u0441\u0442\u043e \u0445\u0435\u0448-\u0442\u0430\u0431\u043b\u0438\u0446\u044b — \u0442\u0430\u043c \u0431\u043e\u043b\u0435\u0435 \u0447\u0435\u0441\u0442\u043d\u0430\u044f \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044f Trie \ud83d\ude42 \u0415\u0449\u0435 \u043c\u043e\u043c\u0435\u043d\u0442 \u043f\u0440\u043e \u0430\u043b\u043b\u043e\u043a\u0430\u0446\u0438\u0438 — \u0432\u0441\u0435 \u0433\u043e\u0432\u043e\u0440\u044f\u0442, \u043a\u043e\u043f\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435 \u044d\u0442\u043e \u043f\u043b\u043e\u0445\u043e (\u0440\u0435\u0434\u043a\u043e, \u043f\u0440\u0430\u0432\u0434\u0430, \u0433\u043e\u0432\u043e\u0440\u044f\u0442, \u043d\u0430\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u043f\u043b\u043e\u0445\u043e), \u043d\u043e \u0447\u0438\u0441\u0442\u043e \u043f\u043e-\u0447\u0435\u043b\u043e\u0432\u0435\u0447\u0435\u0441\u043a\u0438 — \u0435\u0441\u043b\u0438 \u043c\u043e\u0436\u043d\u043e \u043d\u0435 \u0442\u0440\u0430\u0442\u0438\u0442\u044c \u0440\u0435\u0441\u0443\u0440\u0441\u044b, \u043b\u0443\u0447\u0448\u0435 \u0438\u0445 \u043d\u0435 \u0442\u0440\u0430\u0442\u0438\u0442\u044c (\u0441\u043c. \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441 IntoIterator).<\/p>\n
\u041c\u0430\u043a\u0440\u043e\u0441\u044b — \u0440\u043e\u0443\u0442\u0438\u043d\u0433.\u0440\u0441<\/p>\n
\/\/\/ routing.rs  #[macro_export] macro_rules! route {     ( $app:ident, $path:expr, || $handler:expr) => { $app.service( $path,  |_req, _args| $handler )      };     ( $app:ident, $path:literal, |$( $x:ident $(:$t:ty)? ),+| $handler:expr ) => {         {         $app.service(         $path,          |req, args| $crate::make_call![|$($x,)+| $handler, args, req]         )         }     }; }  #[macro_export] macro_rules! make_call {     (|$a:ident,| $handler:expr, $args:ident, $req: ident) => {{ (move |$a: Request|$handler)($req)     }};     (|$a:ident,$b:ident,| $handler:expr, $args:ident, $req:ident) => {{  (move |$a, $b: Request|$handler)($args[0], $req)     }};     (|$a:ident,$b:ident,$c:ident,| $handler:expr, $args:ident, $req:ident) => {{      (move |$a,$b,$c: Request|$handler)($args[0], $args[1], $req)     }}; } <\/code><\/pre>\n
\u041a\u043e\u0440\u0440\u0435\u043a\u0442\u043d\u043e\u0435 \u0438\u0441\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u0435 \u043c\u0430\u043a\u0440\u043e\u0441\u043e\u0432, \u043a\u0430\u043a \u043c\u043d\u0435 \u043a\u0430\u0436\u0435\u0442\u0441\u044f, \u0442\u0440\u0435\u0431\u0443\u0435\u0442 \u0440\u0430\u0431\u043e\u0442\u044b \u0441 \u043f\u043e\u0442\u043e\u043a\u043e\u043c \u0442\u043e\u043a\u0435\u043d\u043e\u0432 — \u0438 \u043f\u0440\u0435\u043a\u0440\u0430\u0441\u043d\u044b\u0439 \u0440\u0430\u0441\u0442 \u0434\u0430\u0435\u0442 \u0442\u0430\u043a\u0443\u044e \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e\u0441\u0442\u044c. \u041a \u0441\u043e\u0436\u0430\u043b\u0435\u043d\u0438\u044e, \u0442\u0440\u0435\u0431\u0443\u0435\u0442 \u0437\u0430\u043c\u043e\u0440\u043e\u0447\u0435\u043a \u0441 \u0441\u043e\u0437\u0434\u0430\u043d\u0438\u0435\u043c \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u043e\u0439 \u043b\u0438\u0431\u044b \u043f\u043e\u0434 \u043c\u0430\u043a\u0440\u043e\u0441 \u0438 \u0442.\u0434. \u041b\u043e\u0433\u0438\u043a\u0430 \u0432 \u0441\u043b\u0435\u0434\u0443\u044e\u0449\u0435\u043c — \u043f\u0430\u0440\u0441\u0438\u043c \u0441\u0442\u0440\u043e\u043a\u0443 \u0440\u043e\u0443\u0442\u0430, \u043f\u0440\u043e\u043a\u0438\u0434\u044b\u0432\u0430\u0435\u043c \u0442\u0438\u043f\u044b \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440\u043e\u0432 \u0432 \u0430\u043d\u043e\u043d\u0438\u043c\u043d\u0443\u044e \u0444\u0443\u043d\u043a\u0446\u0438\u044e. \u041a \u0441\u0447\u0430\u0441\u0442\u044c\u044e, \u0443 \u0440\u0430\u0441\u0442\u0430 \u0435\u0441\u0442\u044c \u0438 \u043f\u0440\u043e\u0441\u0442\u044b\u0435 \u043c\u0430\u043a\u0440\u043e\u0441\u044b (\u043a\u0430\u043a \u043f\u0440\u0435\u0434\u0441\u0442\u0430\u0432\u043b\u0435\u043d\u043e \u0432\u044b\u0448\u0435) — \u0442\u0438\u043f \u0430\u0440\u0433\u0443\u043c\u0435\u043d\u0442\u0430, \u043a \u0441\u043e\u0436\u0430\u043b\u0435\u043d\u0438\u044e, \u0443 \u0432\u0441\u0435\u0445 \u043a\u0440\u043e\u043c\u0435 \u043f\u043e\u0441\u043b\u0435\u0434\u043d\u0435\u0433\u043e \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440\u0430 \u0431\u0443\u0434\u0435\u0442 RouteTokens (Int(i32), Float(f32) \u0438 \u0442.\u0434.), \u0438 \u044d\u0442\u043e \u043c\u043e\u0436\u043d\u043e \u0443\u043b\u0443\u0447\u0448\u0438\u0442\u044c (\u0441\u0435\u0439\u0447\u0430\u0441 \u0442\u0443\u043f\u043e \u043b\u0435\u043d\u044c) \u043f\u0440\u043e\u0434\u0432\u0438\u043d\u0443\u0442\u044b\u043c \u043c\u0430\u043a\u0440\u043e\u0441\u043e\u043c (\u0432 \u0440\u0430\u0441\u0442\u0435 \u043e\u043d \u043d\u0430\u0437\u044b\u0432\u0430\u0435\u0442\u0441\u044f procedural macros, \u0430 \u043c\u0430\u043a\u0440\u043e\u0441\u044b \u0432\u044b\u0448\u0435 — declarative\u00a0macros).<\/p>\n
\u041d\u0430\u043a\u043e\u043d\u0435\u0446, \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u0438\u0439 \u043a\u043e\u0434 — \u043c\u044d\u0439\u043d.\u0440\u0441<\/p>\n
\/\/\/ main.rs  #[tokio::main] async fn main() -> Result<(), Box<dyn Error>> {     let addr = env::args()         .nth(1)         .unwrap_or_else(|| \"0.0.0.0:8080\".to_owned());          let mut app = App::default();      route![app, \"\/\", || \"Hello world\".to_owned()];     route![app, \"\/products\/<usize>\", |id,req| { format!(\"url {:?} and id {:?}\", req.url, id) }];     route![app, \"\/measure\/<float>\/and\/<int>\", |x,y,_req| format!(\"{:?} and {:?}\", x, y)];     route![app, \"\/pong\/\", |req| format!(\"XXX {:?}\", req.body) ];      app.start(&addr).await?;     Ok(()) }  <\/code><\/pre>\n
\u041f\u0440\u043e\u0441\u0442\u0435\u0439\u0448\u0438\u0439 \u0441\u0435\u0440\u0432\u0435\u0440 \u0433\u043e\u0442\u043e\u0432 \ud83d\ude42<\/p>\n
\u0427\u0430\u0441\u0442\u044c 2: \u041d\u0435\u0447\u0435\u0433\u043e \u0442\u0435\u0440\u044f\u0442\u044c<\/h3>\n
\u041c\u044b \u0447\u0442\u043e-\u0442\u043e \u043f\u043e\u0442\u0435\u0440\u044f\u043b\u0438, \u0442\u043e\u0447\u043d\u0435\u0435, \u043e\u043f\u0443\u0441\u0442\u0438\u043b\u0438 \u043d\u0435\u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043f\u0443\u0431\u043b\u0438\u0447\u043d\u044b\u0435 (\u0438 \u043d\u0435 \u0442\u043e\u043b\u044c\u043a\u043e) \u043f\u043e\u043b\u044f \u043e\u0431\u044c\u0435\u043a\u0442\u043e\u0432 \u0432 \u043f\u0435\u0440\u0432\u043e\u043c \u043f\u0440\u0438\u0431\u043b\u0438\u0436\u0435\u043d\u0438\u0438. \u0414\u043b\u044f \u0440\u0430\u0431\u043e\u0447\u0435\u0433\u043e \u043f\u0440\u043e\u0442\u043e\u0442\u0438\u043f\u0430 \u043e\u043d\u0438 \u0431\u044b\u043b\u0438 \u043d\u0435 \u043e\u0441\u043e\u0431\u043e \u043d\u0443\u0436\u043d\u044b, \u043d\u043e \u0441\u0435\u0439\u0447\u0430\u0441 \u0441\u0430\u043c\u043e\u0435 \u0432\u0440\u0435\u043c\u044f. \u0421\u043c\u043e\u0442\u0440\u0438\u043c \u0432 \u043a\u043e\u0434.<\/p>\n
\u0417\u0430\u043c\u0435\u0442\u043a\u0438 \u043d\u0430 \u043f\u043e\u043b\u044f\u0445 (\u043e\u0447\u0435\u043d\u044c \u043a\u043e\u0440\u043e\u0442\u043a\u043e), \u043a\u0430\u043a\u0438\u0435 \u0435\u0449\u0435 \u0444\u0438\u0447\u0438 \u0432 \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u0438:<\/p>\n
http_request.h — \u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043c\u0438\u0434e\u043b\u0432a\u044d\u0440
 http_response.h — \u0434\u043e\u043f\u0443\u0441\u043a\u0430\u0435\u043c, \u0447\u0442\u043e \u0440\u0435\u0441\u043f\u043e\u043d\u0441 \u0443 \u043d\u0430\u0441 \u0442\u043e\u043b\u044c\u043a\u043e \u0441\u0442\u0440\u043e\u043a\u043e\u0439 — \u043f\u0440\u043e\u043f\u0443\u0441\u043a\u0430\u0435\u043c (\u043d\u0443 \u0442\u0430\u043c \u043d\u0435 \u043c\u043d\u043e\u0433\u043e \u0438\u043d\u0442\u0435\u0440\u0435\u0441\u043d\u043e\u0433\u043e, \u0435\u0441\u043b\u0438 \u0447\u0435\u0441\u0442\u043d\u043e)<\/p>\n
http_connection.h — 1) \u0442\u0430\u0439\u043c\u0430\u0443\u0442 \u0442\u0430\u0439\u043c\u0435\u0440 (\u0441 \u043e\u0431\u044f\u0437\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u043c \u043a\u043e\u043c\u043c\u0435\u043d\u0442\u0430\u0440\u0438\u0435\u043c \u0442\u0443\u0434\u0443, \u043a\u0430\u043a \u0443\u043b\u0443\u0447\u0448\u0438\u0442\u044c), 2) \u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043c\u0438\u0434e\u043b\u0432a\u044d\u0440<\/p>\n
http_server.h — \u0442\u0438\u043a_\u0438\u043d\u0442\u0435\u0440\u0432\u0430\u043b \u0438 \u043a\u043e\u043b\u043b\u0431\u0435\u043a \u0441 \u043d\u0438\u043c, \u043c\u0443\u0442\u0435\u043a\u0441\u044b, \u0442\u0430\u0441\u043a_\u0442\u0430\u0439\u043c\u0435\u0440_\u043f\u0443\u043b — \u043d\u0435 \u043f\u043e\u043d\u0430\u0434\u043e\u0431\u044f\u0442\u0441\u044f \u0432 \u043d\u0430\u0448\u0435\u0439 \u0432\u0435\u0440\u0441\u0438\u0438. \u0427\u0442\u043e \u043f\u043e\u043d\u0430\u0434\u043e\u0431\u0438\u0442\u0441\u044f: \u0442\u0430\u0439\u043c-\u0430\u0443\u0442, \u0441\u0438\u0433\u043d\u0430\u043b\u044b \u0438 \u043c\u0438\u0434e\u043b\u0432a\u044d\u0440.<\/p>\n
app.h — \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0438 \u0438 \u043d\u0430\u0434\u0441\u0442\u0440\u043e\u0439\u043a\u0438 \u043d\u0430\u0434 \u0441\u0435\u0440\u0432\u0435\u0440\u043e\u043c<\/p>\n
routing.h — blueprint (\u0433\u0440\u0443\u0431\u043e \u0433\u043e\u0432\u043e\u0440\u044f, \u043f\u0430\u0447\u043a\u0430 \u0440\u043e\u0443\u0442\u0435\u0440\u043e\u0432 \u043f\u043e\u0434 \u043e\u0431\u0449\u0438\u043c \u043f\u0440\u0435\u0444\u0438\u043a\u0441\u043e\u043c) — \u0441\u043a\u043e\u0440\u0435\u0435 \u0432\u0441\u0435\u0433\u043e, \u0434\u0435\u043b\u0430\u0442\u044c \u043d\u0435 \u0431\u0443\u0434\u0435\u043c (\u043b\u0435\u043d\u044c)<\/p>\n
\u041c\u0438\u0434\u0435\u043b\u0432\u0430\u044d\u0440<\/p>\n
pub trait Middleware: Default + Send + Sync + 'static {     fn run(&self, req: &mut Request); }  pub trait Router {     fn handle(&self, req: Request) -> impl Future<Output = String> + Send; }  \/\/\/ app.rs \/\/\/ --** some code before **--  macro_rules! routes_impls {     ( $x:ident, $( $y:ident $(,)?)* ) => {         impl<$x: Middleware, $( $y: Middleware ),*> Router for &App<($x, $( $y ),*)> { fn handle(&self, mut req: Request) -> impl Future<Output = String> + Send { req.context = Some(HashMap::new()); $x::default().run(&mut req); $( $y::default().run(&mut req); )* App::<($x, $( $y ),*)>::handle(self, req) }         }         routes_impls!($( $y, )*);     };      () => { impl Router for &App<()> { fn handle(&self, req: Request) -> impl Future<Output = String> + Send { App::<()>::handle(self, req) } }     }; }  routes_impls![A,B,C,D, E,F,G,H, I,J,K,L, M,N,O,P,Q];   \/\/\/ request.rs  #[derive(Default, Debug)] pub struct Request { \/\/ *( some code before )*  pub context: Option<HashMap<TypeId, Box<dyn Any + Send>>>, }  <\/code><\/pre>\n
\u0421\u043e\u043e\u0442\u0432\u0435\u0442\u0441\u0442\u0432\u0435\u043d\u043d\u043e \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u0430\u044f \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u043a\u0430, \u043a\u043e\u0442\u043e\u0440\u0430\u044f \u0445\u043e\u0447\u0435\u0442 \u043f\u0435\u0440\u0435\u0445\u0432\u0430\u0442\u044b\u0432\u0430\u0442\u044c \u0440\u0435\u043a\u0432\u0435\u0441\u0442, \u0438\u043c\u043f\u043b\u0435\u043c\u0435\u043d\u0442\u0438\u0442 \u0442\u0440\u0430\u0439\u0442 \u041c\u0438\u0434e\u043b\u0432\u0430\u044d\u0440. \u0414\u0430\u043b\u0435\u0435 \u043f\u0435\u0440\u0435\u0434\u0430\u0435\u043c \u0442\u0438\u043f \u043d\u0430\u0448\u0435\u0439 \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u043a\u0438 \u0432 \u0430\u043f\u043f\u0443 — \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440 App<(CORS, Xkey, CookieParser)> — \u043f\u0440\u043e\u0444\u0438\u0442.<\/p>\n
\u0412 \u0440\u0430\u0441\u0442\u0435, \u043a \u0441\u043e\u0436\u0430\u043b\u0435\u043d\u0438\u044e, \u043d\u0435\u0442 variadic template — \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u0440\u0435\u0430\u043b\u0438\u0437\u0443\u0435\u043c \u043c\u0430\u0441\u0441\u0438\u0432 \u0434\u0436\u0435\u043d\u0435\u0440\u0438\u043a\u043e\u0432 \u0442\u0430\u043f\u043b\u0430\u043c\u0438 (tuple) \u0440\u0430\u0437\u043b\u0438\u0447\u043d\u043e\u0439 \u0434\u043b\u0438\u043d\u044b. \u0412 \u043a\u043e\u0434\u0435 \u0432\u044b\u0448\u0435 \u0441 \u043f\u043e\u043c\u043e\u0449\u044c\u044e \u043c\u0430\u043a\u0440\u043e\u0441\u043e\u0432 \u043f\u0440\u0435\u0434\u0441\u0442\u0430\u0432\u043b\u0435\u043d\u0430 \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044f \u0434\u043e 17 \u0430\u0440\u0433\u0443\u043c\u0435\u043d\u0442\u043e\u0432 \u0432 \u0442\u0430\u043f\u043b\u0435.<\/p>\n
\u0414\u043b\u044f \u043f\u0440\u043e\u0431\u0440\u0430\u0441\u044b\u0432\u0430\u043d\u0438\u044f \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442\u0430 \u0432 \u043c\u0438\u0434\u0435\u043b\u0432\u0430\u044d\u0440\u0430\u0445 \u043d\u0443\u0436\u043d\u043e \u043a\u0430\u043a\u0438\u043c-\u0442\u043e \u043e\u0431\u0440\u0430\u0437\u043e\u043c \u0432\u044b\u0440\u0435\u0437\u0430\u0442\u044c \u0442\u0438\u043f \u0434\u0430\u043d\u043d\u044b\u0445 — \u0442\u0430\u043a \u043a\u0430\u043a \u043a\u0430\u0436\u0434\u0430\u044f \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u043a\u0430 \u0437\u0430\u0445\u043e\u0447\u0435\u0442 \u0437\u0430\u044e\u0437\u0430\u0442\u044c \u0441\u0432\u043e\u0439 \u0437\u0430\u0440\u0430\u043d\u0435\u0435 \u043d\u0435 \u0438\u0437\u0432\u0435\u0441\u0442\u043d\u044b\u0439 \u0442\u0438\u043f. \u0412 \u0440\u0430\u0441\u0442\u0435 \u0434\u043b\u044f \u044d\u0442\u0438\u0445 \u0446\u0435\u043b\u0435\u0439 \u0441\u0443\u0449\u0435\u0441\u0442\u0432\u0443\u0435\u0442 \u0437\u0430\u043c\u0435\u0447\u0430\u0442\u0435\u043b\u044c\u043d\u044b\u0439 Any, \u043f\u043b\u044e\u0441 \u043a\u0430\u0436\u0434\u044b\u0439 \u0442\u0438\u043f \u0438\u043c\u0435\u0435\u0442 \u0443\u043d\u0438\u043a\u0430\u043b\u044c\u043d\u044b\u0439 \u0438\u0434\u0435\u043d\u0442\u0438\u0444\u0438\u043a\u0430\u0442\u043e\u0440 — \u0442\u043e \u0435\u0441\u0442\u044c \u0432\u044b\u0431\u043e\u0440 \u0445\u0435\u0448 \u0442\u0430\u0431\u043b\u0438\u0446\u044b (\u043a\u0430\u043a\u043e\u0433\u043e \u043b\u0438\u0431\u043e \u043c\u0430\u043f\u043f\u0438\u043d\u0433\u0430 typeId -> type) \u043d\u0430\u043f\u0440\u0430\u0448\u0438\u0432\u0430\u0435\u0442\u0441\u044f \u0441\u0430\u043c \u0441\u043e\u0431\u043e\u0439.<\/p>\n
\u041d\u043e\u0432\u043e\u0435 \u043d\u0430 \u0441\u0435\u0440\u0432\u0435\u0440\u0435<\/p>\n
\/\/\/ server.rs impl Server {  \/\/\/ --&&-- some code before --&&--   pub async fn accept(&mut self, app: impl Router + Send + Copy + 'static) -> Result<(), Box<dyn Error>> { self.listen_signals(); loop { let (stream, _) = self.listener.accept().await?; let task = tokio::spawn(timeout(self.timeout, async move { let mut p = Connection::new(stream); p.start(app).await.unwrap(); })); self.register(task); } }  pub async fn shutdown(&mut self) { for t in self.tasks.drain(..) { let _ = t.await; } }  fn register(&mut self, t: JoinHandle<Result<(), error::Elapsed>>) { self.tasks.push(t); let (k, next_round) = self._counter.overflowing_add(1); self._counter = k; if next_round { self.tasks.retain(|t| !t.is_finished()); } }  fn listen_signals(&mut self) { \/\/ safe: `server` should be alive before termination let this = unsafe { make_mut_static(self) }; tokio::spawn(async move {     tokio::signal::ctrl_c().await.unwrap();     println!(\"\\nCTRL-C\");     println!(\"Shutdown... waiting for the tasks to complete\");     this.shutdown().await;     println!(\"Done, thx :)\");     std::process::exit(0); }); } }  <\/code><\/pre>\n
\u0422\u0443\u0442 \u044e\u0437\u0430\u0435\u043c \u0441\u0438\u0433\u043d\u0430\u043b\u044b \u0438 \u0442\u0430\u0439\u043c\u0430\u0443\u0442-\u043e\u0431\u0435\u0440\u0442\u043a\u0443 \u043d\u0430\u0434 \u0444\u044c\u044e\u0447\u0435\u0440\u0441\u0430\u043c\u0438 \u0438\u0437 \u0442\u043e\u043a\u0438\u043e, \u0447\u0443\u0442\u044c-\u0447\u0443\u0442\u044c \u043e\u043f\u0442\u0438\u043c\u0438\u0437\u0438\u0440\u0443\u0435\u043c \u043e\u0441\u0442\u0430\u043d\u043e\u0432\u043a\u0443 \u0441\u0435\u0440\u0432\u0435\u0440\u0430 (\u043e\u0436\u0438\u0434\u0430\u043d\u0438\u0435\u043c \u0432\u0441\u0435\u0445 \u0442\u0430\u0441\u043e\u043a \u0438\u0437 \u043e\u0447\u0435\u0440\u0435\u0434\u0438) \u0438 \u0432 \u043f\u0440\u0438\u043d\u0446\u0438\u043f\u0435 \u0432\u0441\u0435 \ud83d\ude42<\/p>\n
\u041d\u0435\u0431\u043e\u043b\u044c\u0448\u043e\u0439 \u0434\u0438\u0441\u043a\u043b\u0435\u0439\u043c\u0435\u0440: \u0443\u0447\u0435\u0431\u043d\u044b\u0439 \u043f\u0440\u043e\u0435\u043a\u0442 \u043d\u0435 \u043f\u043e\u043a\u0440\u044b\u0432\u0430\u0435\u0442 (\u0438 \u043d\u0435 \u0445\u043e\u0447\u0435\u0442 \u043f\u043e\u043a\u0440\u044b\u0432\u0430\u0442\u044c) \u0432\u0435\u0431\u0441\u043e\u043a\u0435\u0442\u044b — \u0447\u0442\u043e \u0441\u0438\u043b\u044c\u043d\u043e \u043e\u0431\u043b\u0435\u0433\u0447\u0430\u0435\u0442 \u043a\u0430\u043a \u0447\u0442\u0435\u043d\u0438\u0435, \u0442\u0430\u043a \u0438 \u0440\u0435\u0430\u043b\u0438\u0437\u0430\u0446\u0438\u044e. \u0427\u0438\u0442\u0430\u0442\u0435\u043b\u044c, \u0436\u0435\u043b\u0430\u044e\u0449\u0438\u0439 \u043e\u0446\u0435\u043d\u0438\u0442\u044c \u0441\u043b\u043e\u0436\u043d\u043e\u0441\u0442\u044c \u0442\u0435\u043c\u044b \u043f\u0440\u0438\u0433\u043b\u0430\u0448\u0430\u0435\u0442\u0441\u044f \u0432 \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u0439 cppCrow.<\/p>\n
\u0427\u0430\u0441\u0442\u044c 3: \u041e\u0431\u043c\u0435\u0440\u043a\u0438<\/h3>\n
\u041d\u0430\u0441\u0442\u0430\u043b\u043e \u0432\u0440\u0435\u043c\u044f \u043c\u0435\u0440\u0438\u0442\u044c\u0441\u044f: c\u0440\u0430\u0432\u043d\u0438\u0432\u0430\u0435\u043c «hello world» \u0438 «\u0434\u0432\u0430 \u043f\u043b\u044e\u0441 \u0434\u0432\u0430» \u0430\u0440\u0433\u0443\u043c\u0435\u043d\u0442\u044b \u0438\u0437 \u0443\u0440\u043b\u0430. \u0414\u043e\u0431\u0430\u0432\u0438\u043c nodejs (\u0432\u0435\u0440\u0441\u0438\u0438 20) \u0437\u0430 \u0431\u0430\u0437\u0443 \u0434\u043b\u044f \u0441\u0440\u0430\u0432\u043d\u0435\u043d\u0438\u044f (\u0440\u0435\u0431\u044f\u0442\u0430 \u0438\u0437 crowCpp \u0433\u043e\u0432\u043e\u0440\u044f\u0442, \u0447\u0442\u043e \u0440\u0432\u0443\u0442 \u043d\u043e\u0434\u0443 \u0432 \u0445\u043b\u0430\u043c). \u041d\u0435 \u0437\u0430\u0431\u044b\u0432\u0430\u0435\u043c, \u0447\u0442\u043e \u0443\u0447\u0435\u0431\u043d\u044b\u0439 \u043f\u0440\u043e\u0435\u043a\u0442 \u043c\u0435\u0434\u043b\u0435\u043d\u043d\u0435\u0435 \u0433\u043e\u0442\u043e\u0432\u043e\u0433\u043e \u043f\u0440\u043e\u0434\u0430\u043a\u0448\u043d-\u0440\u0435\u0448\u0435\u043d\u0438\u044f. \u0421\u0447\u0438\u0442\u0430\u0435\u043c \u043f\u0440\u0438\u0431\u043b\u0438\u0437\u0438\u0442\u0435\u043b\u044c\u043d\u043e (\u0434\u043b\u044f \u043b\u044e\u0431\u0438\u0442\u0435\u043b\u0435\u0439 \u0442\u043e\u0447\u043d\u044b\u0445 \u0434\u0430\u043d\u043d\u044b\u0445 \u0432 \u0440\u0435\u043f\u0435 cppCrow \u0435\u0441\u0442\u044c \u0441\u0441\u044b\u043b\u043a\u0438 \u043d\u0430 \u043f\u0440\u0430\u0432\u0438\u043b\u044c\u043d\u044b\u0435 \u0431\u0435\u043d\u0447\u043c\u0430\u0440\u043a\u0438) \u0438 (\u0435\u0449\u0435 \u0440\u0430\u0437) \u043e\u0442\u043d\u043e\u0441\u0438\u0442\u0435\u043b\u044c\u043d\u043e nodejs.<\/p>\n
ab -n 32768 -c 128 \"http:\/\/0.0.0.0:18080\/\"<\/code><\/p>\n
\u041f\u0430\u0440\u0430\u043c\u0435\u0442\u0440 «\u0426\u044d»
 -c concurrency\u00a0 Number of multiple requests to make at a time<\/code><\/p>\n
\u0420\u0435\u0437\u0443\u043b\u044c\u0442\u0430\u0442\u044b:<\/p>\n
nodejs c=128 -> OK nodejs c=256 -> Err  candidate c=128 -> OK candidate c=256 -> OK candidate c=512 -> Err  canditate without timeout c=512 -> OK canditate without timeout c=625 -> OK canditate without timeout c=725 -> Err  cppCrow c=128 -> OK cppCrow c=256 -> OK cppCrow c=512 -> OK cppCrow c=725 -> OK cppCrow c=1024 -> Err <\/code><\/pre>\n
\u0422\u0443\u0442 \u0441\u0442\u043e\u0438\u0442 \u043e\u0442\u043c\u0435\u0442\u0438\u0442\u044c \u0447\u0442\u043e \u043e\u0431\u0435\u0440\u0442\u043a\u0430 timeout \u0442\u0430\u043a \u043d\u0435\u0445\u0438\u043b\u043e \u0441\u044c\u0435\u0434\u0430\u0435\u0442 \u043f\u0440\u043e\u0438\u0437\u0432\u043e\u0434\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u044c.<\/p>\n
\u041a\u043e\u0434 \u043a\u043b\u0438\u0435\u043d\u0442\u043e\u0432:<\/p>\n
app.get('\/', (req, res) => {   \u00a0\u00a0res.send('Hello World!')   })      app.get('\/:a\/plus\/:b', (req, res) => {   \u00a0\u00a0let a = Number(req.params.a)   \u00a0\u00a0let b = Number(req.params.b)   \u00a0\u00a0res.send(`${a+b}`)   })    const port = 18080 app.listen(port, () => {   \u00a0\u00a0console.log(`Example app listening on port ${port}`)   }) <\/code><\/pre>\n
int main() {     crow::SimpleApp app;      CROW_ROUTE(app, \"\/\")([](){         return \"Hello world\";     });      CROW_ROUTE(app,\"\/<int>\/plus\/<int>\")     ([](int a, int b){         std::ostringstream os;         os << a+b;         return crow::response(os.str());     });      app.port(18080).multithreaded().run(); } <\/code><\/pre>\n
#[tokio::main] async fn main() -> Result<(), Box<dyn Error>> {     let addr = env::args()         .nth(1)         .unwrap_or_else(|| \"0.0.0.0:18080\".to_owned());          let mut app = SimpleApp::default();          route![app, \"\/\", || \"Hello world\".to_owned()];          route![app, \"<usize>\/plus\/<usize>\", |a,b,_req| {          use RouteTokens::Usize;         match (a,b) {             (Usize(x), Usize(y)) => format!(\"{}\", x+y),             _ => panic!(\"hmm...\"),         }     }];      app.start(&addr).await?;     Ok(()) }  <\/code><\/pre>\n
\u0421\u0430\u043c\u044b\u0439 \u043b\u0435\u0433\u043a\u0438\u0439 \u0438\u0442\u043e\u0433: \u0432 \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0435 \u043f\u0440\u043e\u0435\u043a\u0442\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f \u0437\u0430\u0445\u043e\u0442\u0435\u043b\u043e\u0441\u044c \u0447\u0443\u0442\u044c \u0431\u043e\u043b\u0435\u0435 \u043f\u043e\u0434\u0440\u043e\u0431\u043d\u043e \u0432\u0437\u0433\u043b\u044f\u043d\u0443\u0442\u044c \u043d\u0430 \u0441\u0442\u0435\u043a \u0442\u043e\u043a\u0438\u043e, \u043d\u0430\u0434\u0435\u044e\u0441\u044c, \u0432\u0430\u0441 \u0442\u043e\u0436\u0435 \u0432\u0434\u043e\u0445\u043d\u043e\u0432\u0438\u0442 \u043f\u043e\u0438\u0437\u0443\u0447\u0430\u0442\u044c \u043d\u0430 \u0434\u043e\u0441\u0443\u0433\u0435 \u043a\u0430\u043a\u043e\u0439-\u043b\u0438\u0431\u043e \u043f\u0440\u043e\u0435\u043a\u0442\u0438\u043a \ud83d\ude42<\/p>\n<\/div>\n<\/div>\n<\/div>\n
<\/div>\n

 \u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b \u0441\u0442\u0430\u0442\u044c\u0438  https:\/\/habr.com\/ru\/articles\/874760\/<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"
<\/div>\n
\n
\n
\n
\n
\u0420\u0430\u0441\u0442 \u0445\u043e\u0440\u043e\u0448, \u0432\u0441\u0435 \u044d\u0442\u043e \u0437\u043d\u0430\u044e\u0442. \u0418\u043d\u0432\u0435\u0441\u0442\u0438\u0440\u0443\u0435\u0448\u044c \u0432\u0440\u0435\u043c\u044f \u0432 \u044f\u0437\u044b\u043a \u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f, \u043a\u0430\u0439\u0444\u0443\u0435\u0448\u044c, \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0448\u044c c \u0440\u0438\u0441\u043a\u0430\u043c\u0438, \u0437\u0430\u0434\u0430\u0435\u0448\u044c\u0441\u044f \u0432\u043e\u043f\u0440\u043e\u0441\u043e\u043c — \u0430 \u043c\u043e\u0436\u0435\u0442, \u0440\u0430\u0441\u0442 \u0435\u0449\u0435 \u043a\u0440\u0443\u0447\u0435? \u041f\u043e\u0447\u0435\u043c\u0443 \u0431\u044b, \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u043d\u0435 \u0438\u0437\u0443\u0447\u0438\u0442\u044c \u0441\u043e\u043b\u0438\u0434\u043d\u044b\u0439 \u043f\u0440\u043e\u0435\u043a\u0442 \u043d\u0430 \u043f\u043b\u044e\u0441\u0430\u0445 (5k \u0437\u0432\u0435\u0437\u0434 \u043d\u0430 \u0433\u0438\u0442\u0445\u0430\u0431\u0435) — \u0438 \u043c\u0438\u0433\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0435\u0433\u043e. \u0412\u0440\u043e\u0434\u0435, \u0432\u0441\u0435 \u0442\u0430\u043a \u0434\u0435\u043b\u0430\u044e\u0442, \u043d\u043e \u043c\u043e\u0436\u0435\u0442, \u0441\u0443\u0442\u044c \u0432 \u043c\u0438\u0433\u0440\u0430\u0446\u0438\u0438 \u0438\u0434\u0435\u0439, \u0430 \u043d\u0435 \u043a\u043e\u0434\u0430. \u0411\u044b\u0442\u044c \u043c\u043e\u0436\u0435\u0442, \u043c\u044b \u043d\u0430\u0439\u0434\u0435\u043c \u043e\u0442\u0432\u0435\u0442\u044b \u043e \u0432\u044b\u0440\u0430\u0437\u0438\u0442\u0435\u043b\u044c\u043d\u043e\u0441\u0442\u0438 \u044f\u0437\u044b\u043a\u0430, \u0447\u0438\u0442\u0430\u0435\u043c\u043e\u0441\u0442\u0438 \u0438 \u0441\u043a\u043e\u0440\u043e\u0441\u0442\u0438 \u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c\u044b. \u0412\u043e\u0437\u043c\u043e\u0436\u043d\u043e, \u043d\u0430\u043c \u0441\u0442\u0430\u043d\u0435\u0442 \u044f\u0441\u043d\u043e — \u0430 \u0434\u0440\u0443\u0433 \u043b\u0438 \u043d\u0430\u0448 \u043a\u043e\u043c\u043f\u0438\u043b\u044f\u0442\u043e\u0440, \u043d\u043e \u0441\u043a\u043e\u0440\u0435\u0435 \u0432\u0441\u0435\u0433\u043e, \u043c\u044b \u043d\u0430\u0441\u043b\u0430\u0434\u0438\u043c\u0441\u044f \u044d\u0441\u0442\u0435\u0442\u0438\u043a\u043e\u0439 \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0430 \u043f\u0440\u043e\u0435\u043a\u0442\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f \u043f\u0440\u0438\u043b\u043e\u0436\u0435\u043d\u0438\u044f \u043d\u0430 \u0440\u0430\u0441\u0442e.<\/p>\n
\u0421\u0442\u0440\u0430\u043d\u0430 \u0431\u043e\u0433\u0430\u0442\u0430 \u0438\u0434\u0435\u044f\u043c\u0438, \u043a\u0430\u043a \u0447\u0438\u0442\u0430\u0442\u044c \u043a\u043e\u0434: \u0431\u043b\u043e\u043a-\u0441\u0445\u0435\u043c\u044b, \u043a\u043e\u043d\u0446\u0435\u043f\u0442\u0443\u0430\u043b\u044c\u043d\u044b\u0435 \u043c\u043e\u0434\u0435\u043b\u0438, \u0444\u0430\u0439\u043b \u0447\u0435\u0440\u0435\u0437 \u0444\u0430\u0439\u043b \u0438 \u0442.\u0434. \u041a \u0441\u043e\u0436\u0430\u043b\u0435\u043d\u0438\u044e, \u0440\u0430\u0431\u043e\u0447\u0438\u0439 \u0434\u043b\u044f \u043c\u0435\u043d\u044f \u043c\u0435\u0442\u043e\u0434 — \u044d\u0442\u043e \u0447\u0442\u0435\u043d\u0438\u0435 \u0432\u0441\u0435\u0433\u043e \u043f\u043e\u0434\u0440\u044f\u0434. \u042f \u0432\u044b\u0431\u0440\u0430\u043b \u0442\u0435\u043c\u0443, \u043e \u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u0431\u043e\u043b\u044c\u0448\u0438\u043d\u0441\u0442\u0432\u043e \u0440\u0430\u0437\u0440\u0430\u0431\u043e\u0442\u0447\u0438\u043a\u043e\u0432 \u0441\u043b\u044b\u0448\u0430\u043b\u0438 \u0442\u043e\u0447\u043d\u043e (\u0445\u043e\u0442\u044f \u0431\u044b \u043a\u0440\u0430\u0435\u043c \u0443\u0445\u0430): \u0432\u0435\u0431-\u0441\u0435\u0440\u0432\u0435\u0440\u0430. \u0414\u0430\u043b\u0435\u0435 \u0432 \u0442\u0435\u043a\u0441\u0442\u0435 \u0431\u0443\u0434\u0435\u043c \u0430\u043d\u0430\u043b\u0438\u0437\u0438\u0440\u043e\u0432\u0430\u0442\u044c, \u043a\u0430\u043a \u0443\u0441\u0442\u0440\u043e\u0435\u043d \u0432\u0435\u0431 \u0441\u0435\u0440\u0432\u0435\u0440 crowCpp (\u0441\u0441\u044b\u043b\u043a\u0430 \u0431\u0443\u0434\u0435\u0442 \u043d\u0438\u0436\u0435) \u0438 \u043c\u0438\u0433\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c (\u0441\u043a\u043e\u0440\u0435\u0435 \u0432\u043e\u043f\u043b\u043e\u0449\u0430\u0442\u044c \u0435\u0433\u043e \u0438\u0434\u0435\u0438) \u043d\u0430 \u044f\u0437\u044b\u043a \u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f \u0440\u0430\u0441\u0442.<\/p>\n
\u041e\u0447\u0435\u043d\u044c \u043a\u0440\u0430\u0442\u043a\u043e \u0437\u0430\u043c\u0435\u0442\u043a\u0438 \u043d\u0430 \u043f\u043e\u043b\u044f\u0445 \u043f\u043e \u0440\u0435\u043f\u043e\u0437\u0438\u0442\u043e\u0440\u0438\u044e (https:\/\/github.com\/CrowCpp\/Crow<\/a>):<\/p>\n
http_request.h — \u043f\u0440\u0435\u043a\u0440\u0430\u0441\u043d\u044b\u0439 \u043a\u043e\u0434, \u043a\u043e\u0440\u043e\u0442\u043a\u0438\u0435 \u0444\u0443\u043d\u043a\u0446\u0438\u0438\/\u043c\u0435\u0442\u043e\u0434\u044b, \u043c\u043d\u043e\u0433\u043e \u0434\u043e\u043a\u0443\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u0438 (\u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u0431\u0435\u0437 \u0434\u043e\u043a\u043e\u0432 \u0444\u0438\u0433 \u0440\u0430\u0437\u0431\u0435\u0440\u0435\u0448\u044c, \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0439 \u043c\u0435\u0442\u043e\u0434 \u0438\u043b\u0438 \u043d\u0435\u0442).<\/p>\n
http_response.h — \u043c\u043d\u043e\u0433\u043e \u0432\u044b\u0437\u043e\u0432\u043e\u0432 std::move, \u043f\u0440\u0438 \u0441\u043b\u0443\u0447\u0430\u044f\u0445 \u043d\u0435 \u043f\u0440\u0435\u0434\u0443\u0441\u043c\u043e\u0442\u0440\u0435\u043d\u043d\u044b\u0445 \u043b\u043e\u0433\u0438\u043a\u043e\u0439 \u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c\u044b — \u043b\u043e\u0433\u0438\u0440\u0443\u0435\u043c \u0438 \u0432\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u043c \u0434\u0435\u0444\u043e\u043b\u0442\u043d\u043e\u0435 \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u0435, \u043c\u043d\u043e\u0433\u043e \u043c\u0443\u0442\u0430\u0431\u0435\u043b\u044c\u043d\u043e\u0433\u043e \u043a\u043e\u0434\u0430, \u0444\u043b\u0430\u0433\u043e\u0432\u043e\u0435 \u043f\u0440\u043e\u0433\u0440\u0430\u043c\u043c\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435 \u0438 \u0442.\u0434.<\/p>\n
http_connection.h — \u043f\u0440\u0438\u0432\u0435\u0442, \u0440\u0435\u043a\u0443\u0440\u0441\u0438\u044f (\u0432 \u043f\u0440\u0438\u0440\u043e\u0434\u0435 \u043f\u043e\u043a\u0430 \u0435\u0449\u0435 \u043d\u0435\u0442 \u043f\u0440\u043e\u0435\u043a\u0442\u0430 \u0431\u0435\u0437 \u0440\u0435\u043a\u0443\u0440\u0441\u0438\u0438 \ud83d\ude42<\/p>\n
http_server.h — \u043f\u0435\u0440\u0435\u0438\u0437\u043e\u0431\u0440\u0435\u0442\u0435\u043d\u0438\u0435 \u0430\u043b\u0433\u043e\u0440\u0438\u0442\u043c\u043e\u0432 \u0431\u0430\u043b\u0430\u043d\u0441\u0438\u0440\u043e\u0432\u043a\u0438 \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438 (load balancing) \u0441 \u043a\u043e\u043c\u043c\u0435\u043d\u0442\u0430\u0440\u0438\u0435\u043c «\u0442\u0443\u0434\u0443», \u043a\u0430\u043a \u043c\u043e\u0436\u043d\u043e \u0441\u044d\u043a\u043e\u043d\u043e\u043c\u0438\u0442\u044c \u0435\u0449\u0435 \u043f\u0430\u0440\u0443 \u0431\u0430\u0439\u0442.<\/p>\n
app.h — \u0442\u043e\u0447\u043a\u0430 \u0432\u0445\u043e\u0434\u0430 \u0438 \u043c\u0430\u043a\u0440\u043e\u0441\u044b.
 socket_adaptors.h — \u043e\u0431\u0435\u0440\u0442\u043a\u0430 \u043d\u0430\u0434 \u0441\u043e\u043a\u0435\u0442\u043e\u043c.<\/p>\n
routing.h — \u043f\u043e\u043a\u0430\u0437\u0430\u043b\u0441\u044f \u0438\u043d\u0442\u0435\u0440\u0435\u0441\u043d\u044b\u043c \u0444\u0440\u0430\u0433\u043c\u0435\u043d\u0442 \u043a\u043e\u0434\u0430:<\/p>\n
void handle_upgrade(...) override {     max_payload_ = max_payload_override_ ? max_payload_ : app_->websocket_max_payload();     new crow::websocket::Connection<SocketAdaptor, App>(req, std::move(adaptor), app_, max_payload_, ...); } <\/code><\/pre>\n
\u041d\u0430\u043f\u043e\u043c\u0438\u043d\u0430\u0435\u0442 \u044f\u0432\u0443, \u043d\u043e \u043a\u043e\u043d\u0441\u0442\u0440\u0443\u043a\u0442\u043e\u0440 websocket::Connection \u0441\u0430\u043c \u0441\u0435\u0431\u044f \u0438 \u043f\u043e\u0434\u0447\u0438\u0449\u0430\u0435\u0442<\/p>\n
... adaptor_.close(); handler_->remove_websocket(this); delete this; <\/code><\/pre>\n
\u0435\u0449\u0435_\u043c\u043d\u043e\u0433\u043e_\u0444\u0430\u0439\u043b\u043e\u0432.h — \u043c\u043d\u043e\u0433\u043e \u043a\u043e\u0434\u0430 \u0438 \u0440\u0430\u0437\u043d\u044b\u0445 \u0444\u0438\u0447\u0435\u0439, \u043d\u043e \u0432 \u043f\u0440\u0438\u043d\u0446\u0438\u043f\u0435, \u0443\u0436\u0435 \u043c\u043e\u0436\u043d\u043e \u043f\u043e\u0441\u0442\u0440\u043e\u0438\u0442\u044c \u043f\u0435\u0440\u0432\u044b\u0439 \u043f\u0440\u043e\u0442\u043e\u0442\u0438\u043f \u0440\u0430\u0431\u043e\u0447\u0435\u0433\u043e \u0441\u0435\u0440\u0432\u0435\u0440\u0430.<\/p>\n
\u0427\u0430\u0441\u0442\u044c 1: \u041f\u0438\u043d\u0433-\u041f\u043e\u043d\u0433<\/h3>\n
\u041f\u043e\u0441\u043b\u0435 \u0434\u043e\u043b\u0433\u043e\u0433\u043e \u0438 \u0443\u043f\u043e\u0440\u043d\u043e\u0433\u043e \u0440\u0430\u0441\u043f\u0438\u0442\u0438\u044f \u043a\u0440\u0435\u043f\u043a\u043e\u0433\u043e \u043a\u043e\u0444\u0435, \u043d\u043e\u0432\u043e\u0441\u0442\u0435\u0439 \u043e \u0434\u043e\u0442\u0435, \u0448\u0430\u0445\u043c\u0430\u0442\u0430\u0445 \u0438 \u0441\u043d\u0443\u043a\u0435\u0440\u0435, \u0435\u0449\u0435 \u0438 \u0442\u0435\u043b\u0435\u0433\u0438 (\u0442\u0443\u0442 \u043d\u0438\u043a\u0443\u0434\u0430) — \u0434\u0438\u0437\u0430\u0439\u043d\u0438\u043c \u043d\u0430 \u0441\u0430\u043b\u0444\u0435\u0442\u043a\u0435 \u043f\u0440\u043e\u0435\u043a\u0442: \u0441\u043e\u043a\u0435\u0442 -> \u043a\u043e\u043d\u043d\u0435\u043a\u0448\u0435\u043d -> \u0441\u0435\u0440\u0432\u0435\u0440 -> \u0430\u043f\u043f (\u0440\u0435\u0441\u043f\u043e\u043d\u0441 \u0438 \u0440\u0435\u043a\u0432\u0435\u0441\u0442 \u0433\u0434\u0435-\u0442\u043e \u0441\u0431\u043e\u043a\u0443, \u0440\u043e\u0443\u0442\u0435\u0440 \u043f\u0440\u043e\u043a\u0438\u0434\u044b\u0432\u0430\u0435\u043c \u0447\u0435\u0440\u0435\u0437 \u0430\u043f\u043f).<\/p>\n
\u041a\u0430\u043a-\u0442\u043e \u0442\u0430\u043a, \u0435\u0449\u0435 \u0440\u0430\u0437: \u0430\u043f\u043f\u043b\u0438\u043a\u0435\u0439\u0448\u043d -> \u0441\u0435\u0440\u0432\u0435\u0440 -> \u043a\u043e\u043d\u043d\u0435\u043a\u0448\u0435\u043d -> \u0441\u043e\u043a\u0435\u0442. \u0412 \u043a\u043e\u043d\u0446\u0435 \u043a\u043e\u043d\u0446\u043e\u0432, \u043c\u044b \u0445\u043e\u0442\u0438\u043c \u0432\u0438\u0434\u0435\u0442\u044c \u0442\u0430\u043a\u043e\u0439 \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441:<\/p>\n
route![app, \"\/\", || \"Hello world\".to_owned()]; route![app, \"\/measure\/<float>\/and\/<int>\", |x,y,_req| format!(\"{:?} and {:?}\" x, y)]; <\/code><\/pre>\n
\u0425\u043e\u0434\u044f\u0442 \u0441\u043b\u0443\u0445\u0438, \u0447\u0442\u043e \u043c\u0438\u0433\u0440\u0430\u0446\u0438\u044e \u043a\u043e\u0434\u0430 \u0432\u044b\u043f\u043e\u043b\u043d\u044f\u044e\u0442 \u0441\u0442\u0440\u043e\u0447\u043a\u0430 \u0437\u0430 \u0441\u0442\u0440\u043e\u0447\u043a\u043e\u0439 \u0441pp -> rust, \u0430 \u043c\u043e\u0436\u043d\u043e \u0438 \u043c\u0438\u0433\u0440\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0441 \u043d\u0443\u043b\u044f, \u0445\u043e\u0442\u044f, \u043a\u0430\u043a \u0441\u043a\u0430\u0437\u0430\u043b \u0431\u044b \u0414\u0436\u043e\u044d\u043b\u044c \u0421\u043f\u043e\u043b\u044c\u0441\u043a\u0438 — \u0431\u0443\u0434\u0443\u0442 \u0431\u0430\u0433\u0438, \u0434\u0430 \u0438 \u0444\u0438\u0433 \u0441 \u043d\u0438\u043c\u0438, \u043f\u0440\u043e\u0435\u043a\u0442-\u0442\u043e \u0443\u0447\u0435\u0431\u043d\u044b\u0439. \u0422\u0430\u043a\u0436\u0435 \u0432\u0435\u0431\u0441\u043e\u043a\u0435\u0442\u044b \u0432 \u043f\u0435\u0440\u0432\u043e\u0439 \u0432\u0435\u0440\u0441\u0438\u0438 \u0438\u043c\u043f\u043b\u0435\u043c\u0435\u043d\u0442\u0438\u0442\u044c \u043d\u0435 \u0431\u0443\u0434\u0435\u043c\/\u0445\u043e\u0442\u0438\u043c, \u0438 \u0432\u0435\u0440\u0441\u0438\u044e \u0445\u0442\u0442\u043f \u043f\u0440\u043e\u0442\u043e\u043a\u043e\u043b\u0430 \u0432\u043e\u0437\u044c\u043c\u0435\u043c \u0442\u043e\u043b\u044c\u043a\u043e 1.1. \u0412\u0441\u0435 \u043f\u043e\u043a\u0430\u0437\u044b\u0432\u0430\u044e\u0442 \u0432\u0435\u043b\u0438\u043a\u043e\u043b\u0435\u043f\u043d\u044b\u0435 \u0433\u0440\u0430\u0444\u0438\u043a\u0438 \u0441 \u0431\u0435\u0447\u043c\u0430\u0440\u043a\u0430\u043c\u0438, \u043d\u043e \u0445\u043e\u0442\u044c \u043a\u0442\u043e-\u043d\u0438\u0431\u0443\u0434\u044c \u0441\u043a\u0430\u0437\u0430\u043b \u0431\u044b — \u0437\u043d\u0430\u0435\u0442\u0435, \u0431\u0435\u0447\u043c\u0430\u0440\u043a\u0438 \u0443 \u043d\u0430\u0441 \u043d\u043e\u0440\u043c\u0443\u043b\u044c, \u0430 \u043a\u043e\u0434 \u0435\u0449\u0435 \u043b\u0443\u0447\u0448\u0435 — \u0442\u0443\u043f\u043e \u0447\u0438\u0442\u0430\u0435\u043c, \u0434\u0430 \u0438 \u0441 \u0444\u043b\u0430\u0433\u0430\u043c\u0438 (\u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0437\u0430 300) \u043c\u044b \u043d\u0435 \u0431\u0430\u043b\u0443\u0435\u043c\u0441\u044f.<\/p>\n
\u041a\u043e\u043d\u043d\u0435\u043a\u0448\u043d.\u0440\u0441<\/p>\n
\/\/\/ connection.rs  pub struct Connection { socket: Socket, }  impl Connection { pub fn new(stream: TcpStream) -> Self { Connection { socket: Socket::new(stream), } } }  impl Connection{ pub async fn start(&mut self, app: &App) -> Result<(), Box<dyn Error>> { let s = self.socket.read_all().await?; if !s.is_empty() { let req = Parser::new(s).parse().ok_or(\"failed to parse\")?; let resp = app.handle(req).await;         self.socket.write_all(resp).await?;     }     Ok(()) } } <\/code><\/pre>\n
\u0414\u043b\u044f \u0442\u0435\u0445, \u043a\u0442\u043e \u043d\u0435 \u0437\u043d\u0430\u043a\u043e\u043c \u0441 \u0440\u0430\u0441\u0442\u043e\u043c: 1) \u0444\u044c\u044e\u0447\u0435\u0440\u0441\u044b \u0431\u0435\u0437 await \u043d\u0438\u0447\u0435\u0433\u043e \u043d\u0435 \u0434\u0435\u043b\u0430\u044e\u0442, 2) \u0437\u043d\u0430\u043a\u0438 \u0432\u043e\u043f\u0440\u043e\u0441\u0430 — \u0435\u0441\u0442\u044c \u043d\u0435\u044f\u0432\u043d\u0430\u044f \u0440\u0430\u0441\u043f\u0430\u043a\u043e\u0432\u043a\u0430 Result \u0438\u043b\u0438 Option.<\/p>\n
\u041f\u0440\u043e\u0441\u0442\u0435\u0439\u0448\u0438\u0439 \u0438\u0437 \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u044b\u0445 \u043f\u0430\u0440\u0441\u0435\u0440\u043e\u0432 \u0445\u0442\u0442\u043f \u0437\u0430\u043f\u0440\u043e\u0441\u0430<\/p>\n
\/\/\/ parser.rs  pub struct Parser<'a> { s: &'a str, }  impl <'a> Parser<'a> { pub fn new(s: &'a str) -> Self { Parser { s } } }  impl Parser<'_> { pub fn parse(self) -> Option<Request> { let (mut info, mut headers) = (vec![], vec![]);  let mut iter = self.s.split(\"\\r\\n\"); for x in iter.next()?.split(' ') {  info.push(x);  } for x in iter.by_ref() { if x.is_empty() { break; } let mut b = x.split(\": \"); headers.push(( b.next()?.to_owned(),  b.next()?.to_owned() )); } let body = iter.next()?.to_owned();  Request::build(info, headers, body) } }  <\/code><\/pre>\n
\u0414\u0432\u0430 \u043c\u043e\u043c\u0435\u043d\u0442\u0430: 1) \u043c\u0435\u0442\u043e\u0434 parse \u043f\u043e\u0433\u043b\u043e\u0442\u0438\u0442 \u043e\u0431\u044c\u0435\u043a\u0442 (self \u0431\u0435\u0437 \u0430\u043c\u043f\u0435\u0440\u0441\u0430\u043d\u0434\u0430) — \u0433\u0443\u0434 \u043f\u0440\u0438 \u043f\u0440\u043e\u0435\u043a\u0442\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0438; 2) lifetime (\u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0430\u043f\u043e\u0441\u0442\u0440\u043e\u0444) \u043d\u0435 \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0435\u0442 \u0437\u0430\u044e\u0437\u0430\u0442\u044c \u0441\u0441\u044b\u043b\u043a\u0443 \u043d\u0430 \u0431\u0443\u0444\u0435\u0440 \u0441\u043e\u043a\u0435\u0442\u0430 (\u0447\u0435\u0440\u0435\u0437 \u0441\u0441\u044b\u043b\u043a\u0443 \u043d\u0430 \u0441\u0442\u0440\u043e\u043a\u0443) \u043f\u043e\u0441\u043b\u0435 \u0435\u0433\u043e (\u0431\u0443\u0444\u0435\u0440\u0430) \u0443\u0434\u0430\u043b\u0435\u043d\u0438\u044f.<\/p>\n
\u0420\u0435\u043a\u0432\u0435\u0441\u0442.pc — \u0441\u043e\u0431\u0441\u0442\u0432\u0435\u043d\u043d\u043e, \u043e\u0441\u043d\u043e\u0432\u043d\u0430\u044f \u0438\u043d\u0444\u043e\u0440\u043c\u0430\u0446\u0438\u044f, \u043a\u043e\u0442\u043e\u0440\u0443\u044e \u043c\u044b \u0445\u043e\u0442\u0438\u043c \u043f\u0435\u0440\u0435\u0434\u0430\u0442\u044c \u043a\u043b\u0438\u0435\u043d\u0442\u0441\u043a\u043e\u043c\u0443 \u043a\u043e\u0434\u0443.<\/p>\n
\/\/\/ request.rs  #[derive(Default, Debug, Clone)] pub struct Request { pub method: String, pub url: String, pub version: String, pub query: String, pub headers: Vec<(String, String)>, pub body: String,   }  fn parse_url(s: &str) -> (String, String) { if let Some(i) = s.find('?') { (s[..i].to_owned(), s[i+1..].to_owned()) } else { (s.to_owned(), \"\".to_owned()) } }  impl Request { pub fn build(mut info: Vec<&str>, headers: Vec<(String, String)>, body: String) -> Option<Self> { let version = info.pop()?.to_owned(); let (url, query) = parse_url(info.pop()?); let method = info.pop()?.to_owned(); Some(Request {method, url, query, version, headers, body}) } } <\/code><\/pre>\n
\u0420\u0435\u0441\u043f\u043e\u043d\u0441 \u0434\u043b\u044f \u043f\u0440\u043e\u0441\u0442\u043e\u0442\u044b \u0438\u043c\u043f\u043b\u0435\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u0438 \u0441\u0434\u0435\u043b\u0430\u0435\u043c \u0441\u0442\u0440\u0438\u043d\u0433\u043e\u043c (String).<\/p>\n
\u0412\u043e\u0437\u0432\u0440\u0430\u0449\u0430\u0435\u043c\u0441\u044f \u043a \u0441\u043e\u043a\u0435\u0442\u0430\u043c — \u0421\u043e\u043a\u0435\u0442.\u0440\u0441<\/p>\n
\/\/\/ socket.rs  pub struct Socket { stream: TcpStream, buf: [u8; 1024], }  impl Socket { pub fn new(stream: TcpStream) -> Self {     Socket { stream, buf: [0; 1024] } } }  impl Socket {  pub async fn read_all(&mut self) -> Result<&str, Box<dyn Error>> { let n = self.stream.read(&mut self.buf).await?; Ok(std::str::from_utf8(&self.buf[..n])?) }  pub async fn write_all(&mut self, s: String) -> Result<(), Box<dyn Error>> { let x = format!(\"HTTP\/1.1 200 OK\\r\\nContent-Length: {}\\r\\n\\n\", s.len()); self.stream.write_all(&x.into_bytes()).await?; self.stream.write_all(&s.into_bytes()).await?; Ok(()) } } <\/code><\/pre>\n
\u041f\u0430\u0440\u0443 \u043c\u043e\u043c\u0435\u043d\u0442\u043e\u0432: 1) \u0434\u043e\u043f\u0443\u0441\u043a\u0430\u0435\u043c, \u0447\u0442\u043e \u0431\u0443\u0444\u0435\u0440 \u0432\u043c\u0435\u0441\u0442\u0438\u0442 \u0432\u0435\u0441\u044c \u0440\u0435\u043a\u0432\u0435\u0441\u0442 \u0432 \u0431\u0430\u0439\u0442\u0430\u0445, 2) \u0440\u0430\u0437\u043c\u0435\u0449\u0430\u0435\u043c \u0431\u0443\u0444\u0435\u0440 \u0432\u043c\u0435\u0441\u0442\u0435 \u0441 \u0441\u043e\u043a\u0435\u0442\u043e\u043c \u0438\u0437-\u0437\u0430 \u043f\u0440\u043e\u0441\u0442\u043e\u0442\u044b \u0438\u043c\u043f\u043b\u0435\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u0438, 3) \u0440\u0430\u0437\u043c\u0435\u0440 \u0431\u0443\u0444\u0435\u0440\u0430 \u0444\u0438\u043a\u0441\u0438\u0440\u043e\u0432\u0430\u043d \u0442\u0430\u043a\u0436\u0435 \u0434\u043b\u044f \u043f\u0440\u043e\u0441\u0442\u043e\u0442\u044b, 4) \u043c\u0438\u043d\u0438\u043c\u0430\u043b\u044c\u043d\u044b\u0435 \u0445\u0435\u0434\u0435\u0440\u0430.<\/p>\n
\u0421\u0430\u043c\u043e\u0435 \u0438\u043d\u0442\u0435\u0440\u0435\u0441\u043d\u043e\u0435 \u043d\u0430 \u0441\u0435\u0440\u0432\u0435\u0440\u0435 — \u0421\u0435\u0440\u0432\u0435\u0440.\u0440\u0441<\/p>\n
\/\/\/ server.rs  pub struct Server { listener: TcpListener, }  impl Server { pub async fn bind(addr: &str) -> Result<Server, Box<dyn Error>> { let listener = TcpListener::bind(&addr).await?;     println!(\"Listening on: {addr}\");     Ok(Server{listener}) }  pub async fn accept(&mut self, app: &'static App) -> Result<(), Box<dyn Error>> { loop { let (stream, _) = self.listener.accept().await?; tokio::spawn(async move { let mut p = Connection::new(stream); p.start(app).await.unwrap(); }); } } } <\/code><\/pre>\n
\u0420\u0435\u0431\u044f\u0442\u0430 \u0438\u0437 CrowCpp \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043b\u0438 \u0441\u0432\u043e\u0439 (\u043d\u0430 \u0431\u0430\u0437\u0435 boost::asio) \u0431\u0430\u043b\u0430\u043d\u0441\u0438\u0440\u043e\u0432\u0449\u0438\u043a \u043d\u0430\u0433\u0440\u0443\u0437\u043a\u0438, \u0443 \u0440\u0430\u0441\u0442\u0430 \u043d\u0435\u043c\u043d\u043e\u0433\u043e \u0432\u0435\u0441\u0435\u043b\u0435\u0435 — \u0435\u0441\u0442\u044c tokio \u0440\u0430\u043d\u0442\u0430\u0439\u043c. \u042d\u0442\u043e \u0442\u0430\u043a\u043e\u0439 \u0440\u0430\u043d\u0442\u0430\u0439\u043c, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u0431\u0435\u0440\u0435\u0442 \u043d\u0430 \u0441\u0435\u0431\u044f \u043a\u043e\u043e\u0440\u0434\u0438\u043d\u0430\u0446\u0438\u044e \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u044b\u0445 \u0442\u0430\u0441\u043a\u043e\u0432, \u0431\u0430\u043b\u0430\u043d\u0441\u0438\u0440\u043e\u0432\u043a\u0443 (\u0441\u0430\u043c\u0443\u044e \u0431\u0430\u0437\u043e\u0432\u0443\u044e) \u0438 \u0442.\u0434.<\/p>\n
\u0418\u0437 \u0434\u043e\u043a\u043e\u0432 tokio::spawn
 Spawning a task enables the task to execute concurrently to other tasks. The spawned task may execute on the current thread, or it may be sent to a different thread to be executed.<\/code><\/p>\n
\u0415\u0449\u0435 \u0434\u043e\u043a\u0438 \u043e \u0442\u043e\u043a\u0438\u0439\u0441\u043a\u043e\u043c \u0440\u0430\u043d\u0442\u0430\u0439\u043c\u0435:
 The multi-thread scheduler executes futures on a\u00a0thread pool, using a work-stealing strategy. By default, it will start a worker thread for each CPU core available on the system. This tends to be the ideal configuration for most applications.<\/code><\/p>\n
\u0422\u0430\u0441\u043a\u0438 \u0440\u0430\u043d\u0442\u0430\u0439\u043c\u0430 \u043d\u0435 \u043b\u044e\u0431\u044f\u0442 \u0431\u0440\u0430\u0442\u044c \u0434\u0430\u043d\u043d\u044b\u0435 \u0438\u0437\u0432\u043d\u0435, \u0438 \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u0430\u043f\u043f\u0435 \u043d\u0443\u0436\u043d\u043e \u043f\u0440\u0438\u0442\u0432\u043e\u0440\u0438\u0442\u044c\u0441\u044f \u0437\u043d\u0430\u0447\u0435\u043d\u0438\u0435\u043c (\u0441\u043c. \u0432 \u043a\u043e\u0434\u0435 — \u0441\u0442\u0430\u0442\u0438\u043a \u0441\u0441\u044b\u043b\u043a\u0430 \u043f\u0440\u0438\u0431\u043b\u0438\u0437\u0438\u0442\u0435\u043b\u044c\u043d\u043e \u0440\u0430\u0432\u043d\u0430 \u0432\u044d\u043b\u044c\u044e \u0441 \u0442\u043e\u0447\u043a\u0438 \u0437\u0440\u0435\u043d\u0438\u044f \u0442\u0438\u043f\u043e\u0432) \u0438 \u043f\u0435\u0440\u0435\u043f\u0440\u044b\u0433\u043d\u0443\u0442\u044c \u0432 \u0430\u0441\u0438\u043d\u0445\u0440\u043e\u043d\u043d\u0443\u044e \u0442\u0430\u0441\u043a\u0443. \u0418\u043c\u0435\u043d\u043e\u0432\u0430\u043d\u0438\u0435 \u043f\u0435\u0440\u0435\u043c\u0435\u043d\u043d\u043e\u0439 \u0434\u043b\u044f \u043d\u043e\u0432\u043e\u0433\u043e \u043a\u043e\u043d\u043d\u0435\u043a\u0448\u0435\u043d\u0430 \u0432\u0437\u044f\u043b \u0443 \u0440\u0435\u0431\u044f\u0442 \u0438\u0437 CrowCpp, \u043f\u043e\u0447\u0435\u043c\u0443-\u0442\u043e \u0442\u0430\u043a \u0438 \u043d\u0435 \u0441\u043c\u043e\u0433 \u043f\u0440\u0438\u0434\u0443\u043c\u0430\u0442\u044c \u043d\u0438\u0447\u0435\u0433\u043e \u043b\u0443\u0447\u0448\u0435 \ud83d\ude42<\/p>\n
\u0426\u0435\u043d\u0442\u0440\u0430\u043b\u044c\u043d\u0430\u044f \u0441\u0442\u0440\u0443\u043a\u0442\u0443\u0440\u043a\u0430 — a\u043f\u043f.\u0440\u0441<\/p>\n
\/\/\/ app.rs  #[derive(Default)] pub struct App { map: Trie<fn(Request, Vec<RouteTokens>) -> String>, }  unsafe fn make_static<T>(t: &T) -> &'static T {     std::mem::transmute(t) }  impl App { pub async fn start(&self, addr: &str) -> Result<(), Box<dyn Error>> {     let mut server = Server::bind(addr).await?;     \/\/ safe: app should be alive before termination     server.accept(unsafe { make_static(self) }).await?;     Ok(()) }  pub async fn handle(&self, req: Request) -> String { let b = req.url.split('\/').filter(|s| !s.is_empty()); self.map.get(b) .map(|(fun, args)| fun(req, args)) .unwrap_or(\"Not found\".to_owned()) }  pub fn service(&mut self, key: &'static str, fun: fn(Request, Vec<RouteTokens>) -> String) { let b = key.split('\/').filter(|s| !s.is_empty()); self.map.insert(b, fun); } } <\/code><\/pre>\n
\u0422\u0443\u0442 \u044e\u0437\u0430\u0435\u043c \u043f\u0440\u0435\u0444\u0438\u043a\u0441\u043d\u043e\u0435 \u0434\u0435\u0440\u0435\u0432\u043e (Trie, \u043d\u0443\u0436\u043d\u043e\u0435 \u0434\u043b\u044f \u0440\u043e\u0443\u0442\u0435\u0440\u043e\u0432), \u0447\u0443\u0442\u044c-\u0447\u0443\u0442\u044c unsafe \u043a\u043e\u0434\u0430 (\u0438 \u043a\u043e\u043c\u043c\u0435\u043d\u0442, \u043f\u043e\u0447\u0435\u043c\u0443 \u044d\u0442\u043e OK) \u0438 \u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0435\u043d\u0438\u044f, \u0434\u043e\u0431\u0430\u0432\u043b\u0435\u043d\u043d\u044b\u0435 \u0441\u0438\u0441\u0442\u0435\u043c\u043e\u0439 \u0442\u0438\u043f\u043e\u0432: 1) fn(…) — \u0435\u0441\u0442\u044c non-capturing\u00a0closures, \u0442\u043e \u0435\u0441\u0442\u044c \u043b\u0430\u043c\u0431\u0434\u0435 \u043d\u0435 \u043f\u043e\u0437\u0432\u043e\u043b\u044f\u0442 \u0437\u0430\u0445\u0432\u0430\u0442\u0438\u0442\u044c \u043a\u043e\u043d\u0442\u0435\u043a\u0441\u0442 \u0438\u0437\u0432\u043d\u0435, 2) key &’static str — \u043f\u0443\u0442\u044c \u0432 \u0440\u043e\u0443\u0442\u0435\u0440\u0435 \u043f\u0438\u0448\u0435\u043c (\u0432 \u0431\u043e\u043b\u044c\u0448\u0438\u043d\u0441\u0442\u0432\u0435 \u0441\u043b\u0443\u0447\u0430\u0435\u0432) \u0440\u0443\u0447\u043a\u0430\u043c\u0438 (\u0445\u0437, \u0445\u043e\u0440\u043e\u0448\u043e \u044d\u0442\u043e \u0438\u043b\u0438 \u043f\u043b\u043e\u0445\u043e, \u043d\u043e \u0434\u043b\u044f \u043f\u0440\u0438\u043c\u0435\u0440\u0430).<\/p>\n
\u041f\u0440\u0435\u0444\u0438\u043a\u0441\u043d\u043e\u0435 \u0434\u0435\u0440\u0435\u0432\u043e (\u043e\u043f\u044f\u0442\u044c \u0436\u0435, \u043f\u0440\u043e\u0441\u0442\u0435\u0439\u0448\u0430\u044f \u0438\u043c\u043f\u043b\u0435\u043c\u0435\u043d\u0442\u0430\u0446\u0438\u044f)<\/p>\n
\/\/\/ trie.rs  pub struct Trie<T> { head: Node<T>,  }  struct Node<T> { value: Option<T>, map: HashMap<&'static str, Node<T>>  }  impl<T> Default for Trie<T> { fn default() -> Self { let head = Node { value: None, map: HashMap::new() }; Trie { head } } }  impl<T> Trie<T> { pub fn insert(&mut self, v: impl IntoIterator<Item = &'static str>, elem: T) { let mut node = &mut self.head; for s in v { if node.map.contains_key(s) {  node = node.map.get_mut(s).unwrap(); } else { let next = Node { value: None, map: HashMap::new() }; node.map.insert(s, next); node = node.map.get_mut(s).unwrap();  } } node.value = Some(elem); }  pub fn get<'a>(&self, v: impl IntoIterator<Item = &'a str>) -> Option<(&T, Vec<RouteTokens>)> { let mut node = &self.head; let mut args = vec![]; for s in v { let (s, token) = mapping(s); if node.map.contains_key(s) {  node = node.map.get(s).unwrap(); } else { return<\/code><\/pre>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[],"tags":[],"class_list":["post-445438","post","type-post","status-publish","format-standard","hentry"],"_links":{"self":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/445438","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=445438"}],"version-history":[{"count":0,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/445438\/revisions"}],"wp:attachment":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=445438"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=445438"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=445438"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}