Poco C++库如何实现对服务器请求的异步回复

问题根因 #

Poco HTTPServer默认会将响应数据写入内核缓冲区，直到handleRequest方法执行完成后才会主动flush套接字缓冲区关闭会话，所以你调用response.send()只是将响应头写入了应用层缓冲区，并没有实际发送到客户端。

解决方案1：手动刷出响应（适合响应发送后仅需短时间后台处理的场景） #

你只需要在调用response.send()获取输出流后，主动调用flush()方法即可立即将响应数据发送给客户端，无需等待handleRequest返回：

void handler::handleRequest(HTTPServerRequest &request, HTTPServerResponse &response)
{
   Poco::Util::Application::instance().logger().information("Got A Request");
   Poco::Util::Application::instance().logger().information("Sending response");
   response.setStatusAndReason(HTTPResponse::HTTP_OK);
   // 如果没有响应体，需要显式设置Content-Length为0，避免客户端等待后续数据
   response.setContentLength(0);
   // 获取输出流并立即刷出
   std::ostream& out = response.send();
   out.flush();
   // 后续处理逻辑，此时客户端已经收到200OK响应
   auto& stream = request.stream();
   // 处理POST数据
}

解决方案2：后台线程异步处理（适合响应发送后有长时间耗时操作的场景） #

如果后续POST数据处理耗时很长，不要占用请求处理线程，提前将请求数据拷贝到独立变量后扔给线程池处理，handleRequest刷完响应直接返回即可：

1. 先提前初始化全局/类成员的Poco线程池实例
2. 请求处理时先读取全部POST数据拷贝出来，再提交异步任务
3. 刷出响应后直接结束handleRequest

// 假设你已经定义了线程池成员 Poco::ThreadPool _taskPool;
void handler::handleRequest(HTTPServerRequest &request, HTTPServerResponse &response)
{
   Poco::Util::Application::instance().logger().information("Got A Request");
   // 第一步：提前读取所有POST数据，避免后续request对象销毁后访问失效
   std::string postBody(std::istreambuf_iterator<char>(request.stream()), {});
   // 第二步：发送响应并立即刷出
   response.setStatusAndReason(HTTPResponse::HTTP_OK);
   response.setContentLength(0);
   std::ostream& out = response.send();
   out.flush();
   // 第三步：将数据提交给后台线程异步处理，不占用当前请求线程
   _taskPool.start([postBody = std::move(postBody)]() {
       // 这里执行POST数据的耗时处理逻辑
       processPostData(postBody);
   });
   // handleRequest直接返回，客户端已经收到响应
}

注意事项 #

• 如果需要返回响应体后再执行后台逻辑，要提前计算好响应体大小设置setContentLength，或者开启分块传输response.setChunkedTransferEncoding(true)，避免客户端等待数据超时。
• 绝对不要在异步任务中直接引用HTTPServerRequest和HTTPServerResponse对象，这两个对象的生命周期仅在handleRequest执行期间有效，方法返回后会被立即销毁，直接引用会触发内存访问错误。

内容的提问来源于stack exchange，提问作者user3472