17370845950

CQRS 是一种将写操作与读操作分离的架构模式，通过 MediatR 在 .NET 中实现时，命令负责修改数据并返回状态，查询负责读取数据而不改变状态；安装 MediatR 包后，在程序中注册服务，定义继承 IRequest 的命令和查询类，并编写对应处理程序实现 IRequestHandler；控制器通过 IMediator 发送请求，实现逻辑解耦、职责分明、易于测试与扩展的代码结构，适用于中大型项目以提升可维护性与性能。

MediatR 是 .NET 中一个轻量级的库，用于实现“中介者模式”（Mediator Pattern），它能有效解耦应用程序中的发送方和处理方。通过 MediatR，你可以将请求（如命令、查询）与它们的处理逻辑分离，使代码更清晰、可维护性更高。它特别适合用来实现 CQRS 模式（Command Query Responsibility Segregation，命令查询职责分离）。

什么是 CQRS？

CQRS 是一种架构模式，核心思想是将写操作（命令）和读操作（查询）分离：

• 命令（Commands）：负责修改数据状态，不返回结果或只返回操作状态。

• 查询（Queries）：负责读取数据，不改变系统状态。

这种分离使得你可以为读写操作设计不同的模型、数据库甚至架构，提升性能与可维护性。

如何使用 MediatR 实现 CQRS？

以下是使用 MediatR 在 .NET 中实现 CQRS 的基本步骤。

在项目中安装 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));

命令用于修改数据。例如，创建一个添加用户命令：

public class CreateUserCommand : IRequest
{
    public string Name { get; set; }
    public string Email { get; set; }
}

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 { Id = Guid.NewGuid(), Name = request.Name, Email = request.Email };
        await _userRepository.AddAsync(user);
        return user.Id;
    }
}

查询用于获取数据。例如，获取用户列表：

public class GetUsersQuery : IRequest> { }

public class GetUsersQueryHandler : IRequestHandler>
{
    private readonly IUserRepository _userRepository;

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

    public async Task> Handle(GetUsersQuery request, CancellationToken ct)
    {
        var users = await _userRepository.GetAllAsync(ct);
        return users.Select(u => new UserDto(u.Id, u.Name, u.Email)).ToList();
    }
}

通过依赖注入获取 IMediator，并发送命令或查询：

[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 userId = await _mediator.Send(command);
        return CreatedAtAction(nameof(Get), new { id = userId }, userId);
    }

    [HttpGet]
    public async Task Get()
    {
        var users = await _mediator.Send(new GetUsersQuery());
        return Ok(users);
    }
}

使用 MediatR 实现 CQRS 的优势

• 职责清晰：命令只负责写，查询只负责读，逻辑分离明确。
• 易于测试：每个处理程序独立，便于单元测试。
• 扩展性强：可通过行为管道（如日志、验证）增强处理流程。
• 解耦：控制器不需要知道具体业务细节，只需发送请求。

基本上就这些。MediatR 配合 CQRS 能让 .NET 应用结构更清晰，尤其适合中大型项目。虽然小项目可能显得“过度设计”，但在需要良好分层和可维护性的场景下，它非常实用。关键是合理划分命令与查询，避免滥用。