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 的基本步骤。
1. 安装 MediatR 包在项目中安装 MediatR 和依赖注入扩展:
dotnet add package MediatR dotnet add package MediatR.Extensions.Microsoft.DependencyInjection
然后在 Program.cs 或 Startup.cs 中注册服务:
采用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 : IRequest3. 定义查询与处理程序{ 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 : IRequest4. 在控制器中使用 MediatR> { } 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 应用结构更清晰,尤其适合中大型项目。虽然小项目可能显得“过度设计”,但在需要良好分层和可维护性的场景下,它非常实用。关键是合理划分命令与查询,避免滥用。









