.NET中的CQRS和MediatR模式：构建清晰、可维护的应用架构-C#.Net教程-PHP中文网

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

小老鼠

发布： 2025-12-02 14:05:02

原创

682人浏览过

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

.net中的cqrs和mediatr模式：构建清晰、可维护的应用架构

在现代 .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：

微信源码微趣能Weiqn

产品介绍微趣能 Weiqn 开源免费的微信公共账号接口系统。MVC框架框架结构清晰、易维护、模块化、扩展性好，性能稳定强大核心－梦有多大核心就有多大，轻松应对各种场景！微趣能系统以关键字应答为中心与内容素材库文本如图片语音视频和应用各类信息整体汇集并且与第三方应用完美结合，强大的前后台管理；人性化的界面设计。开放API接口－灵活多动的API，万名开发者召集中。Weiqn 系统开发者AP

查看详情

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);
    }
}

登录后复制

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