Загрузка QsMessaging - Загрузка исходного кода QsMessaging

QsMessaging

Другие категории

1.0.0

Скачать

QsСообщения

QsMessaging — это библиотека .NET 8, предназначенная для отправки и получения сообщений между службами или компонентами вашего приложения с помощью RabbitMQ . Он поддерживает горизонтальную масштабируемость, позволяя нескольким экземплярам одной и той же службы эффективно обрабатывать сообщения.
Доступно на NuGet для бесшовной интеграции:

Простое масштабируемое решение для обмена сообщениями для распределенных систем.

Установка

Установите пакет с помощью следующей команды:

dotnet add package QsMessaging

Регистрация библиотеки

Зарегистрировать библиотеку очень просто. Добавьте следующие две строки кода в файл Program.cs :

 // Add QsMessaging (use the default configuration)...
builder . Services . AddQsMessaging ( options => { } ) ;

.. .
await host . UseQsMessaging ( ) ;

Конфигурация по умолчанию

КроликMQ

Хост: localhost
Имя пользователя: guest
Пароль: guest
Порт: 5672

Использование

Отправка сообщений

Договор

Определите контракт сообщения:

 public class RegularMessageContract
{
    public required string MyTextMessage { get ; set ; } 
}

Отправка сообщения

Внедрите IQsMessaging в свой класс:

 public YourClass ( IQsMessaging qsMessaging ) { }

Затем используйте его для отправки сообщения:

 await qsMessaging . SendMessageAsync ( new RegularMessageContract { MyTextMessage = "My message." } ) ;

Обработка сообщений

Для обработки сообщения создайте обработчик:

 public class RegularMessageContractHandler : IQsMessageHandler < RegularMessageContract >
{
    public Task < bool > Consumer ( RegularMessageContract contractModel )
    {
        // Process the message here
        return Task . FromResult ( true ) ;
    }
}

Шаблон запроса/ответа

Вы также можете использовать шаблон запроса/ответа для отправки запроса и ожидания ответа. Это полезно, когда вам нужно обмениваться данными между службами и ожидать ответа.

Контракт запрос/ответ

Определите контракты запроса и ответа:

 public class MyRequestContract
{
    public required string RequestMessage { get ; set ; }
}

public class MyResponseContract
{
    public required string ResponseMessage { get ; set ; }
}

Отправка запроса и получение ответа

Чтобы отправить запрос и дождаться ответа, используйте RequestResponse<TRequest, TResponse> :

 public class MyService
{
    private readonly IQsMessaging _qsMessaging ;

    public MyService ( IQsMessaging qsMessaging )
    {
        _qsMessaging = qsMessaging ;
    }

    public async Task < MyResponseContract > SendRequestAsync ( MyRequestContract request )
    {
        var response = await _qsMessaging . SendRequestResponseAsync < MyRequestContract , MyResponseContract > ( request ) ;
        return response ;
    }
}

Обработка запросов

Для обработки запросов реализуйте интерфейс IQsRequestResponseHandler<TRequest, TResponse> :

 public class MyRequestHandler : IQsRequestResponseHandler < MyRequestContract , MyResponseContract >
{
    public Task < MyResponseContract > Handle ( MyRequestContract request )
    {
        // Process the request and create a response
        return Task . FromResult ( new MyResponseContract { ResponseMessage = "Response to: " + request . RequestMessage } ) ;
    }
}