c++ - 是否有用于阻塞 boost::asio TCP 连接的 boost::iostreams(双向)设备？

Question

我正在研究可移植的 C++ 库，阻止对文件系统和网络的 I/O 访问。 看起来boost::filesystem、boost::iostreams 和boost::asio 将介于这三者之间他们的工作。

明确地说，我目前对boost::asio 的异步方面不感兴趣；我只想要一个可移植的阻塞式网络接口(interface)。

深入研究，我看到 boost::iostreams 有一个设备的概念，每个设备都有一个关联的 mode concept .双向模式似乎专门为流式访问全双工 TCP 连接而量身定制。太棒了。

boost::iostreams 似乎不支持实际打开 TCP 连接(与本地文件系统不同。)没关系，boost::asio 肯定会让我打开连接，将其适本地建模为双向 Device，并将其包装在 boost::iostreams::stream 中。

..除非它不会？我看到 boost::asio::ip::tcp::iostream ，它将取代 boost::iostreams::stream，但大概不会充当 Device。

我知道 tcp::iostream 的行为类似，但我仍然更愿意只针对一个接口(interface)而不是两个接口(interface)学习和编写代码。具体来说，处理两个错误处理机制和异常层次结构并不是很容易接受。

那么，问题来了:我是瞎了吗？也许这两个库之间存在一个适配器，我错过了谷歌搜索。或者也许有人已经发布了这样的适配器作为我可以放入的第 3 方组件？

Answer 1

我不知道直接映射。但是，如果您有兴趣，编写这样一个设备是相当简单的。此版本针对非 EOF 错误抛出 boost::system::system_error，但您可以选择执行其他操作。

#include <iosfwd>

#include <boost/asio/io_service.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <boost/asio/buffer.hpp>
#include <boost/iostreams/categories.hpp>
#include <boost/system/system_error.hpp>


class asio_stream_device
{
public:
    typedef char char_type;
    typedef boost::iostreams::bidirectional_device_tag category;

    explicit asio_stream_device(boost::asio::ip::tcp::socket& sock) : socket_(sock)
    {

    }

    std::streamsize read(char* s, std::streamsize n)
    {
        // Read up to n characters from the underlying data source
        // into the buffer s, returning the number of characters
        // read; return -1 to indicate EOF
        boost::system::error_code ec;

        std::size_t rval = socket_.read_some(boost::asio::buffer(s, n), ec);
        if (!ec)
        {
            return rval;
        }
        else if (ec == boost::asio::error::eof)
        {
            return -1;
        }
        else
        {
            throw boost::system::system_error(ec,"read_some");
        }

    }


    std::streamsize write(const char* s, std::streamsize n)
    {
        // Write up to n characters to the underlying
        // data sink into the buffer s, returning the
        // number of characters written

        boost::system::error_code ec;
        std::size_t rval = socket_.write_some(boost::asio::buffer(s, n), ec);
        if (!ec)
        {
            return rval;
        }
        else if (ec == boost::asio::error::eof)
        {
            return -1;
        }
        else
        {
            throw boost::system::system_error(ec,"write_some");
        }

    }



private:

    boost::asio::ip::tcp::socket& socket_;

};

基本上，正常打开/连接套接字，然后将其传递给构造函数。该示例只是读取并输出到屏幕。

void test
{
   namespace asio = boost::asio;
   namespace io = boost::iostreams;

   asio::io_service service;
   asio::ip::tcp::socket socket(service);


   asio::ip::tcp::endpoint remote -  ...; ////

   socket.connect(remote);

   io::stream<asio_stream_device> str(socket);

   std::string line;

   while (std::getline(str, line)) {
    std::cout << line << std::endl;
   }
}