tubusのダウンロードtubusソースコードのダウンロード

tubus

その他のカテゴリー

v1.2.1

ダウンロード

readme

このリポジトリには、 UDPに基づいたストリーミングトランスポートプロトコルを実装するクロスプラットフォームC ++ Tubusライブラリが含まれています。このプロトコルは、もともとワームホールユーティリティの一部として開発されました。たとえば、TCPの使用が困難な場合、NATを介して実行されるアプリケーションで使用できます。オプションで、接続セキュリティを増やすために、 tubusパケットは、事前に共有キーによって難読化できます。

boost::asio 、ASIOのようなプリミティブのtubus::socket and tubus::acceptorが提供されたASIOに基づいてアプリケーションを開発する便利さのために提供されます。 tubus::socket Primitiveは、 asyncreadStream 、 asyncwriteStream 、 Stream 、 SyncreadStream 、 SyncwriteStreamの概念を実装しているため、 boost::asio::ssl::streamの下層として使用できます。

コア

Tubus -Quannelインターフェイス。

 namespace tubus {
...
struct channel
{
    virtual ~channel () noexcept ( true ) {}
    virtual void close () noexcept ( true ) = 0;
    virtual void open ( const endpoint& local) noexcept ( false ) = 0;
    virtual void connect ( const endpoint& remote, const callback& handle) noexcept ( true ) = 0;
    virtual void accept ( const endpoint& remote, const callback& handle) noexcept ( true ) = 0;
    virtual void read ( const mutable_buffer& buffer, const io_callback& handle) noexcept ( true ) = 0;
    virtual void write ( const const_buffer& buffer, const io_callback& handle) noexcept ( true ) = 0;
    virtual void shutdown ( const callback& handle) noexcept ( true ) = 0;
    virtual size_t writable () const noexcept ( true ) = 0;
    virtual size_t readable () const noexcept ( true ) = 0;
    virtual endpoint host () const noexcept ( false ) = 0;
    virtual endpoint peer () const noexcept ( false ) = 0;
};
...
channel_ptr create_channel (boost::asio::io_context& io, uint64_t /* pre-shared key */ secret = 0 ) noexcept ( true );
}

開く- 指定されたエンドポイントでチャネルを開きます
閉じる- リモート側に通知せずにチャネルを閉じ、すべてのペンデッド非同期操作を中断します
シャットダウン- リモート側の通知でチャネルを閉じ、すべてのペンディング非同期操作を中断します
受け入れる- 指定されたピアからの接続を非同期に待つ
接続- 指定されたピアに非同期的に接続します
読み取り- 非同期読み取り操作を追加する、渡されたバッファーがいっぱいになったときに呼び戻すか、エラーが発生した
書き込み- 非同期書き込み操作を追加し、渡されたバッファーが送信されたときに呼び戻すか、エラーが発生した
書き込み可能- すぐに送信できるバイト数を返します
読み取り可能- 読みに利用できるバイト数を返します
ホスト- チャネルのローカルエンドポイントを返します
ピア- チャネルのリモートエンドポイントを返します

例

tubus::channelを使用して実装されたデータコンシューマ。

# include < tubus/channel.h >
...
auto consumer = tubus::create_channel(io_service, key);
consumer-> open (local_endpoint);
consumer-> connect (remote_endpoint, [&]( const boost::system::error_code& error)
{
    ...
    tubus::mutable_buffer buffer (consumer-> readable ()); 
    
    // if the buffer is empty, the callback will be called when all previously
    // pended read operations are completed and more data can be read
    
    consumer-> read (buffer, [&]( const boost:: system ::error_code& error, size_t size)
    {
        ...
        consumer-> shutdown ();
    };
});

tubus::socketを使用して実装されたデータプロデューサー。

# include < tubus/socket.h >
...
tubus::socket producer (io_service, key);
producer.open(local_endpoint);
producer.async_accept(remote_endpoint, [&]( const boost::system::error_code& error)
{
    ...
    tubus::const_buffer buffer ( " hello, world! " );
    producer. async_write_some (buffer, [&]( const boost:: system ::error_code& error, size_t size)
    {
        ...
        producer. shutdown ();
    };
});

tubus::acceptor （ Linuxのみ）を使用して実装されたサーバー。

# include < tubus/acceptor.h >
...
tubus::acceptor server (io_service, key);
server.open(local_endpoint);

tubus::socket peer1 (io_service);
server.accept(peer1);

peer1.read_some(...);
peer1.write_some(...);

tubus::socket peer2 (io_service);
server.accept(peer2);

peer2.read_some(...);
peer2.write_some(...);

peer1.shutdown();
peer2.shutdown();

server.close();

boost::asio::ssl::stream and tubus::socketを使用して実装された暗号化されたストリーム。

# include < boost/asio/ssl.hpp >
# include < tubus/socket.h >
...
boost::asio::ssl::stream<tubus::socket> client (tubus::socket(io_service, key), ssl_ctx);

client.lowest_layer().open(local_endpoint);
client.lowest_layer().connect(remote_endpoint);
client.handshake(boost::asio::ssl::stream_base::client);

boost::asio::read (client, ...);
boost::asio::write (client, ...);

client.shutdown();

建てる

DebianプラットフォームとWindowsプラットフォーム用のPreBuildパッケージをダウンロードできます。

ライブラリはboostに依存します。テストを作成するには、 opensslが必要です。

 cd ~
git clone https://github.com/novemus/tubus.git
cd ~/tubus
cmake -B ./build [-DBOOST_ROOT=...] [-DBUILD_TESTING=ON [-DOPENSSL_ROOT_DIR=...]]
cmake --build ./build --config Release --target tubus_shared tubus_static [tubus_ut]
cmake --build ./build --target install

CMakeインポート変数。