4

ファイルシステムとネットワークへのI/OアクセスをブロックするポータブルなC++ライブラリを調査しています。のように見えboost::filesystem、3人の間で仕事をしますboost::iostreams。boost::asio

明確にするために、私は現在、boost::asio;の非同期の側面には興味がありません。ネットワークへのポータブルなブロッキングインターフェイスが必要です。

掘り下げてみると、boost::iostreamsデバイスの概念があり、それぞれに関連するモードの概念があります。双方向モードは、特に全二重TCP接続へのストリーミングアクセス用に手動で調整されているように見えます。素晴らしい。

boost::iostreams（ローカルファイルシステムとは異なり）実際にTCP接続を開くためのサポートを提供していないようです。それで問題ありboost::asioません。確かに、接続を開き、双方向として適切にモデル化しDevice、でラップすることができboost::iostreams::streamます。

..そうでないことを除いて？が表示されますboost::asio::ip::tcp::iostream。これは、に置き換わるものboost::iostreams::streamですが、おそらくとしては機能しませんDevice。

が同じように動作することは理解していますtcp::iostreamが、それでも2つではなく、1つのインターフェイスに対して学習してコーディングしたいと思います。具体的には、2つのエラー処理レジームと例外階層を処理することはあまり口に合いません。

だから、質問：私は盲目ですか？たぶん、2つのライブラリの間にアダプタが存在しますが、それは私がぐるぐる回ることを逃しました。あるいは、誰かが私が立ち寄ることができるサードパーティのコンポーネントなどのアダプタをすでにリリースしているのでしょうか？

4

1 に答える 1

7

私は直接マッピングを知りません。ただし、興味がある場合は、そのようなデバイスを作成するのはかなり簡単です。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;
   }
}
于 2012-08-19T01:41:57.760 に答える