.NET中的CQRS和MediatR模式：构建清晰、可维护的应用架构

来源：这里教程网时间：2026-02-21 17:32:22 作者：

在现代 .NET 应用开发中，随着业务逻辑日益复杂，如何保持代码的清晰性和可维护性成为关键挑战。CQRS（Command Query Responsibility Segregation）与 MediatR 模式结合使用，提供了一种解耦请求处理流程、提升系统可读性与扩展性的有效方案。这种架构方式将“读取数据”和“修改数据”的操作彻底分离，配合中介者模式实现关注点分离。

什么是 CQRS？

CQRS 的核心思想是将应用程序的读操作（Queries）与写操作（Commands）分开处理：

Commands（命令）：用于修改状态的操作，例如创建订单、更新用户信息。这类操作应返回 void 或结果状态，不应直接返回数据。 Queries（查询）：仅用于获取数据，不产生副作用，例如列出所有用户、查找某个订单详情。

通过这种分离，可以为读写两端设计不同的模型、数据库甚至技术栈。比如写模型使用事务性强的关系库，读模型使用优化过的视图或 NoSQL 存储。

MediatR 如何协助实现 CQRS？

MediatR 是一个轻量级的 .NET 库，实现了中介者（Mediator）模式，允许你以松耦合的方式发送和处理请求。它非常适合配合 CQRS 使用：

每个 Command 或 Query 被定义为一个独立的消息对象。 对应的 Handler 负责处理该消息，实现具体逻辑。 控制器或其他入口只需依赖 IMediator 接口调用 Send 或 SendAsync，无需知道内部如何处理。

这种方式显著降低了模块间的依赖，提升了测试性和可维护性。

实际应用示例

以下是一个简单的用户注册场景实现：

定义 Command：

public class CreateUserCommand : IRequest<Guid>
{
    public string Name { get; set; }
    public string Email { get; set; }
}
public class CreateUserCommandHandler : IRequestHandler<CreateUserCommand, Guid>
{
    private readonly AppDbContext _context;
    public CreateUserCommandHandler(AppDbContext context)
    {
        _context = context;
    }
    public async Task<Guid> Handle(CreateUserCommand request, CancellationToken ct)
    {
        var user = new User(request.Name, request.Email);
        await _context.Users.AddAsync(user, ct);
        await _context.SaveChangesAsync(ct);
        return user.Id;
    }
}

定义 Query：

public class GetUserByIdQuery : IRequest<UserDto>
{
    public Guid Id { get; set; }
}
public class GetUserByIdQueryHandler : IRequestHandler<GetUserByIdQuery, UserDto>
{
    private readonly AppDbContext _context;
    public GetUserByIdQueryHandler(AppDbContext context)
    {
        _context = context;
    }
    public async Task<UserDto> Handle(GetUserByIdQuery request, CancellationToken ct)
    {
        return await _context.Users
            .Where(u => u.Id == request.Id)
            .Select(u => new UserDto(u.Id, u.Name, u.Email))
            .FirstOrDefaultAsync(ct);
    }
}

在控制器中使用：

[ApiController]
[Route("[controller]")]
public class UsersController : ControllerBase
{
    private readonly IMediator _mediator;
    public UsersController(IMediator mediator)
    {
        _mediator = mediator;
    }
    [HttpPost]
    public async Task<ActionResult<Guid>> Create([FromBody] CreateUserCommand command)
    {
        var id = await _mediator.Send(command);
        return CreatedAtAction(nameof(Get), new { id }, id);
    }
    [HttpGet("{id:guid}")]
    public async Task<ActionResult<UserDto>> Get(Guid id)
    {
        var query = new GetUserByIdQuery { Id = id };
        var user = await _mediator.Send(query);
        if (user == null) return NotFound();
        return Ok(user);
    }
}

整个流程清晰明了，职责分明，新增功能只需添加新的消息和处理器，不影响现有代码。