c++ - 带有 cpprest 的多个 POST 请求，没有多线程和服务器停止

Question

当我发送多个帖子时，我的服务器 cpprest 出现了一些问题。

这是 MyServer 的代码：

MyServer::MyServer(utility::string_t url) : m_listener(url)
{
  std::function<void(http_request)> fnPost = &MyServer::handle_post;
  m_listener.support(methods::POST, fnPost);
  mongocxx::instance instance{};
}

void MyServer::handle_error(pplx::task<void> &t)
{
  try
  {
    t.get();
  }
  catch (...)
  {
    // Ignore the error, Log it if a logger is available
  }
}
pplx::task<void> MyServer::open()
{
  return m_listener.open().then([](pplx::task<void> t)
                                { handle_error(t); });
}
pplx::task<void> MyServer::close()
{
  return m_listener.close().then([](pplx::task<void> t)
                                 { handle_error(t); });
}
void MyServer::handle_post(http_request message)
{
  message.extract_string().then([=](const utility::string_t &data)
                                {
                                  try
                                  {
                                    message.reply(status_codes::Accepted);
                                    DoSomething::doSomething(jsonObj, message);
                                  catch (...)
                                  {
                                    message.reply(status_codes::InternalError).then([](pplx::task<void> t)
                                                                                    { handle_error(t); });
                                  }
                                }).then([](pplx::task<void> t){ handle_error(t); });

};

这是我的 DoSomething ：

void DoSomething::doSomething(nlohmann::json jsonObj, http_request message)
{
    try
    {
        (... do something with jsonObj)
        message.reply(status_codes::OK).then([](pplx::task<void> t)
                                             { MyServer::handle_error(t); });
    }
    catch (const filesystem_error &ex)
    {
        message.reply(status_codes::InternalError).then([](pplx::task<void> t)
                                                        { MyServer::handle_error(t); });
    }
}

而我的主要：

int main(int argc, char ** argv) {
  InterruptHandler * itrpt = new InterruptHandler();
  itrpt -> hookSIGINT();
  
  std::unique_ptr < MyServer > g_http;
  utility::string_t adress = U("http://0.0.0.0:33333");
  uri_builder uri(adress);
  uri.append_path(U("MyServer/Action/"));
  auto addr = uri.to_uri().to_string();
  
  g_http = std::unique_ptr < MyServer > (new MyServer(addr));
  try {
    g_http -> open().wait();
    ucout << utility::string_t(U("Listening for requests at: ")) << addr << std::endl;
    InterruptHandler::waitForUserInterrupt();
  } catch (const std::exception & e) {
    printf("Error exception:%s\n", e.what());
  }
  return 0;
}

如果我在 doSomething 仍在运行时发起请求，则没有队列并且服务器正在停止。我不知道如何对我的服务器进行多线程处理以同时处理多个发布请求。我不是 C++ 专家，但我必须让自己适应这种语言才能完成我的工作。

我查看我的代码示例：https ://github.com/microsoft/cpprestsdk/blob/master/Release/samples/CasaLens/

标签： c++multithreadingthreadpoolcpprest-sdk