C# 如何使用MediatR库 - 实现CQRS模式中的命令和查询-C#.Net教程-PHP中文网

C# 如何使用MediatR库 - 实现CQRS模式中的命令和查询

畫卷琴夢

发布： 2025-12-14 20:45:25

原创

359人浏览过

CQRS将操作分为命令与查询，MediatR通过中介者模式实现解耦，提升系统可维护性与扩展性，适用于复杂业务场景。

c# 如何使用mediatr库 - 实现cqrs模式中的命令和查询

在现代C#应用程序开发中，CQRS（命令查询职责分离）模式被广泛用于提升系统可维护性和可扩展性。MediatR 是一个轻量级库，帮助我们在项目中轻松实现这一模式。它通过中介者模式将请求与处理逻辑解耦，使代码更清晰、更易于测试。

什么是CQRS？

CQRS 将数据操作分为两类：

命令（Commands）：用于修改状态的操作，比如创建、更新或删除数据。
查询（Queries）：仅用于读取数据，不改变任何状态。

这种分离让我们可以为写操作和读操作设计不同的模型、数据库甚至架构。

安装与配置 MediatR

在使用之前，先通过 NuGet 安装 MediatR 和依赖注入支持包：

dotnet add package MediatR
dotnet add package MediatR.Extensions.Microsoft.DependencyInjection

然后在 Program.cs 或 Startup.cs 中注册服务：

builder.Services.AddMediatR(cfg => cfg.RegisterServicesFromAssembly(typeof(Program).Assembly));

这样，MediatR 就会自动发现并注册所有实现 IRequestHandler 的类。

定义命令与处理程序

以“创建用户”为例，我们定义一个命令类：

public record CreateUserCommand(string Name, string Email) : IRequest;

接着编写对应的处理程序：

public class CreateUserCommandHandler : IRequestHandler
{
private readonly IUserRepository _userRepository;

public CreateUserCommandHandler(IUserRepository userRepository)
{
_userRepository = userRepository;
}

public async Task Handle(CreateUserCommand request, CancellationToken ct)
{
var user = new User(request.Name, request.Email);
await _userRepository.AddAsync(user, ct);
return user.Id;
}
}

这个处理程序接收命令，执行业务逻辑，并返回新用户的 ID。

Pippit AI

CapCut推出的AI创意内容生成工具

133

查看详情

定义查询与处理程序

对于查询，比如“根据ID获取用户信息”，我们这样定义：

public record GetUserByIdQuery(Guid Id) : IRequest;

处理程序从只读数据源中提取数据：

public class GetUserByIdQueryHandler : IRequestHandler
{
private readonly IUserReadRepository _readRepository;

public GetUserByIdQueryHandler(IUserReadRepository readRepository)
{
_readRepository = readRepository;
}

public async Task Handle(GetUserByIdQuery request, CancellationToken ct)
{
var user = await _readRepository.GetByIdAsync(request.Id, ct);
if (user == null) throw new KeyNotFoundException();
return user;
}
}

在控制器中使用 MediatR

在 ASP.NET Core 控制器中注入 ISender 接口来发送请求：

[ApiController]
[Route("api/users")]
public class UsersController : ControllerBase
{
private readonly ISender _sender;

public UsersController(ISender sender)
{
_sender = sender;
}

[HttpPost]
public async Task CreateUser([FromBody] CreateUserCommand command)
{
var userId = await _sender.Send(command);
return CreatedAtAction(nameof(GetUser), new { id = userId }, userId);
}

[HttpGet("{id}")]
public async Task> GetUser(Guid id)
{
var query = new GetUserByIdQuery(id);
var user = await _sender.Send(query);
return Ok(user);
}
}

ISender 是 MediatR 提供的核心接口，可用于发送任意请求类型。