ThothRpc

Thothrpc

Thothrpc adalah drop-in, holistik, kompatibel sepenuhnya, ringan, dupleks penuh dan kerangka kerja RPC dua arah untuk .NET. Itu sangat sederhana tapi kuat. Ini sepenuhnya platform agnostik dan modular, tidak membuat asumsi dari proyek seperti apa yang Anda bangun. Lapisan transportasi dan objek (untuk parameter dan metode pengembalian) Lapisan terpisah dari pustaka pangkalan dan implementasi khusus dari lapisan-lapisan ini mudah untuk memberi Anda kebebasan bagi Anda untuk dengan mudah membangun sistem RPC Anda sendiri.

Tentu saja, tidak akan sederhana jika lapisan -lapisan ini tidak termasuk untuk Anda. Perpustakaan ini dilengkapi dengan lapisan transport UDP yang andal dan dipesan yang dibangun dari litenetlib dan lapisan serialisasi yang dibangun dari paket pesan cepat dengan solusi transportasi berbasis web HTTP/2 yang aman di peta jalan.

Membangun

Nuget

Contoh penggunaan

Untuk menggunakan kode sampel berikut, Anda memerlukan 3 paket Nuget ini.

 dotnet add package ThothRpc
dotnet add package ThothRpc.LiteNetLib
dotnet add package ThothRpc.MessagePack

--atau--

 Install-Package ThothRpc
Install-Package ThothRpc.LiteNetLib
Install-Package ThothRpc.MessagePack

RPC yang diketik

Kode bersama

 public interface IClientService
{
    [ ThothMethod ] // indicates that this method is callable from server
    void PrintServerTime ( DateTime time ) ;

    Task GetHelloWorld ( ) ;
}

public interface IServerService
{
    [ ThothMethod ] // indicates that this method is callable from client
    string GetHelloWorld ( ) ;
} 

Server

 // hubs are thread-safe and can be single instanced for your entire app,
// or you can have multiple instances - its up to you
var hub = ServerHubBuilder . BuildServer ( )
    . UseTransport < LiteNetRpcServer > ( )
    . UseMessagePack ( ) // any object that is serializable by MessagePack can be used in parameters or return values
    . Build ( ) ;

var serverService = new ServerService ( hub ) ;

// register methods can be called multiple times to register multiple services to the same hub
hub . RegisterAs < IServerService > ( serverService ) ;
hub . Listen ( 9050 , "SomeConnectionKey" ) ;

// Thread.Sleep(60000);
// hub.Dispose(); // closes the connection

public class ServerService : IServerService
{
    readonly ServerHub _hub ;

    public ServerService ( ServerHub hub )
    {
        _hub = hub ;

        Task . Run ( async ( ) =>
        {
            // print the current time to all clients every second
            while ( true )
            {
                var now = DateTime . Now ;
                
                // Fire and forget
                _hub . InvokeForgetAllClients < IClientService > ( DeliveryMode . Sequenced ,
                    c => c . PrintServerTime ( now ) ) ;

                await Task . Delay ( 1000 ) ;
            }
        } ) ;
    }

    public string GetHelloWorld ( ) // called from client
    {
        return "Hello World From Server!" ;
    }
} 

Klien

 var hub = ClientHubBuilder . BuildClient ( )
    . UseTransport < LiteNetRpcClient > ( )
    . UseMessagePack ( )
    . Build ( ) ;

var clientService = new ClientService ( hub ) ;
hub . RegisterAs < IClientService > ( clientService ) ;

await hub . ConnectAsync ( "localhost" , 9050 , "SomeConnectionKey" ) ;
await clientService . GetHelloWorld ( ) ;

public class ClientService : IClientService
{
    readonly ClientHub _hub ;

    public ClientService ( ClientHub hub )
    {
        _hub = hub ;
    }

    public async Task GetHelloWorld ( )
    {
        // Method invocations not using fire-and-forget with a udp transport are always delivered reliable and ordered.
        var helloWorld = await _hub . InvokeServerAsync < IServerService , string >
            ( s => s . GetHelloWorld ( ) ) ;

        Console . WriteLine ( helloWorld ) ;
    }

