ThothRpc 다운로드 ThothRpc 소스 코드 다운로드

ThothRpc

기타 카테고리

v0.7.5-beta

다운로드

Thothrpc

ThothRPC는 .NET 용 드롭 인, 전체 론적, 완전 AOT 호환, 경량, 가벼운 이중 및 양방향 RPC 프레임 워크입니다. 단순하지만 강력합니다. 그것은 완전히 플랫폼의 불가지론적이고 모듈 식으로, 어떤 종류의 프로젝트를 구축하고 있는지 가정하지 않습니다. 전송 및 객체 직렬화 (매개 변수 및 메소드 리턴의 경우) 레이어는 기본 라이브러리와 분리되어 있으며 이러한 레이어의 사용자 정의 구현은 쉽게 소유 한 RPC 시스템을 쉽게 빌드 할 수있는 자유를 제공 할 수 있습니다.

물론,이 레이어가 포함되지 않은 경우 간단하지 않을 것입니다. 이 라이브러리에는 Litenetlib에서 구축 된 신뢰할 수 있고 주문한 UDP 전송 계층과 로드맵에서 안전한 HTTP/2 웹 기반 전송 솔루션이있는 빠른 메시지 팩으로 구축 된 직렬화 레이어가 제공됩니다.

짓다

너겟

사용 예제

다음 샘플 코드를 사용하려면이 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 전송에 존재합니다. 그러나 유입 및 egress 콜백으로 자신의 암호화 시스템을 구현하는 것은 쉽습니다.

특징

런타임 기반
- 계약 파일 없음 (.proto, ect)
- 동적 엔드 포인트 등록/등록
수행자
- 낮은 GC 압력 설계
- 낮은 CPU 사용
- 작은 패킷 크기 (최적화 된 화재 및 잊어 버리기 위해 총 3 바이트가 줄어 듭니다)
다양한 전화 규칙
- 입력 또는 타이핑이없는 호출
- 클라이언트와 서버가 같은 컴퓨터에있을 때 프로세스 내 직접 메소드 호출
- 사용자 정의 가능한 전달 모드가있는 빠른 발사 및 포 게트 통화 서버 또는 클라이언트
- 신뢰할 수있는 RPC 양방향 요청-응답 호출
서버 및 클라이언트에 대한 사용자 정의 처리 요청을 별도로 요청합니다
- 모든 들어오는 요청을 스레드에서 투표 할 수있는 수동 처리 (즉, 게임 루프)
- 모든 들어오는 요청의 다중 스레드 스레드 풀 처리 (ASP.NET Core와 같은)
전체 론적 및 모듈 식
- 구성 가능한 전송 및 직렬화
- 구성 가능한 데이터 유입 및 egress
- 의존적 로깅이 없음 (콜백을 사용하는 것만으로도 작동)
- 미들웨어 타이 인, 필요한 종속성 주입 구성 또는 복잡한 보일러 플레이트 코드가 없습니다.