是否有一个boost ::输入输出流（双向）用于阻塞的boost :: ASIO TCP连接？(Is

我调查C ++库为便携式，阻断到文件系统和网络I / O访问。它看起来像boost::filesystem ， boost::iostreams和boost::asio的意志，他们三人之间，做这项工作。

需要明确的是，我不是当前的异步方面感兴趣boost::asio ; 我只想要一个便携式，阻断接口到网络。

挖，我看到boost::iostreams有设备，每个都有一个相关的概念模式概念。双向模式似乎特别手工定制流媒体到全双工TCP连接访问。真棒。

boost::iostreams似乎并没有提供真正打开TCP连接的支持（不像本地文件系统）。这很好，肯定boost::asio会让我打开连接，适当其建模为双向Device ，并在其包装boost::iostreams::stream 。

..except也不会？我看到boost::asio::ip::tcp::iostream ，将取代boost::iostreams::stream ，但想必不是作为一个Device 。

据我所知， tcp::iostream将采取类似行动，但我还是喜欢学习和代码对只有一个接口，而不是两个。具体来说，处理两个错误处理机制与异常层次结构不是很可口。

因此，问题：我这是瞎了？也许这两个库之间的适配器存在，我错过了周围的Googling。也许有人已经发布了这样的适配器作为第三方组件，我可以在下降？

我不知道的直接映射。但是，如果你有兴趣，写这样的设备是相当简单的。这个版本抛出boost::system::system_error非EOF错误，但你可以选择做别的事情。

#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;
   }
}