tubus 다운로드 - tubus 소스 코드 다운로드

tubus

기타 카테고리

v1.2.1

다운로드

readme

이 저장소에는 Cross-Platform C ++ Tubus 라이브러리가 포함되어 있으며 UDP 를 기반으로 한 스트리밍 전송 프로토콜을 구현합니다. 이 프로토콜은 원래 Wormhole 유틸리티의 일부로 개발되었습니다. 예를 들어 NAT를 통해 실행되는 응용 분야에서는 TCP의 사용이 어려운 경우에 사용할 수 있습니다. 선택적으로 연결 보안을 향상시키기 위해 tubus 패킷은 사전 공유 키로 난독 화 될 수 있습니다.

boost::asio 기반으로 응용 프로그램을 개발하는 편의를 위해 Asio와 같은 프리미티브 tubus::socket tubus::acceptor 제공됩니다. tubus::socket Primitive는 AsyncreadStream , Asyncwritestream , Stream , SyncreadStream 및 SynCwriteStream 개념을 구현하므로 boost::asio::ssl::stream 의 하부 층으로 사용할 수 있습니다.

핵심

Tubus сhannel 인터페이스.

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

OPEN- 지정된 엔드 포인트에서 채널을 엽니 다
CLOSE- 원격쪽에 알리지 않고 채널을 닫고, 모든 보완 된 비동기 작업을 방해합니다.
셧다운 - 원격 쪽 알림으로 채널을 닫고 모든 보완 된 비동기 작업을 방해합니다.
수락 - 지정된 피어의 연결을 위해 비동기 적으로 기다립니다.
연결 - 지정된 피어에 비동기 적으로 연결을 시작합니다
읽기 - 비동기식 읽기 작업에 추가, 전달 된 버퍼가 가득 차 있거나 오류가 발생했을 때 다시 호출됩니다.
쓰기 - 비동기 쓰기 작업이 추가되고 전달 된 버퍼가 전송되거나 오류가 발생했을 때 다시 호출됩니다.
쓰기 가능 - 즉시 전송할 수있는 바이트 수를 반환합니다.
읽기 가능 - 읽을 수있는 바이트 수를 반환합니다
호스트 - 채널의 로컬 엔드 포인트를 반환합니다
피어 - 채널의 원격 엔드 포인트를 반환합니다

예

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 및 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 가져 오기 변수.

tubus_use_shared_lib = on- 동적 라이브러리 가져 오기 CMAKE 프로젝트로, 기본적으로 정적 라이브러리 검색
tubus_include_dir- Tubus 헤더 파일 디렉토리
Tubus_library_dir- Tubus 라이브러리 디렉토리
Tubus_dll- Tubus.dll 라이브러리 파일로가는 경로
tubus_lib- Tubus- static.lib, tubus.lib, libtubus.a 또는 libtubus.so 라이브러리 파일의 경로