Using MassTransit with RabbitMQ and Azure Service Bus

Milan Jovanović - Jan 10 - - Dev Community

MassTransit is an open-source distributed application framework for .NET. It provides a messaging abstraction on top of the supported message transports. MassTransit lets you focus on adding business value instead of worrying about messaging complexity.

MassTransit supports many message transport technologies. Here are a few that are popular:

  • RabbitMQ
  • Azure Service Bus
  • Amazon SQS
  • Kafka

In today's newsletter, I'll show you how to install and configure MassTransit in .NET. We'll connect MassTransit to a few message brokers - RabbitMQ and Azure Service Bus. And we will also cover how to publish and consume messages with MassTransit.

Why Use MassTransit?

MassTransit solves many challenges of building distributed applications. You (almost) don't have to think about the underlying message transport. This allows you to focus on providing business value.

Here are a few things MassTransit does for you:

  • Message routing - Type-based publish/subscribe, automatic broker topology configuration
  • Exception handling - Messages can be retried or moved to an error queue
  • Dependency injection - Service collection configuration and scope service provider
  • Request-Response - Handle requests with automatic response routing
  • Observability - Native Open Telemetry (OTEL) support
  • Scheduling - Schedule message delivery using transport delay, Quartz.NET, or Hangfire
  • Sagas - Reliable, durable, event-driven workflow orchestration

Let's see how to start using MassTransit.

Installing and Configuring MassTransit with RabbitMQ

You need to install the MassTransit library. If you already have a message transport, you can install the respective transport library. Let's add the MassTransit.RabbitMQ library to configure RabbitMQ as the transport mechanism.

Install-Package MassTransit

Install-Package MassTransit.RabbitMQ
Enter fullscreen mode Exit fullscreen mode

Then, you can configure the required services for MassTransit. The AddMassTransit method accepts a delegate where you can configure many settings. For example, you can set the messaging endpoints to use kebab case naming by calling SetKebabCaseEndpointNameFormatter. This is also where you configure the transport mechanism. Calling UsingRabbitMq allows you to connect RabbitMQ as the transport mechanism.

builder.Services.AddMassTransit(busConfigurator =>
{
    busConfigurator.SetKebabCaseEndpointNameFormatter();

    busConfigurator.UsingRabbitMq((context, configurator) =>
    {
        configurator.Host("localhost", "/", h =>
        {
            h.Username("guest");
            h.Password("guest");
        });

        configurator.ConfigureEndpoints(context);
    });
});
Enter fullscreen mode Exit fullscreen mode

MassTransit takes care of setting up the required broker topology. RabbitMQ supports exchanges and queues, so messages are sent or published to exchanges. RabbitMQ routes those messages through exchanges to the appropriate queues.

You can start RabbitMQ locally inside a Docker container:

docker run -d --name rabbitmq -p 5672:5672
Enter fullscreen mode Exit fullscreen mode

Configuring MassTransit with Azure Service Bus

Azure Service Busis a cloud-based message broker with support for queues and topics. MassTransit fully supports Azure Service Bus, including many advanced features and capabilities. However, you must be on the Standard or Premium tier of the Microsoft Azure Service Bus service.

To configure MassTransit to work with Azure Service Bus, you need to install the required transport library:

Install-Package MassTransit.Azure.ServiceBus.Core
Enter fullscreen mode Exit fullscreen mode

Then, you can connect to Azure Service Bus by calling UsingAzureServiceBus and providing the connection string. Everything else remains the same. MassTransit takes care of configuring the broker topology. MassTransit sends messages to topics, and Azure Service Bus routes those messages to the appropriate queues.

builder.Services.AddMassTransit(busConfigurator =>
{
    busConfigurator.SetKebabCaseEndpointNameFormatter();

    busConfigurator.UsingAzureServiceBus((context, configurator) =>
    {
        configurator.Host("<CONNECTION_STRING>");

        configurator.ConfigureEndpoints(context);
    });
});
Enter fullscreen mode Exit fullscreen mode

Using the MassTransit In Memory Transport

You can also configure MassTransit to use an in-memory transport. It's useful for testing, because it doesn't require a message broker to be running. Another advantage is that it's fast.

However, there's a big problem with the in-memory transport - it's not durable.

If the message bus is stopped, all messages are lost. Don't use the in-memory transport for production systems.

It will only work on a single machine. So, it doesn't make sense for distributed applications.

builder.Services.AddMassTransit(busConfigurator =>
{
    busConfigurator.SetKebabCaseEndpointNameFormatter();

    busConfigurator.UsingInMemory((context, configurator) =>
    {
        configurator.ConfigureEndpoints(context);
    });
});
Enter fullscreen mode Exit fullscreen mode

Message Types

MassTransit requires message types to be reference types.So, you can use a class, record or interface to define a message.

You'll often create two types of messages: commands and events.

A command is an instruction to perform some action. Commands are intended to have exactly one consumer. Commands are expressed using verbs first: CreateArticle, PublishArticle, ShareArticle.

