c++ - 在 Boost.Asio 请求期间检测中止的连接

Question

<分区>

Answer 1

这个问题的关键是避免在接收处理程序中进行请求处理。以前，我在做这样的事情:

async_receive(..., recv_handler)

void recv_handler(error) {
    if (!error) {
        parse input
        process input
        async_send(response, ...)

相反，适当的模式更像这样:

async_receive(..., recv_handler)

void async_recv(error) {
    if (error) {
        canceled_flag = true;
    } else {
        // start a processing event
        if (request_in_progress) {
            capture input from input buffer
            io_service.post(process_input)
        }
        // post another read request
        async_receive(..., recv_handler)
    }
}

void process_input() {
    while (!done && !canceled_flag) {
        process input
    }
    async_send(response, ...)
}

显然我遗漏了很多细节，但重要的部分是将处理作为单独的“事件”发布到 io_service 线程池中，以便可以同时运行额外的接收。这允许在处理过程中接收“连接中止”消息。但是请注意，这意味着两个线程必须相互通信，需要某种同步，并且正在处理的输入必须与接收调用所在的输入缓冲区分开保存，因为更多数据可能会因到期而到达附加读取调用。

编辑:

我还应该注意，如果您在处理过程中收到更多数据，您可能不想启动另一个异步处理调用。稍后的处理可能会先完成，结果可能会乱序发送给客户端。除非您使用的是 UDP，否则这可能是一个严重的错误。

这是一些伪代码:

async_read (=> read_complete)
read_complete
    store new data in queue
    if not currently processing
         if a full request is in the queue
             async_process (=> process_complete)
    else ignore data for now
    async_read (=> read_complete)
async_process (=> process_complete)
    process data
process_complete
    async_write_result (=> write_complete)
write_complete
    if a full request is in the queue
        async_process (=> process_complete)

因此，如果在处理请求时收到数据，它会排队但不会被处理。一旦处理完成并发送结果，我们就可以使用之前收到的数据再次开始处理。

这可以通过允许在写入先前请求的结果时进行处理来进一步优化，但这需要更加小心以确保结果的写入顺序与收到的请求相同。