    public void PrintServerTime ( DateTime time ) // called from server
    {
        Console . WriteLine ( $ "Server time: { time } " ) ;
    }
}

RPC Texeless

Kode di bawah ini sama seperti di atas, tetapi kali ini tanpa pengetikan yang kuat.

Server

 var hub = ServerHubBuilder . BuildServer ( )
    . UseTransport < LiteNetRpcServer > ( )
    . UseMessagePack ( )
    . Build ( ) ;

var serverService = new ServerService ( hub ) ;
hub . Register ( serverService , "ServerService" ) ;
hub . Listen ( 9050 , "SomeConnectionKey" ) ;

public class ServerService
{
    readonly ServerHub _hub ;

    public ServerService ( ServerHub hub )
    {
        _hub = hub ;

        Task . Run ( async ( ) =>
        {
            while ( true )
            {
                _hub . InvokeForgetAllClients ( DeliveryMode . Sequenced , 
                    "ClientService" , "PrintServerTime" , DateTime . Now ) ;

                await Task . Delay ( 1000 ) ;
            }
        } ) ;
    }

    [ ThothMethod ]
    public string GetHelloWorld ( )
    {
        return "Hello World From Server!" ;
    }
} 

Klien

 var hub = ClientHubBuilder . BuildClient ( )
    . UseTransport < LiteNetRpcClient > ( )
    . UseMessagePack ( )
    . Build ( ) ;

var clientService = new ClientService ( hub ) ;
hub . Register ( clientService , "ClientService" ) ;

await hub . ConnectAsync ( "localhost" , 9050 , "SomeConnectionKey" ) ;
await clientService . GetHelloWorld ( ) ;

public class ClientService
{
    readonly ClientHub _hub ;

    public ClientService ( ClientHub hub )
    {
        _hub = hub ;
    }

    public async Task GetHelloWorld ( )
    {
        var helloWorld = await _hub . InvokeServerAsync < string >
            ( "ServerService" , "GetHelloWorld" ) ;

        Console . WriteLine ( helloWorld ) ;
    }

    [ ThothMethod ]
    public void PrintServerTime ( DateTime time )
    {
        Console . WriteLine ( $ "Server time: { time } " ) ;
    }
} 

Menggunakan kasus

Thoth (dalam keadaan saat ini) sangat bagus untuk ...

• Jaringan Game Multiplayer
• Komunikasi layanan mikro dua arah yang sangat cepat dalam VPC yang diamankan
• Aplikasi dan alat berbasis LAN/VPN

CATATAN: Lalu lintas yang dienkripsi saat ini belum menjadi fitur tetapi akan hadir dalam transportasi HTTP/2 yang akan datang. Namun, mengimplementasikan sistem enkripsi Anda sendiri mudah dengan masuknya masuk dan jalan keluar.

Fitur

• Berbasis Runtime
  • Tidak ada file kontrak (.proTo, dll)
  • Pendaftaran titik akhir dinamis/unristrasi
• Performant
  • Desain Tekanan GC Rendah
  • Penggunaan CPU Rendah
  • Ukuran paket kecil (turun ke total 3 byte untuk panggilan api yang dioptimalkan dan lupakan)
• Berbagai konvensi panggilan
  • Doa yang diketik atau tanpa tipu
  • In-Proses Metode Langsung Panggilan Saat klien dan server berada di mesin yang sama
  • Server atau klien panggilan tembak cepat dan cepat dengan mode pengiriman yang dapat disesuaikan
  • Panggilan Permintaan Biaya-Direksi RPC yang andal
• Meminta penanganan kustomisasi untuk server dan klien secara terpisah
  • Penanganan manual yang memungkinkan semua permintaan yang masuk untuk disurvei di utas (yaitu loop permainan)
  • Penanganan kumpulan benang multi-utas dari semua permintaan yang masuk (seperti ASP.NET Core)
• Holistik dan modular
  • Transportasi dan serialisasi yang dapat dikonfigurasi
  • Data masuk dan keluar data yang dapat dikonfigurasi
  • Pencatatan No-Dependency (bekerja dengan apa pun yang Anda miliki, cukup gunakan callback)
  • Tidak ada ikatan middleware, konfigurasi injeksi ketergantungan yang diperlukan, atau kode boilerplate yang rumit