An event represents that something of significance happened. Events can have one or many consumers. Events should have a name in the past tense: ArticleCreated, ArticlePublished, ArticleShared.

Here's an example ArticleCreated message containing information about an article:

public record ArticleCreated
{
    public Guid Id { get; init; }
    public string Title { get; init; }
    public string Content { get; init; }
    public DateTime CreatedOnUtc { get; init; }
}
Enter fullscreen mode Exit fullscreen mode

Using public set or public init properties is recommended to avoid serialization problems with System.Text.Json.

Publishing and Consuming Messages

You can use the IPublishEndpoint service to publish messages with MassTransit. The framework routes the message to the appropriate queue or topic based on the message type.

app.MapPost("article", async (
    CreateArticleRequest request,
    IPublishEndpoint publishEndpoint) =>
{
    await publishEndpoint.Publish(new ArticleCreated
    {
        Id = Guid.NewGuid(),
        Title = request.Title,
        Content = request.Content,
        CreatedOnUtc = DateTime.UtcNow
    });

    return Results.Accepted();
});
Enter fullscreen mode Exit fullscreen mode

To consume an ArticleCreated message, you need to implement the IConsumer interface. The IConsumer has one Consume method where you place your business logic. The consumer also gives you access to the ConsumeContext, which you can use to send further messages.

public class ArticleCreatedConsumer(ApplicationDbContext dbContext)
    : IConsumer<ArticleCreatedEvent>
{
    public async Task Consume(ConsumeContext<ArticleCreatedEvent> context)
    {
        ArticleCreated message = context.Message;

        var article = new Article
        {
            Id = message.Id,
            Title = message.Title,
            Content = message.Content,
            CreatedOnUtc = message.CreatedOnUtc
        };

        dbContext.Add(article);

        await dbContext.SaveChangesAsync();
    }
}
Enter fullscreen mode Exit fullscreen mode

MassTransit doesn't automatically know that the ArticleCreatedConsumer exists. You have to configure the consumer when calling AddMassTransit. The AddConsumer method registers the consumer type with the bus.

builder.Services.AddMassTransit(busConfigurator =>
{
    busConfigurator.SetKebabCaseEndpointNameFormatter();

    busConfigurator.AddConsumer<ArticleCreatedConsumer>();

    // ...
});
Enter fullscreen mode Exit fullscreen mode

Next Steps

MassTransit is an excellent messaging library I often use when building distributed applications. The setup is straightforward, and there are only a few important abstractions. You need to know abstraction for publishing messages (IPublishEndpoint) and consuming messages (IConsumer). MassTransit takes care of doing the heavy lifting for you.

If you aren't already using it, I highly recommend adding MassTransit to your toolbox.

Here are some more practical MassTransit learning resources :

That's all for today.

See you next week.

P.S. Whenever you're ready, there are 2 ways I can help you:

  1. Pragmatic Clean Architecture: This comprehensive course will teach you the system I use to ship production-ready applications using Clean Architecture. Learn how to apply the best practices of modern software architecture. Join 1,800+ students here.

  2. Patreon Community: Think like a senior software engineer with access to the source code I use in my YouTube videos and exclusive discounts for my courses. Join 970+ engineers here.

Image
10 Life Lessons We Can Learn From Mental Health Practitioners
Image
Coolchat : révolution du chat en ligne que tout le monde adore !
Image
Add some opuch Up Your Reach: Mastering Car Function Advertising for Maximum Impact
Image
Where Will Causes Of Mesothelioma Other Than Asbestos Be 1 Year From What Is Happening Now?
Image
Addressing The Threat of Deepfakes With Authentic Images

ai, cryptography, security, deepfake
Image
14 Cartoons About Personal Injury Lawyer To Brighten Your Day
Image
15 Shocking Facts About Injury Lawyer You've Never Seen
Image
14 Cartoons About Mesothelioma Asbestos Lawyers That Will Brighten Your Day
Image
CRYPTO ASSET RECOVERY SPECIALIST NEAR ME | CYBER GENIE HACK PRO.

webdev, tutorial, ai, productivity
Image
Do Not Forget Wall Mount For Electric Fireplace: 10 Reasons Why You Don't Have It
Image
ini arti krusial di perjudian slots online
Image
14 Questions You Shouldn't Be Afraid To Ask About Wall Mounted Electric Fireplace Heater
Image
Zainspiruj się: Magia Aranżacji Wnętrz, Która Odmieni Twój Dom!
Image
What NOT To Do When It Comes To The Accident Lawyer Philadelphia Industry
Image
15 Inspiring Facts About Accident Lawyers That You'd Never Been Educated About
Image
My Hacktoberfest 2024 Journey

devchallenge, hacktoberfestchallenge, hacktoberfest, opensource
Image
Trik Daftar Beradu Ayam Sv388 Tiada Modal
Image
5 Reasons To Be An Online Mental Health Practitioners Shop And 5 Reasons Why You Shouldn't
Image
Add some opuch Up Your Get to: Mastering Car Occasion Advertising for Utmost Impact
. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . .