Boost ASIO async_read_until无法读取背靠背消息的问题

在 _stream.lowest_layer（） 上调用 available（） 方法以查看可用的字节数会导致错误的文件描述符异常。

这意味着套接字变得无效，例如因为它已关闭。

为了回顾问题的其余部分，我使用最少的代码使您的代码自包含：

在 Coliru 上直播

#include <boost/asio.hpp>
#include <boost/asio/ssl.hpp>
#include <iostream>
namespace asio = boost::asio;
namespace ssl = asio::ssl;
using namespace std::chrono_literals;
using error_code = boost::system::error_code;
using asio::ip::tcp;

static ssl::context s_ctx{ssl::context::sslv23_server};

struct SomeClass : std::enable_shared_from_this<SomeClass> {
    SomeClass(tcp::socket&& s) : _stream(std::move(s), s_ctx) {}

    void start() {
        _stream.async_handshake(ssl::stream_base::server, [this, self = shared_from_this()](error_code ec) {
            std::cout << "Handshake: " << ec.message() << std::endl;
            if (!ec)
                read("\n");
        });
    }

  private:
    asio::streambuf                     _recBuf;
    ssl::stream<tcp::socket>            _stream;
    asio::strand<asio::any_io_executor> _readStrand{_stream.get_executor()};
    using String = std::string;

    void read(String const& delim) {
        asio::async_read_until(
            _stream, _recBuf, delim,
            bind_executor( //
                _readStrand, [this, delim, self = shared_from_this()](error_code const& ec, size_t bytes) {
                    if (!ec || (ec == asio::error::eof && bytes)) {
                        if (bytes <= delim.size()) {
                            return; // TODO review?!
                        }

                        String data(asio::buffers_begin(_recBuf.data()),
                                    asio::buffers_begin(_recBuf.data()) + (bytes - delim.size()));
                        _recBuf.consume(bytes);

                        std::cout << "Received:  " << quoted(data) << std::endl;
                        std::cout << "Available: " << _recBuf.size() << "/"
                                  << _stream.lowest_layer().available() << std::endl;

                        read(delim);
                    } else if (ec == asio::error::operation_aborted) {

                    } else {
                    }
                }));
    }
};

void accept_loop(tcp::acceptor& acc) {
    acc.async_accept(make_strand(acc.get_executor()), [&acc](error_code ec, tcp::socket s) {
        if (!ec) {
            std::cout << "Accepted from " << s.remote_endpoint() << std::endl;
            std::make_shared<SomeClass>(std::move(s))->start();
            accept_loop(acc);
        }
    });
}

int main() {
    s_ctx.set_default_verify_paths();
    s_ctx.use_private_key_file("server.pem", ssl::context::pem);
    s_ctx.use_certificate_file("server.pem", ssl::context::pem);

    asio::io_context ioc(1);
    tcp::acceptor acc(ioc, {{}, 6443});
    accept_loop(acc);

    ioc.run();
    ioc.run_for(30s);
}

使用 server.pem 和客户端

openssl s_client -connect 127.0.0.1:6443 <<< $'FIRST\nSECOND\nTHIRD\nFOURTH'

精确显示预期

Accepted from 127.0.0.1:40198
Handshake: Success
Received:  "FIRST"
Available: 20/0
Received:  "SECOND"
Available: 13/0
Received:  "THIRD"
Available: 7/0
Received:  "FOURTH"
Available: 0/0

任何剩下的批评都是

• 字符串提取效率不是特别高
• 这不如首先将套接字与链相关联（在我的代码中，我已经这样做了，所以会话类 （） 中的整个链是多余的）bind_executorSomeClass
• 事实上，你比较error_codes，特别是跨不同的类别 - 这是行不通的。相反，与或确实对应（如果可用）进行比较（请阅读此处了解更多信息：测试特定错误条件asio::error::operation_abortederror_condition)
• 在以下情况下以静默方式中断读取循环（以及潜在的连接）。当客户端发送空消息时，这似乎“挂断”bytes <= delim.size()
• 忘记处理部分成功（例如，在 EOF 上） - 在这种特殊情况下，您可能希望在截断消息之前检查分隔符是否存在。（我的代码还没有做这部分）