LightBus

Lighbus

Lightbusは、非同期メッセージをワンウェイまたは.NETアプリケーションのリターンとともに送信するための簡単な実装です。

インストール

ライブラリは、NUGETパッケージを介して利用できます。

パッケージマネージャー

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

.NET CLI

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

スターターを取得します

ASP.NETコア

ASP.NET Coreを使用している場合は、LightBus.Microsoft.DependencyInjectionをインストールするだけで、このパッケージを使用すると、下のSintaxを使用してメッセージハンドラーを自動的に登録できます。

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

メッセージとハンドラーの作成

メッセージ

メッセージを作成するには非常に簡単です。クラスが必要で、以下のようにIMessageインターフェイスを実装するだけです

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

MessageHandler

メッセージのように、クラスと実装が必要です： IMessageHandler<TMessage> where TMessage: IMessageインターフェイス

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

メッセージの送信

メッセージをトリガーするには、 ILightBusインターフェイスを挿入し、 PushAsync<TMessage>(TMessage)を使用して以下のようなメッセージを派遣する必要があります

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

応答したメッセージとハンドラーを作成します

メッセージ応答

メッセージを作成するには非常に簡単ですが、クラスが必要であり、以下のようにIMessage<out Response>インターフェイスを実装するだけです

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

MessageHandLerresponse

メッセージのように、クラスと実装が必要なだけです。imessagehandler IMessageHandler<TMessage, TResponse> where TMessage: IMessage<TResponse>インターフェイス

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

応答でメッセージを送信します

メッセージをトリガーするには、 ILightBusインターフェイスを挿入し、 Task<TResponse> SendAsync<TMessage, TResponse>(Action<TMessage> messageHandler = null)を使用する必要があります。

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