Библиотека шарписта | C#, F#, .NET, ASP.NET: “🛠 RabbitMQ плюс MassTransit Мы уже давали мини гайд по RabbitMQ и Mas…”

🛠 RabbitMQ плюс MassTransit

Мы уже давали мини гайд по RabbitMQ и MassTransit, и сейчас повторяем его как шпаргалку. Это один из самых прямых способов завести асинхронное общение сервисов в .NET без ручной возни с протоколом и очередями.

Какие инструменты нужны

• RabbitMQ. Брокер сообщений, который позволяет сервисам отправлять и получать сообщения асинхронно, используя очереди.

• MassTransit. Библиотека для .NET, которая предоставляет простой и удобный API для работы с брокерами сообщений.

Как использовать их вместе

1️⃣ Устанавливаем RabbitMQ

RabbitMQ можно развернуть в Docker:

docker run -d --hostname my-rabbit --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:management

2️⃣ Настраиваем MassTransit

Необходимо зарегистрировать MassTransit и подключить его к RabbitMQ:

builder.Services.AddMassTransit(x =>
{
    x.UsingRabbitMq((context, cfg) =>
    {
        cfg.Host("localhost", "/", h => 
        {
            h.Username("guest");
            h.Password("guest");
        });
    });
});

Этот код создает подключение к RabbitMQ, которое позволяет сервису отправлять и получать сообщения.

3️⃣ Создаем производителя

Производитель отправляет сообщения в очередь, используя MassTransit:

public async Task SendMessage(IBus bus, string message)
{
    var endpoint = await bus.GetSendEndpoint(new Uri("queue:order-queue"));
    await endpoint.Send(new OrderCreated { OrderId = Guid.NewGuid(), Message = message });
}

4️⃣ Создаем потребителя

Потребитель автоматически получает и обрабатывает сообщения из очереди:

public class OrderConsumer : IConsumer<OrderCreated>
{
    public Task Consume(ConsumeContext<OrderCreated> context)
    {
        Console.WriteLine($"Получено сообщение: {context.Message.Message}");
        return Task.CompletedTask;
    }
}

💾 Сохраняйте мини-гайд себе, чтобы не потерять

📍 Навигация: Вакансии • Задачи • Собесы

🐸Библиотека шарписта

#лучшее_из_библиотеки_2025