carrier

ผู้ให้บริการ

กรอบงานเซิร์ฟเวอร์เครือข่าย C++ สมัยใหม่

สร้างด้วย std::experimental::net, Boost.Asio, Boost.Beast และบัฟเฟอร์ Google Protocol
ด้วยบริการไคลเอ็นต์ เซิร์ฟเวอร์ พร็อกซี เกตเวย์ พุช และการถ่ายโอนไฟล์ที่รองรับ

ภาพรวม

ไคลเอ็นต์การถ่ายโอนไฟล์แบบอะซิงโครนัส

# include < file_transfer_client_async.hpp >

int main ( int argc, char * argv[])
{
    if (argc < 3 )
    {
        std::cerr << " Usage: " << argv[ 0 ] << " <host> <port> [<file|dir>] ... " << std::endl;
        return 1 ;
    }

    net::io_context ioc;
    auto session_ = std::make_shared<session>(ioc, argv[ 1 ], argv[ 2 ]);

    std::thread t ([&ioc]{ ioc. run (); });

    for ( int i = 3 ; i != argc; ++i)
         session_-> transfer ( std::string (argv[i]));

    session_-> transfer ( fs::path ( " path/transfer/ " ));
    session_-> transfer ( std::string ( " []<typename ...>(){}(); n " ), " file/transfer.txt " );

    t. join ();

    return 0 ;
}

การซิงค์ไคลเอ็นต์การถ่ายโอนไฟล์

# include < file_transfer_client_sync.hpp >

int main ( int argc, char * argv[])
{
    if (argc < 3 )
    {
        std::cerr << " Usage: " << argv[ 0 ] << " <host> <port> [<file|dir>] ... " << std::endl;
        return 1 ;
    }

    try
    {
        net::io_context ioc;
        auto session_ = std::make_shared<session>(ioc, argv[ 1 ], argv[ 2 ]);

        for ( int i = 3 ; i != argc; ++i)
             session_-> transfer ( std::string (argv[i]));

        session_-> transfer ( fs::path ( " path/transfer/ " ));
        session_-> transfer ( std::string ( " []<typename ...>(){}(); n " ), " file/transfer.txt " );
    }
    catch (std:: exception & e)
    {
        std::cerr << e. what () << std::endl;
    }

    return 0 ;
}

เซิร์ฟเวอร์การถ่ายโอนไฟล์ async

# include < file_transfer_server_async.hpp >

int main ( int argc, char * argv[])
{
    std::string host ( " 0.0.0.0 " );
    unsigned short port = 2020 ;

    if (argc == 4 )
    {
        host = argv[ 1 ];
        port = static_cast < unsigned short >( std::atoi (argv[ 2 ]));
    }
    else if (argc != 2 )
    {
        std::cerr << " Usage: " << argv[ 0 ] << " [<host> <port>] <path> n " ;
        return 1 ;
    }

    auto const host_ = net::ip::make_address (host);
    auto const threads = static_cast < int >( std::thread::hardware_concurrency ());

    net::io_context ioc{threads};
    std::make_shared<listener>(ioc, endpoint_t {host_, port}, argv[argc - 1 ])-> run ();

    std::vector<std::thread> v;
    v. reserve (threads - 1 );

    for ( auto i = threads - 1 ; i > 0 ; --i)
        v. emplace_back ([&ioc]{ ioc. run (); });
    ioc. run ();

    return 0 ;
}