.NET中的MediatR库是什么？如何用它实现CQRS模式？-C#.Net教程-PHP中文网

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

畫卷琴夢

发布： 2025-11-27 19:24:06

原创

105人浏览过

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

.net中的mediatr库是什么？如何用它实现cqrs模式？

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 中注册服务：

Android配合WebService访问远程数据库中文WORD版

采用HttpClient向服务器端action请求数据，当然调用服务器端方法获取数据并不止这一种。WebService也可以为我们提供所需数据，那么什么是webService呢？，它是一种基于SAOP协议的远程调用标准，通过webservice可以将不同操作系统平台，不同语言，不同技术整合到一起。实现Android与服务器端数据交互，我们在PC机器java客户端中，需要一些库，比如XFire,Axis2,CXF等等来支持访问WebService，但是这些库并不适合我们资源有限的android手机客户端，

查看详情

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

登录后复制