LightBus

Lighbus

Lightbus - это простая реализация для отправки асинхронных сообщений OneWay или с возвратом для приложений .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 CORE

Если вы используете Core ASP.NET, просто установите LightBus.microsoft.dependencyInction, этот пакет позволяет автоматически зарегистрировать обработчик сообщений, просто используя Sintax ниже.

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

Создание сообщения и обработчиков

Сообщение

Чтобы создать сообщение очень просто, вам просто нужен класс и реализовать интерфейс IMessage как и ниже.

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

MessageHandler

Как сообщение, вам просто нужен класс и реализация: IMessageHandler<TMessage> where TMessage: IMessage Interface, как ниже ниже

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