Reo.Core.Queue.MassTransit.Abstractions 10.0.210

Reo.Core.Queue.MassTransit.Abstractions

Описание пакета

Reo.Core.Queue.MassTransit.Abstractions — это библиотека для работы с сообщениями и очередями через MassTransit и * RabbitMQ*. Пакет предоставляет абстракции для создания и настройки конечных точек, отправки сообщений, а также интеграции с системами мониторинга через проверки здоровья (health checks).

Основные функции:

• Упрощённая настройка отправки сообщений в RabbitMQ с использованием MassTransit.
• Поддержка создания конечных точек для очередей и обработки событий.
• Интеграция с проверками здоровья (health checks) для мониторинга состояния RabbitMQ-кластера.
• Гибкая конфигурация через DI-контейнер (например, в ASP.NET Core).

Основные компоненты

1. EndpointBuilder

• Назначение: Создание адресов конечных точек для очередей RabbitMQ.
• Описание: Позволяет программно настраивать параметры очередей (например, имя, тип, атрибуты) и генерировать URI для использования в MassTransit.

2. SendEndpointProviderExtensions

• Назначение: Расширение функционала ISendEndpointProvider для отправки сообщений в конкретные очереди.
• Описание: Методы для асинхронного получения ISendEndpoint по имени очереди, упрощающие работу с отправкой сообщений.

3. RabbitMqHealthChecksBuilderExtensions

• Назначение: Интеграция с системами мониторинга через проверки здоровья (health checks).
• Описание: Добавляет проверку работоспособности RabbitMQ-кластера, используя настройки из RabbitMqClusterOptions.

4. RabbitMqClusterOptions

• Назначение: Конфигурационный класс для настройки подключения к RabbitMQ.
• Описание: Содержит параметры подключения (хосты, порты, логины, пароли) и настройки проверок здоровья.

Требования

Версии .NET

• .NET 8.0 и выше (тестирование на .NET 8.0 и .NET 9.0).

Зависимости

• MassTransit (для работы с сообщениями и очередями).
• RabbitMQ.Client (для взаимодействия с RabbitMQ).
• Microsoft.Extensions.Diagnostics.HealthChecks (для проверок здоровья).

Установка

NuGet Package Manager

Install-Package Reo.Core.Queue.MassTransit.Abstractions

.NET CLI

dotnet add package Reo.Core.Queue.MassTransit.Abstractions

Настройка

Регистрация в DI-контейнере (ASP.NET Core)

services.AddReoIntegrationServices<YourAssembly>();

Пример конфигурации в appsettings.json

{
 "RabbitMqClusterOptions": {
 "Hosts": ["rabbitmq-host:5672"],
 "Username": "guest",
 "Password": "guest"
 }
}

Регистрация проверок здоровья

services.TryAddRabbitMqCluster(new RabbitMqClusterOptions
{
 Hosts = new[] { "rabbitmq-host:5672" },
 Username = "guest",
 Password = "guest"
});

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

Пример 1: Отправка сообщения в очередь

public class MyService
{
 private readonly ISendEndpointProvider _sendEndpointProvider;

 public MyService(ISendEndpointProvider sendEndpointProvider)
 {
 _sendEndpointProvider = sendEndpointProvider;
 }

 public async Task SendToQueueAsync(string message)
 {
 var endpoint = await _sendEndpointProvider.GetQueueSendEndpointAsync("my-queue", CancellationToken.None);
 await endpoint.Send(new MyMessage { Content = message });
 }
}

Пример 2: Проверка работоспособности RabbitMQ

// В Startup.cs или Program.cs (ASP.NET Core)
services.AddHealthChecks()
 .TryAddRabbitMqCluster(new RabbitMqClusterOptions
 {
 Hosts = new[] { "rabbitmq-host:5672" },
 Username = "guest",
 Password = "guest"
 });

Лицензия

Данный пакет распространяется под лицензией MIT.