如何確定套接字何時收到EOF？（C 20boostasio協程）

考慮一個簡單的回顯服務器：

#include <boost/asio.hpp>
#include <boost/asio/experimental/as_tuple.hpp>
#include <iostream>
#include <vector>

using boost::asio::awaitable;
using boost::asio::buffer;
using boost::asio::co_spawn;
using boost::asio::io_context;
using boost::asio::detached;
namespace ip = boost::asio::ip;
using boost::asio::use_awaitable;

// echo server
awaitable<void> serve_coroutine(ip::tcp::socket s) {
    std::vector<unsigned char> data_buf;
    data_buf.resize(4096);
    for (;;) {
        auto n = co_await s.async_read_some(buffer(data_buf, data_buf.size()),
                use_awaitable);
        auto ep = s.remote_endpoint();
        std::cout << "R from " << ep.address().to_string()
            << " " << ep.port() << " L=" << n << std::endl;
        while (n) {
            size_t written = co_await s.async_write_some(buffer(data_buf, n), use_awaitable);
            n -= written;
        }
    }
}

awaitable<void> listen_coroutine(ip::tcp::acceptor& acceptor) {
    for (;;) {
        auto [e, client] = co_await acceptor.async_accept(
                boost::asio::experimental::as_tuple(use_awaitable));
        if (!e) {
            auto ex = client.get_executor();
            // create working coroutine for data-transmission
            co_spawn(ex, serve_coroutine(std::move(client)), detached);
        } else {
            std::cerr << "accept failed: " << e.message() << std::endl;
        }
    }
}

int main(int argc, char** argv) {
    if (argc < 3) {
        std::cout << "Usage: " << argv[0]
            << " <bind_address> <bind_port>" << std::endl;
        return 1;
    }

    try {
        io_context ctx;
        // bind address
        ip::tcp::endpoint listen_endpoint{ip::make_address(argv[1]),
            static_cast<ip::port_type>(std::stoi(argv[2]))};
        // create acceptor
        ip::tcp::acceptor acceptor{ctx, listen_endpoint};
        // add coroutine to execution queue
        co_spawn(ctx, listen_coroutine(acceptor), detached);
        // start executing coroutines
        ctx.run();
    } catch (boost::system::system_error& e) {
        std::cerr << "boost system error: " << e.what() << std::endl;
    } catch (std::exception& e) {
        std::cerr << "E: " << e.what() << std::endl;
    }
    return 0;
}

g -std=c 20（使用or構建clang -stdlib=libc -fcoroutines-ts）

當遠程對等端關閉連接時，co_await async_read_some永不回傳

似乎 boost io_service 在關閉連接時簡單地破壞了一切

如果我將一個物件插入serve_coroutine并跟蹤它的建構式和解構式，我會發現它在關閉連接時被破壞

那么處理連接關閉事件的正確方法是什么？如果你正在開發游戲，你需要清除玩家的資料，并在你確定他的連接關閉時告訴大家他已經下線了

uj5u.com熱心網友回復：

您可以捕獲例外：

for (;;) {
    try {
        auto n = co_await s.async_read_some(
            buffer(data_buf, data_buf.size()), use_awaitable);
        auto ep = s.remote_endpoint();
        std::cout << "R from " << ep.address().to_string() << " "
                  << ep.port() << " L=" << n << std::endl;

        while (n) {
            size_t written = co_await s.async_write_some(
                buffer(data_buf, n), use_awaitable);
            n -= written;
        }
    } catch (std::exception& e) {
        std::cerr << "boost system error: " << e.what() << std::endl;
    }
}

哪個會列印

boost system error: End of file [asio.misc:2]

或者，您可以使用其他方法來接收 error_code。您可以在您的清單中看到一個示例：

auto [e, client] = co_await acceptor.async_accept(
    boost::asio::experimental::as_tuple(use_awaitable));

所以，例如：

for (;;) {
    auto [ec, n] = co_await s.async_read_some(
        buffer(data_buf, data_buf.size()),
        boost::asio::experimental::as_tuple(use_awaitable));

    auto ep = s.remote_endpoint();
    std::cout << "R from " << ep.address().to_string() << " " << ep.port()
              << " L=" << n << " (" << ec.message() << ")" << std::endl;

    if (!ec)
        break;

    while (n) {
        size_t written =
            co_await s.async_write_some(buffer(data_buf, n), use_awaitable);
        n -= written;
    }
}

將顯示如下內容：

R from 127.0.0.1 51586 L=4 (Success)
R from 127.0.0.1 51586 L=1 (Success)
R from 127.0.0.1 51586 L=1 (Success)
R from 127.0.0.1 51586 L=1 (Success)
R from 127.0.0.1 51586 L=0 (End of file)
R from 127.0.0.1 51590 L=1 (Success)
R from 127.0.0.1 51590 L=1 (Success)
R from 127.0.0.1 51590 L=0 (End of file)

標籤：C 促进 c 20 阿西奥 c -协程

上一篇：為什么要避免C 中的冗余宣告？

下一篇：PANDAS：根據多個if條件為特定列中的每一行分配一個值