2310C++协程超传服务器

原文
告别异步回调模型,写代码更简单.同样也是跨平台,仅头文件的,包含头文件即可用,来看看它的用法.

基本用法

提供getpost服务

  coro_http_server server(1, 9001);server.set_http_handler<GET, POST>("/", [](coro_http_request &req, coro_http_response &resp) {//`io`线程中的响应.resp.set_status_and_content(status_type::ok, "hello world");});server.set_http_handler<GET>("/coro",[](coro_http_request &req,coro_http_response &resp) -> async_simple::coro::Lazy<void> {co_await coro_io::post([&] {// 其他线程中的协程.resp.set_status_and_content(status_type::ok, "hello world in coro");});});server.sync_start();

coro_http_server提供了三个http服务,通过set_http_handler注册的,注册了两个http处理函数:一个是普通函数,一个是协程函数.

注册为普通函数时,会在io线程里执行该函数;注册为协程函数时,允许在其它线程或线程池中执行.上面注册协程函数示例,展示了分发业务函数到coro_io内部的线程池中执行.

co_await时挂起协程,不会阻塞io线程,可继续处理新的io事件.

ssl

coro_http_server也支持https,只要设置证书,密码等参数即可.

  coro_http_server server(1, 9001);server.init_ssl("server.crt", "server.key", "test");server.set_http_handler<GET, POST>("/ssl", [](coro_http_request &req, coro_http_response &resp) {resp.set_status_and_content(status_type::ok, "ssl");});server.sync_start();

chunked(上传/下载)

接收chunked流

cinatra::coro_http_server server(1, 9001);server.set_http_handler<cinatra::GET, cinatra::POST>("/chunked",[](coro_http_request &req,coro_http_response &resp) -> async_simple::coro::Lazy<void> {assert(req.get_content_type() == content_type::chunked);chunked_result result{};std::string content;while (true) {result = co_await req.get_conn()->read_chunked();if (result.ec) {co_return;}if (result.eof) {break;}content.append(result.data);}std::cout << content << "\n";resp.set_format_type(format_type::chunked);resp.set_status_and_content(status_type::ok, "chunked ok");});

while循环不断的co_await块流数据,直到读完所有的数据为止,使用接口比回调模式简单很多.

写chunked流

  server.set_http_handler<cinatra::GET, cinatra::POST>("/write_chunked",[](coro_http_request &req,coro_http_response &resp) -> async_simple::coro::Lazy<void> {resp.set_format_type(format_type::chunked);bool ok;if (ok = co_await resp.get_conn()->begin_chunked(); !ok) {co_return;}std::vector<std::string> vec{"hello", " world", " ok"};for (auto &str : vec) {if (ok = co_await resp.get_conn()->write_chunked(str); !ok) {co_return;}}ok = co_await resp.get_conn()->end_chunked();});

类似,循环不断的co_awaitwrite_chunked(),写完之后调用end_chunked()即可.