LightBus

Lighbus

LightBus ist eine einfache Implementierung zum Senden von asynchronen Nachrichten an eine Wege oder mit Rückgabe für .NET -Anwendungen.

Installation

Die Bibliothek ist über Nuget -Pakete erhältlich:

Paketmanager

 Install-Package LightBus.Core
Install-Package LightBus.Microsoft.DependencyInjection

.NET CLI

dotnet add package LightBus.Core
dotnet add package LightBus.Microsoft.DependencyInjection

Starter bekommen

ASP.NET CORE

Wenn Sie ASP.NET Core verwenden, installieren Sie einfach lightbus.microsoft.DependencyInjection. Mit diesem Paket können Sie den Nachrichtenhandler automatisch registrieren, indem Sie nur die unten stehende Sintax verwenden.

 public void ConfigureServices ( IServiceCollection services )
{
    .. .
    services . AddLightBus ( ) ;
    .. .
} 

Erstellen von Nachrichten und Handlern

Nachricht

Um eine Nachricht zu erstellen, ist sehr einfach, Sie benötigen nur eine Klasse und implementieren IMessage -Schnittstellen wie unten

 public class SampleMessage : IMessage
{
    public string Value { get ; set ; }
}

MessageHandler

Wie eine Nachricht benötigen Sie nur eine Klasse und implementiert: IMessageHandler<TMessage> where TMessage: IMessage -Schnittstelle wie unten wie unten

 public class SampleMessageHandler : IMessageHandler < SampleMessage >
{
    public Task HandleAsync ( SampleMessage message )
    {
        Debug . WriteLine ( message . Value ) ;
        return Task . CompletedTask ;
    }
}

Nachricht senden

Um ILightBus PushAsync<TMessage>(TMessage) auszulösen

 [ Route ( "" ) ]
public class ValuesController : Controller
{
    private readonly ILightBus _lightBus ;

    public ValuesController ( ILightBus lightBus )
    {
        _lightBus = lightBus ;
    }

    [ HttpGet ]
    public async Task < string > Get ( )
    {
        await _lightBus . PushAsync (
            new SampleMessage { Value = "Hello LightBus" } ) ;

        return "Ok" ;
    }
} 

Erstellen von Nachrichten und Handlern mit Antwort

Nachrichtenantwort

Um eine Nachricht zu erstellen ist sehr einfach, benötigen Sie nur eine Klasse und implementieren IMessage<out Response> Schnittstelle wie unten

 public class SampleMessageResponse : IMessage < string >
{
    public string Value { get ; set ; }
}

MessageHandLerResponse

Wie eine Nachricht benötigen Sie nur eine Klasse und implementiert: IMessageHandler<TMessage, TResponse> where TMessage: IMessage<TResponse> Schnittstelle wie unten wie unten

 public class SampleMessageHandler : IMessageHandler < SampleMessageResponse , string >
{
    public Task < string > HandleAsync ( SampleMessageResponse message )
    {
        return Task . FromResult ( $ "Hello { message . Value } " ) ;
    }
}

Nachricht mit Antwort senden

Um ILightBus Task<TResponse> SendAsync<TMessage, TResponse>(Action<TMessage> messageHandler = null) auszulösen

 [ Route ( "" ) ]
public class ValuesController : Controller
{
    private readonly ILightBus _lightBus ;

    public ValuesController ( ILightBus lightBus )
    {
        _lightBus = lightBus ;
    }

    [ HttpGet ]
    public async Task < string > Get ( )
    {
        await _lightBus . SendAsync < SampleMessageResponse , string > ( msg => msg . Value = "LightBus" ) ;
    }
}