17370845950

CQRS 将读写操作分离，Commands 负责修改状态，Queries 仅获取数据，结合 MediatR 实现松耦合消息处理，通过定义独立的 Command/Query 消息与 Handler，控制器依赖 IMediator 发送请求，提升代码可维护性与扩展性，适用于业务复杂的中大型项目。

在现代 .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
{
    public string Name { get; set; }
    public string Email { get; set; }
}

public class CreateUserCommandHandler : IRequestHandler
{
    private readonly AppDbContext _context;

    public CreateUserCommandHandler(AppDbContext context)
    {
        _context = context;
    }

    public async Task 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
{
    public Guid Id { get; set; }
}

public class GetUserByIdQueryHandler : IRequestHandler
{
    private readonly AppDbContext _context;

    public GetUserByIdQueryHandler(AppDbContext context)
    {
        _context = context;
    }

    public async Task 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> Create([FromBody] CreateUserCommand command)
    {
        var id = await _mediator.Send(command);
        return CreatedAtAction(nameof(Get), new { id }, id);
    }

    [HttpGet("{id:guid}")]
    public async Task> Get(Guid id)
    {
        var query = new GetUserByIdQuery { Id = id };
        var user = await _mediator.Send(query);
        if (user == null) return NotFound();
        return Ok(user);
    }
}

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

优势与适用场景

采用 CQRS + MediatR 架构的主要好处包括：

• 逻辑分层清晰，易于理解与维护。
• 便于实施横切关注点（如日志、验证、事务），可通过行为管道（Pipeline Behaviors）统一处理。
• 支持未来演进，比如引入事件溯源、缓存读模型、分布式处理等。

适合中大型项目或预期会持续增长的系统。对于简单 CRUD 应用，可能引入额外复杂度，需权衡使用。

基本上就这些。合理运用 CQRS 与 MediatR，能让 .NET 项目的结构更整洁，团队协作更顺畅。