ThothRpc

thothrpc

ThothRPC عبارة عن إطار RPC متكامل ، شامل ، متوافق تمامًا ، خفيفة الوزن ، مزدوج الوجهين الكامل وإطار RPC ثنائي الاتجاه لـ .NET. إنها ميتة بسيطة ولكنها قوية. إنه منصة تمامًا غير ملائمة ومعيار ، لا تقدم أي افتراضات عن نوع المشروع الذي تبنيه. تكون طبقات النقل والتسلسل الكائن (بالنسبة للمعلمات وعودة الطريقة) منفصلة عن المكتبة الأساسية ، كما أن التنفيذ المخصص لهذه الطبقات يسهل عليك أن تمنحك الحرية لك لبناء نظام RPC الخاص بك بسهولة.

بالطبع ، لن يكون الأمر بسيطًا إذا لم يتم تضمين هذه الطبقات لك. تأتي هذه المكتبة مع طبقة نقل UDP موثوقة ومرتبة تم تصميمها من Litenetlib وطبقة تسلسل مبنية على حزمة الرسائل السريعة مع حل نقل على شبكة الإنترنت HTTP/2 آمن على خريطة الطريق.

يبني

nuget

أمثلة الاستخدام

لاستخدام رمز العينة التالي ، تحتاج إلى حزم 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 القادم. ومع ذلك ، فإن تنفيذ نظام التشفير الخاص بك أمر سهل مع عوامل التراجع عن Ingress و Egress.

سمات

• قائم على وقت التشغيل
  • لا توجد ملفات عقد (.proto ، إلخ)
  • تسجيل نقطة النهاية الديناميكية/عدم التسجيل
• أداء
  • تصميم ضغط GC منخفض
  • استخدام وحدة المعالجة المركزية منخفضة
  • حجم الحزمة الصغيرة (أسفل إلى 3 بايت إجمالي لحريق محسّن ونسيان المكالمة)
• اتفاقيات الاتصال المختلفة
  • المكتب أو الاحتجاج غير المكتوب
  • مكالمات الطريقة المباشرة أثناء العملية عندما يكون العميل والخادم على نفس الجهاز
  • خادم الاتصال السريع للحرائق والناشئة أو العميل مع وضع توصيل قابل للتخصيص
  • استجابة استجابة RPC ثنائية الاتجاه الموثوقة
• طلب تخصيص تخصيص الخادم والعميل بشكل منفصل
  • التعامل اليدوي الذي يسمح بجميع الطلبات الواردة لإقامة خيط (أي حلقة اللعبة)
  • معالجة تجمع الخيوط متعددة الخيوط لجميع الطلبات الواردة (مثل ASP.NET Core)
• شمولي ومعيار
  • النقل والتسلسل القابل للتكوين
  • دخول البيانات القابلة للتكوين والخروج
  • تسجيل عدم الاعتماد (يعمل مع كل ما لديك ، فقط استخدم عمليات الاسترجاعات)
  • لا يوجد أي تعادل الوسيطة أو تكوين حقن التبعية المطلوب أو رمز الغلاية المعقدة