Reo.Core.Queue.MassTransit.Models 10.0.210

Reo.Core.Queue.MassTransit.Models

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

Reo.Core.Queue.MassTransit.Models — это библиотека, предназначенная для интеграции с системами сообщений на основе MassTransit, используемой в распределённых системах и микросервисах. Пакет предоставляет модели, события и инфраструктурные классы для обработки асинхронных операций, управления связями объектов инфраструктуры и взаимодействия с внешними сервисами. Он решает задачи, связанные с обработкой событий, координацией между компонентами и обеспечением надёжной передачи данных между сервисами.

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

1. InfrastructureObjectReferenceBase

Абстрактный базовый класс для событий, связанных с объектами инфраструктуры. Определяет тип ссылки ( ExternalReferenceType) и базовую логику обработки событий.

2. AsyncInfrastructureObjectReferenceEvent

Модель для асинхронных событий, связанных с объектами инфраструктуры. Используется для передачи данных между сервисами.

3. VehicleAllTrackComparisonCompleted

Событие, сигнализирующее о завершении сравнения траекторий транспортных средств. Пример использования: обработка завершения операции в системе мониторинга транспорта.

4. InfrastructureObjectReference

Модель для хранения ссылок на объекты инфраструктуры, например, на внешние сервисы или ресурсы.

5. QueueConstants

Классы с константами для имен очередей и сообщений (например, VehicleTrackComparisonCompletedQueue), используемые для настройки интеграции с MassTransit.

Требования

• .NET версии: .NET 8.0, .NET 9.0.
• Зависимости:
  • MassTransit
  • Reo.Core.BaseDomainModels

Установка

NuGet Package Manager

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

.NET CLI

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

Настройка

Регистрация в ASP.NET Core

Добавьте сервисы в DI-контейнер в Program.cs или Startup.cs:

var builder = WebApplication.CreateBuilder(args);

// Регистрация MassTransit и связанных моделей
builder.Services.AddMassTransit(x =>
{
 x.AddConsumersFromNamespaceContaining<InfrastructureObjectReferenceBase>();
 x.UsingRabbitMq((context, cfg) =>
 {
 cfg.Host("localhost", h => h.UseDefaultHost());
 cfg.ConfigureEndpoints(context);
 });
});

var app = builder.Build();
app.Run();

Конфигурационные параметры

Настройка MassTransit осуществляется через стандартные параметры, например, в appsettings.json:

{
 "MassTransit": {
 "Host": "rabbitmq://localhost"
 }
}

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

Пример 1: Обработка события VehicleAllTrackComparisonCompleted

public class VehicleTrackComparisonConsumer : IConsumer<VehicleAllTrackComparisonCompleted>
{
 public Task Consume(ConsumeContext<VehicleAllTrackComparisonCompleted> context)
 {
 var eventPayload = context.Message;
 Console.WriteLine($"Сравнение траекторий завершено для события: {eventPayload.EventId}");
 return Task.CompletedTask;
 }
}

Пример 2: Создание события для связи объектов инфраструктуры

var referenceEvent = new AsyncInfrastructureObjectReferenceEvent
{
 Type = ExternalReferenceType.Vehicle,
 ObjectId = "vehicle-123",
 ExternalId = "external-vehicle-456"
};

// Отправка события через MassTransit
await _bus.Publish(referenceEvent);

Лицензия

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