tubus Download - ดาวน์โหลดซอร์สโค้ด tubus

tubus

หมวดหมู่อื่นๆ

v1.2.1

ดาวน์โหลด

readme

พื้นที่เก็บข้อมูลนี้มีไลบรารี C ++ Tubus Cross-Platform ซึ่งใช้โปรโตคอลการขนส่งสตรีมมิ่งตาม UDP โปรโตคอลได้รับการพัฒนา แต่เดิมเป็นส่วนหนึ่งของยูทิลิตี้หนอน สามารถใช้งานได้ในกรณีที่การใช้ TCP เป็นเรื่องยากตัวอย่างเช่นสำหรับแอปพลิเคชันที่ทำงานผ่าน NAT เป็นทางเลือกเพื่อเพิ่มความปลอดภัยในการเชื่อมต่อแพ็คเก็ต tubus สามารถทำให้งงงวยได้โดยคีย์ที่แชร์ล่วงหน้า

เพื่อความสะดวกในการพัฒนาแอพพลิเคชั่นตาม boost::asio มีการเสนอตัวรับแบบดั้งเดิม tubus::socket and tubus::acceptor tubus::socket Primitive ใช้ asyncreadstream , asyncwritestream , สตรีม , แนวคิด 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 );
}

เปิด - เปิดช่องทางที่จุดสิ้นสุดที่ระบุ
ปิด - ปิดช่องทางโดยไม่ต้องแจ้งด้านระยะไกลขัดจังหวะการดำเนินการแบบอะซิงโครนัสทั้งหมด
SHUTDOWN - ปิดช่องทางด้วยการแจ้งเตือนของระยะไกลขัดจังหวะการดำเนินการแบบอะซิงโครนัสทั้งหมด
ยอมรับ - รอการเชื่อมต่อแบบอะซิงโครนัสจากเพียร์ที่ระบุ
เชื่อมต่อ - เริ่มการเชื่อมต่อแบบอะซิงโครนัสกับเพียร์ที่ระบุ
อ่าน - ผนวกการดำเนินการอ่านแบบอะซิงโครนัสโทรกลับเมื่อบัฟเฟอร์ผ่านเต็มหรือเกิดข้อผิดพลาด
เขียน - ผนวกการดำเนินการเขียนแบบอะซิงโครนัสโทรกลับเมื่อบัฟเฟอร์ผ่านถูกส่งหรือเกิดข้อผิดพลาด
เขียนได้ - ส่งคืนจำนวนไบต์ที่สามารถส่งได้ทันที
อ่านได้ - ส่งคืนจำนวนไบต์สำหรับการอ่าน
โฮสต์ - ส่งคืนจุดสิ้นสุดท้องถิ่นของช่อง
เพียร์ - ส่งคืนจุดสิ้นสุดระยะไกลของช่องสัญญาณ

ตัวอย่าง

ข้อมูลผู้บริโภคใช้งานโดยใช้ 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();

สร้าง

คุณสามารถดาวน์โหลดแพ็คเกจ prebuild สำหรับแพลตฟอร์ม Debian และ Windows

ห้องสมุดขึ้นอยู่กับ 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 Library Directory
tubus_dll - พา ธ ไปยังไฟล์ไลบรารี tubus.dll
tubus_lib - เส้นทางไปยัง tubus -static.lib, tubus.lib, libtubus.a หรือ libtubus.so ไฟล์ไลบรารี

การทำงานร่วมกัน

รายงานข้อบกพร่องและแนะนำการปรับปรุง

ใบอนุญาต

Tubus ได้รับใบอนุญาตภายใต้ Apache License 2.0 ซึ่งหมายความว่าคุณมีอิสระที่จะได้รับและใช้เพื่อวัตถุประสงค์ทางการค้าและไม่ใช่เชิงพาณิชย์ตราบใดที่คุณปฏิบัติตามเงื่อนไข ดูไฟล์ License.txt สำหรับรายละเอียดเพิ่มเติม