The .NET ecosystem has witnessed a significant shift in recent years, with MediatR becoming almost synonymous with Clean Architecture implementations. This library, designed to implement the mediator pattern, has found its way into countless tutorials, templates, and starter kits, making it seem like an essential component of modern .NET Core applications.
The appeal is understandable - MediatR provides an elegant solution for implementing the mediator pattern, facilitating communication between different layers of an application without direct dependencies.
While MediatR offers powerful features for handling cross-cutting concerns, it shouldn't be treated as a default inclusion in every .NET Core project. Instead, its implementation should be carefully considered based on specific use cases and requirements.
This article demonstrates how to maintain the benefits of a use-case-centric architecture without relying on MediatR's internal messaging system, offering a more streamlined approach that preserves architectural clarity without unnecessary complexity.
Use case with/without MediatR
Before getting started, to achieve the same result as MediatR, it's essential to create the interfaces for commands and handlers to obtain an equivalent structure.
public interface ICommand<T>;
public interface IHandler<in TQuery, TResult> where TQuery : ICommand<TResult>
{
Task<TResult> Handle(TQuery query);
}
The declaration of commands and responses is exactly the same, with the use of ICommand
created above.
public record AddGoatWithMediatRCommand(string Name, string Description) : IRequest<AddGoatResponse>;
public record AddGoatWithMediatRResponse(Guid GoatId);
// vs without MediatR
public record AddGoatCommand(string Name, string Description) : ICommand<AddGoatResponse>;
public record AddGoatResponse(Guid GoatId);
At the handler level, it's much the same. The handler declares an input type (the command) and an output type (the response), with a Handle
method to handle processing related to the command.
One notable difference is the use of a CancellationToken
, which can easily be added to the IHandler
interface declaration.
internal class AddGoatWithMediatRHandler : IRequestHandler<AddGoatWithMediatRCommand, AddGoatResponse>
{
public Task<AddGoatResponse> Handle(AddGoatWithMediatRCommand request, CancellationToken cancellationToken)
{
return Task.FromResult(new AddGoatResponse(Guid.NewGuid()));
}
}
// vs without MediatR
public interface IAddGoatHandler : IHandler<AddGoatCommand, AddGoatResponse>;
internal class AddGoatHandler : IAddGoatHandler
{
public Task<AddGoatResponse> Handle(AddGoatCommand query)
{
return Task.FromResult(new AddGoatResponse(Guid.NewGuid()));
}
}
The API display is exactly the same for both solutions, with the order sent to the internal messaging system and MediatR, and the handler injected directly to manage the order.
app.MapPost("/goat/with-mediatr", async (
[FromServices] ISender mediator,
GoatToCreate input)
=>
{
var command = new AddGoatWithMediatRCommand(input.Name, input.Description);
return await mediator.Send(command);
});
// vs without MediatR
app.MapPost("/goat", async (
[FromServices] IAddGoatHandler handler,
GoatToCreate input)
=>
{
var command = new AddGoatCommand(input.Name, input.Description);
return await handler.Handle(command);
});
As far as injection is concerned, MediatR is certainly simpler to use as it stands, since service registration is carried out via the assembly.
builder.Services.AddMediatR(cfg => cfg.RegisterServicesFromAssemblies(typeof(Program).Assembly));
// vs without MediatR
builder.Services.AddScoped<IAddGoatHandler, AddGoatHandler>();
But there's nothing to stop you building an extension method similar to RegisterServicesFromAssemblies
to do the same thing.
We end up with 2 almost identical solutions for cutting up an application by use-case, with a folder containing the command, the response and the handler.
The advantage of using this solution is that you can easily switch to MediatR if you need to, by changing only the command and handler interfaces, as well as changing all the declarations in the endpoints (which is quite minimal).
public interface IHandler<in TQuery, TResult> : IRequestHandler<TQuery, TResult> where TQuery : IRequest<TResult>
public interface ICommand<T> : IRequest<T>;
What's wrong with the systematic use of MediatR?
Using the MediatR pattern is not a bad thing, since it creates a decoupling between the exposure and the handler when the command is received.
It becomes dangerous when you also start using it to trigger other commands within a handler to access another context.
And to back it all up, we're going to take a simple example: when I add my goat, I want to add an audit trail to track all the changes.
The first question to ask is: in order for the addition to be validated, must the audit trail also have been performed? In other words, is there an atomic relationship between these two operations?
By atomic, we don't mean database transactions, but rather processing atomicity. Processing can be done synchronously or not, but it must be done in its entirety or not at all. Here, does the creation of an audit condition the creation of a goat?
If the answer is no, then you're right to create decoupling here, since the two operations are independent of each other. At the end of goat creation, all you need to do is Publish
(and not Send
) to start recording in another context. This is event-driven architecture in its own right.
If the answer is yes, then you'll be creating decoupling between two operations that are correlated, and this is where the complexity comes in.
The event-sharing problem in an atomic context
Before getting started, it's important to clarify the difference between the notion of event and command:
- An event is a notification which may have several handlers and which does not return any results
- A command is a request that has a single handler and returns a result (void being a result).
Why this clarification? Because we're not here to criticize the notion of events produced in a handler, but rather the use of these events to generate commands.
To return to our example, it seems intuitive to start from the following premise:
- Goat management is in a context
- The goat context produces a created goat event
- The audit trail subscribes to an command related to this event for processing
The slightly more complete handler performs the following steps:
public Task<AddGoatResponse> Handle(AddGoatWithMediatRCommand request, CancellationToken cancellationToken)
{
// We create the goat : var goatCreated = new GoatCreated....
// We save it in the database : Repository.Save(goatCreated)
return Task.FromResult(new AddGoatResponse(Guid.NewGuid()));
}
To wire up the audit trail system, we could imagine several systems:
- Send an event after the
Handle
has been processed, using aPipelineBehavior
in order to raise a command - Send a command while the
Handle
is being processed.
The 1st case is technically the βcleanestβ, since it doesn't use the handler's message sending mechanism, delegating it to the pipeline. To do this, we use the events generated in the handler to send commands to other contexts. This solution seems very clean.
Let's imagine the following case: I now want to check that I have access to the credits needed to create a goat.
With case 1, you'll have to create a new subscriber in the credit context to be able to validate that you have enough credits to add a goat.
In terms of performance, this is a disaster: you've run through the entire creation process (search in database, save in database) only to realize that you don't have enough credits because the command to retrieve the number of credits is only triggered once the handler has finished.
You can then fall back on case 2.
public Task<AddGoatResponse> Handle(AddGoatWithMediatRCommand request, CancellationToken cancellationToken)
{
// We create the goat : var goatCreated = new GoatCreated....
// We asked here for the credits : var credits = await mediator.Send(new GetCreditsCommand());
// We save it in the database : Repository.Save(goatCreated)
return Task.FromResult(new AddGoatResponse(Guid.NewGuid()));
}
We end up using an internal messaging call in a handler to call another context.
Can you see the problem?
We end up injecting into a handler an abstraction mechanism between two services that are dependent on each other by using internal messaging. What a mess...
Creating an event-driven application is not for novices. It's a complex infrastructure, with lots of side effects, complex debugging etc... Don't get into it unless you really need it, which will not be the case in 99% of your cases.
Do not over-engineering solutions
A simple solution is to limit the sending of these messages by using service adapters, which enable communication from one service to another.
Let's go back to the example we used at the beginning to implement use-cases without MediatR.
public Task<AddGoatResponse> Handle(AddGoatWithMediatRCommand request, CancellationToken cancellationToken)
{
// We create the goat : var goatCreated = new GoatCreated....
// We asked here for the credits : var credits = creditsService.GetCredits();
// We save it in the database : Repository.Save(goatCreated)
return Task.FromResult(new AddGoatResponse(Guid.NewGuid()));
}
The credit context has an interface for exposing its methods to other contexts, creating a dependency. But in reality, it's just an exposure, which we could, if need be, transform into an API call to a microservice or similar.
The key here is to maintain an atomic relationship between separate contexts.
Conclusion
I haven't mentioned here the advantages of using a library like MediatR, specifically to show the complexities of using it without realizing its impact.
The example taken here is MediatR, and it could be applied to all the libraries we're used to using: EFCore, FluentValidation...
Always ask yourself: Am I making this technical choice because it makes me tick as a developer, or because I really need it?
In this case, I was able to completely remove MediatR from my application and return to simple, easy-to-understand development with no external dependencies.
You can find all the code here:
Have a goat day π
Join the conversation.