C#如何实现CQRS模式 MediatR库入门与实践指南

来源:这里教程网 时间:2026-02-21 17:34:26 作者:

在C#中实现CQRS模式,MediatR是最轻量、最主流的选择之一。它不强制你写一堆接口和基类,而是用“请求-响应”模型自然地把命令(Command)和查询(Query)分开,让业务逻辑更清晰、可测试性更强、扩展更灵活。

一、理解CQRS与MediatR的核心分工

CQRS(Command Query Responsibility Segregation)本质是把“改数据”和“读数据”彻底拆开:命令负责修改状态(如创建订单、更新用户),查询只负责返回数据(如获取用户列表、查订单详情)。MediatR不是CQRS框架,而是一个进程内消息总线——它帮你把请求(IRequest)发给唯一对应的处理器(IRequestHandler),自动完成路由、依赖注入和生命周期管理。

关键点:

一个请求类型(比如
CreateUserCommand
)只能有一个处理器;
查询和命令都用
IRequest<tresponse></tresponse>
统一建模,是否修改数据库由你决定;
MediatR本身不处理事务、缓存或事件发布,这些需你自行组合(比如配合Entity Framework Core + IUnitOfWork + IDomainEvent)。

二、快速上手:三步接入MediatR

以.NET 6+项目为例(控制台或Web API均可):

1. 安装包

通过NuGet安装:

MediatR
(核心库)
MediatR.Extensions.Microsoft.DependencyInjection
(集成ASP.NET Core DI)

2. 注册服务

Program.cs
中添加:

builder.Services.AddMediatR(cfg => cfg.RegisterServicesFromAssembly(typeof(Program).Assembly));

这会自动扫描当前程序集下所有实现了

IRequestHandler
INotificationHandler
的类并注册。

3. 写一个查询示例

定义查询请求:

public record GetUserByIdQuery(int Id) : IRequest<UserDto>;

定义处理器:

public class GetUserByIdQueryHandler : IRequestHandler<GetUserByIdQuery, UserDto>
{
    private readonly IUserRepository _repo;
    public GetUserByIdQueryHandler(IUserRepository repo) => _repo = repo;
    public async Task<UserDto> Handle(GetUserByIdQuery request, CancellationToken ct)
        => await _repo.GetByIdAsync(request.Id, ct);
}

在Controller中使用:

[HttpGet("{id}")]
public async Task<ActionResult<UserDto>> Get(int id)
    => Ok(await _mediator.Send(new GetUserByIdQuery(id)));

三、命令与验证的最佳实践

命令通常伴随业务规则校验。推荐组合FluentValidation:

为每个命令定义对应Validator(如
CreateUserCommandValidator : AbstractValidator<createusercommand></createusercommand>
);
安装
MediatR.Extensions.FluentValidation.AspNetCore
,自动启用验证管道行为;
验证失败时直接返回
ValidationException
,可在全局Filter中统一转为400响应。

命令执行后若需通知其他模块(如发邮件、更新搜索索引),不要在Handler里硬编码调用。改用

INotification
+
INotificationHandler
解耦:

await _mediator.Publish(new UserCreatedNotification(user), ct);

多个Handler可同时监听该事件,互不影响。

四、常见陷阱与应对建议

别把MediatR当Service Locator用:避免在Handler里通过

IMediator
再发另一个请求——这容易导致隐式调用链、事务边界混乱、难以调试。需要组合逻辑?提取成领域服务,由Handler协调。

事务控制要明确:MediatR不管理事务。命令Handler中若涉及EF Core操作,应在最外层(如中间件或基类Handler)开启

DbContextTransaction
,或用
IUnitOfWork
封装。

查询不要偷偷改状态:虽然技术上可以,但违背CQRS语义。如果某个“查询”必须触发副作用(如记录访问日志),应显式命名为

TrackUserViewQuery
,并在文档/命名中体现其非纯查询性质。

异步要到底:所有Handler方法必须标记

async Task<t></t>
,不要用
.Result
.Wait()
阻塞——尤其在Web环境下会导致线程饥饿。

基本上就这些。MediatR本身很薄,真正考验的是你对领域边界的划分能力。用好它,不是为了炫技,而是让每个类只做一件事:接收请求、专注逻辑、返回结果。

相关推荐