Библиотека шарписта | C#, F#,… on Telegram: “🛠 Асинхронное взаимодействие микросервисов в .N…”

🛠 Асинхронное взаимодействие микросервисов в .NET

Одним из самых популярных брокеров сообщений является 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;
    }
}

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

📎 Подробный гайд в источнике

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