.NET中的MediatR库是什么？如何用它实现CQRS模式？

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

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

什么是 CQRS？

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

命令（Commands）：负责修改数据状态，不返回结果或只返回操作状态。 查询（Queries）：负责读取数据，不改变系统状态。

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

如何使用 MediatR 实现 CQRS？

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

1. 安装 MediatR 包

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

2. 定义命令与处理程序

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

public class CreateUserCommand : IRequest<Guid>
{
    public string Name { get; set; }
    public string Email { get; set; }
}
public class CreateUserCommandHandler : IRequestHandler<CreateUserCommand, Guid>
{
    private readonly IUserRepository _userRepository;
    public CreateUserCommandHandler(IUserRepository userRepository)
    {
        _userRepository = userRepository;
    }
    public async Task<Guid> 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;
    }
}

3. 定义查询与处理程序

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

public class GetUsersQuery : IRequest<List<UserDto>> { }
public class GetUsersQueryHandler : IRequestHandler<GetUsersQuery, List<UserDto>>
{
    private readonly IUserRepository _userRepository;
    public GetUsersQueryHandler(IUserRepository userRepository)
    {
        _userRepository = userRepository;
    }
    public async Task<List<UserDto>> Handle(GetUsersQuery request, CancellationToken ct)
    {
        var users = await _userRepository.GetAllAsync(ct);
        return users.Select(u => new UserDto(u.Id, u.Name, u.Email)).ToList();
    }
}

4. 在控制器中使用 MediatR

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

[ApiController]
[Route("[controller]")]
public class UsersController : ControllerBase
{
    private readonly IMediator _mediator;
    public UsersController(IMediator mediator)
    {
        _mediator = mediator;
    }
    [HttpPost]
    public async Task<IActionResult> Create([FromBody] CreateUserCommand command)
    {
        var userId = await _mediator.Send(command);
        return CreatedAtAction(nameof(Get), new { id = userId }, userId);
    }
    [HttpGet]
    public async Task<IActionResult> Get()
    {
        var users = await _mediator.Send(new GetUsersQuery());
        return Ok(users);
    }
}