ThothRpc

thothrpc

THOTHRPC是.NET的液位，整體，完全AOT兼容，輕巧，完全雙鍊和雙向RPC框架。它很簡單，但功能強大。它完全是平台不可知和模塊化，沒有假設您正在構建哪種項目。傳輸和對象序​​列化（對於參數和方法返回）與基本庫是分開的，並且這些圖層的自定義實現很容易為您提供自由，讓您可以輕鬆構建自己的RPC系統。

當然，如果不包括這些層，這並不簡單。該庫帶有由LiteNetlib建造的可靠和有序的UDP傳輸層，並在路線圖上使用安全的HTTP/2基於安全的HTTP/2基於安全的HTTP/2基於Web的傳輸解決方案構建的序列化層。

建造

nuget

用法示例

要使用以下示例代碼，您需要這3個Nuget軟件包。

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

- 或者 -

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

鍵入RPC

共享代碼

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

伺服器

 // 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!" ;
    }
} 

客戶

 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

下面的代碼與上面相同，但是這次沒有任何強大的打字。

伺服器

 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!" ;
    }
} 

客戶

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

用例

Thoth（以目前的狀態）非常適合…

• 遊戲多人遊戲網絡
• 在有擔保VPC內的超快速可靠的雙向微服務通信
• 基於LAN/VPN的應用程序和工具

注意：目前尚未加密安全流量，但將在即將到來的HTTP/2傳輸中存在。但是，通過入口和出口回調，實現自己的加密系統很容易。

特徵

• 基於運行時
  • 沒有合同文件（.proto，ect）
  • 動態端點註冊/未註冊
• 表演者
  • 低GC壓力設計
  • CPU使用率低
  • 小數據包尺寸（降至3個字節總數，以進行優化的火，忘記呼叫）
• 各種呼叫慣例
  • 打字或無打字調用
  • 客戶和服務器在同一台計算機上時，在過程中直接調用
  • 快速射擊通話服務器或具有可自定義交付模式的客戶端
  • 可靠的RPC雙向請求響應調用
• 請求分別為服務器和客戶端進行自定義
  • 手動處理允許在線程上進行輪詢所有傳入請求（即遊戲環）
  • 所有傳入請求的多線程池處理（例如ASP.NET Core）
• 整體和模塊化
  • 可配置的運輸和序列化
  • 可配置的數據入口和出口
  • 無依賴性記錄（與您擁有的任何東西一起使用，只需使用回調）
  • 沒有中間件搭配，所需的依賴注入配置或複雜的樣板代碼