tubus下载 - tubus源代码下载

tubus

其他类别

v1.2.1

下载

读书我

该存储库包含跨平台C ++小管库，该库在基于UDP的流传输协议中实现了。该协议最初是作为虫洞实用程序的一部分而开发的。例如，在使用TCP的使用情况下，可以使用它，例如在NAT上运行的应用程序。可选地，为了提高连接安全性，可以通过预共享密钥混淆tubus数据包。

为了方便开发基于boost::asio的应用程序，提供了类似ASIO的原语tubus::socket and tubus::acceptor 。 tubus::socket原始实施疗法，异步流，异步流，流， SyncreadStream和SyncWritestream概念，因此可以用作boost::asio::ssl::stream的下层。

核

Tubus和ann的接口。

 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平台的Prenuild软件包。

图书馆取决于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导入变量。