0

0

C# 如何使用MediatR库 - 实现CQRS模式中的命令和查询

畫卷琴夢

畫卷琴夢

发布时间:2025-12-14 20:45:25

|

359人浏览过

|

来源于php中文网

原创

CQRS将操作分为命令与查询,MediatR通过中介者模式实现解耦,提升系统可维护性与扩展性,适用于复杂业务场景。

c# 如何使用mediatr库 - 实现cqrs模式中的命令和查询

在现代C#应用程序开发中,CQRS(命令查询职责分离)模式被广泛用于提升系统可维护性和可扩展性。MediatR 是一个轻量级库,帮助我们在项目中轻松实现这一模式。它通过中介者模式将请求与处理逻辑解耦,使代码更清晰、更易于测试。

什么是CQRS?

CQRS 将数据操作分为两类:

  • 命令(Commands):用于修改状态的操作,比如创建、更新或删除数据。
  • 查询(Queries):仅用于读取数据,不改变任何状态。
这种分离让我们可以为写操作和读操作设计不同的模型、数据库甚至架构。

安装与配置 MediatR

在使用之前,先通过 NuGet 安装 MediatR 和依赖注入支持包:

dotnet add package MediatR
dotnet add package MediatR.Extensions.Microsoft.DependencyInjection

然后在 Program.csStartup.cs 中注册服务:

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

这样,MediatR 就会自动发现并注册所有实现 IRequestHandler 的类。

定义命令与处理程序

以“创建用户”为例,我们定义一个命令类:

public record CreateUserCommand(string Name, string Email) : IRequest;

接着编写对应的处理程序:

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

这个处理程序接收命令,执行业务逻辑,并返回新用户的 ID。

Mureka
Mureka

Mureka是昆仑万维最新推出的一款AI音乐创作工具,输入歌词即可生成完整专属歌曲。

下载

定义查询与处理程序

对于查询,比如“根据ID获取用户信息”,我们这样定义:

public record GetUserByIdQuery(Guid Id) : IRequest;

处理程序从只读数据源中提取数据:

public class GetUserByIdQueryHandler : IRequestHandler
{
private readonly IUserReadRepository _readRepository;

public GetUserByIdQueryHandler(IUserReadRepository readRepository)
{
_readRepository = readRepository;
}

public async Task Handle(GetUserByIdQuery request, CancellationToken ct)
{
var user = await _readRepository.GetByIdAsync(request.Id, ct);
if (user == null) throw new KeyNotFoundException();
return user;
}
}

在控制器中使用 MediatR

在 ASP.NET Core 控制器中注入 ISender 接口来发送请求:

[ApiController]
[Route("api/users")]
public class UsersController : ControllerBase
{
private readonly ISender _sender;

public UsersController(ISender sender)
{
_sender = sender;
}

[HttpPost]
public async Task CreateUser([FromBody] CreateUserCommand command)
{
var userId = await _sender.Send(command);
return CreatedAtAction(nameof(GetUser), new { id = userId }, userId);
}

[HttpGet("{id}")]
public async Task> GetUser(Guid id)
{
var query = new GetUserByIdQuery(id);
var user = await _sender.Send(query);
return Ok(user);
}
}

ISender 是 MediatR 提供的核心接口,可用于发送任意请求类型。

优点与适用场景

使用 MediatR 实现 CQRS 带来的好处包括:

  • 职责清晰:每个类只做一件事。
  • 便于添加横切关注点:如日志、验证、事务控制等,可通过行为(Behaviors)统一处理。
  • 可测试性强:处理程序容易单元测试。
  • 适合复杂业务系统:尤其在读写频率差异大或性能要求高的场景下表现优异。

基本上就这些。掌握 MediatR 的基本用法后,你可以逐步引入管道行为、缓存机制或事件发布等功能,进一步增强系统的灵活性和健壮性。不复杂但容易忽略的是保持请求类的简洁和单一职责,避免滥用导致过度拆分。

相关专题

更多
string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

315

2023.08.02

c语言中null和NULL的区别
c语言中null和NULL的区别

c语言中null和NULL的区别是:null是C语言中的一个宏定义,通常用来表示一个空指针,可以用于初始化指针变量,或者在条件语句中判断指针是否为空;NULL是C语言中的一个预定义常量,通常用来表示一个空值,用于表示一个空的指针、空的指针数组或者空的结构体指针。

231

2023.09.22

java中null的用法
java中null的用法

在Java中,null表示一个引用类型的变量不指向任何对象。可以将null赋值给任何引用类型的变量,包括类、接口、数组、字符串等。想了解更多null的相关内容,可以阅读本专题下面的文章。

436

2024.03.01

if什么意思
if什么意思

if的意思是“如果”的条件。它是一个用于引导条件语句的关键词,用于根据特定条件的真假情况来执行不同的代码块。本专题提供if什么意思的相关文章,供大家免费阅读。

738

2023.08.22

硬盘接口类型介绍
硬盘接口类型介绍

硬盘接口类型有IDE、SATA、SCSI、Fibre Channel、USB、eSATA、mSATA、PCIe等等。详细介绍:1、IDE接口是一种并行接口,主要用于连接硬盘和光驱等设备,它主要有两种类型:ATA和ATAPI,IDE接口已经逐渐被SATA接口;2、SATA接口是一种串行接口,相较于IDE接口,它具有更高的传输速度、更低的功耗和更小的体积;3、SCSI接口等等。

1018

2023.10.19

PHP接口编写教程
PHP接口编写教程

本专题整合了PHP接口编写教程,阅读专题下面的文章了解更多详细内容。

63

2025.10.17

php8.4实现接口限流的教程
php8.4实现接口限流的教程

PHP8.4本身不内置限流功能,需借助Redis(令牌桶)或Swoole(漏桶)实现;文件锁因I/O瓶颈、无跨机共享、秒级精度等缺陷不适用高并发场景。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

406

2025.12.29

class在c语言中的意思
class在c语言中的意思

在C语言中,"class" 是一个关键字,用于定义一个类。想了解更多class的相关内容,可以阅读本专题下面的文章。

465

2024.01.03

Golang gRPC 服务开发与Protobuf实战
Golang gRPC 服务开发与Protobuf实战

本专题系统讲解 Golang 在 gRPC 服务开发中的完整实践,涵盖 Protobuf 定义与代码生成、gRPC 服务端与客户端实现、流式 RPC(Unary/Server/Client/Bidirectional)、错误处理、拦截器、中间件以及与 HTTP/REST 的对接方案。通过实际案例,帮助学习者掌握 使用 Go 构建高性能、强类型、可扩展的 RPC 服务体系,适用于微服务与内部系统通信场景。

8

2026.01.15

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Bootstrap 5教程
Bootstrap 5教程

共46课时 | 2.9万人学习

Go语言实战之 GraphQL
Go语言实战之 GraphQL

共10课时 | 0.8万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号