C# Academy · 课时

使用 MediatR 处理命令和请求

将请求分派给专用处理程序。

第 2 / 4 课13 个步骤

使用 MediatR 处理命令和请求 是 CoddyKit 上的免费 C# Academy 课时。 这是第 2 节课,共 4 节。 你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。 这是 C# Academy 学习路径的一部分,你的进度在网页和 CoddyKit 应用中同步。 C# Academy 课程共包含 4 节课。

注册 MediatR

MediatR 会扫描程序集以发现 handler。请在启动时注册一次,并将其指向包含 handler 的程序集。

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

IRequest

需要响应的消息会实现 IRequest<TResponse>。类型参数表示 handler 返回的内容。

public record CreateOrderCommand(int CustomerId, string[] Items)
    : IRequest<int>;   // returns the new order id

不返回结果的命令

如果命令不返回有意义的内容,请实现非泛型 IRequest(它是 IRequest<Unit> 的简写)。

public record CancelOrderCommand(int OrderId) : IRequest;

IRequestHandler

handler 会实现 IRequestHandler<TRequest, TResponse>,并提供执行实际工作的 Handle 方法。

public class CreateOrderHandler
    : IRequestHandler<CreateOrderCommand, int>
{
    public Task<int> Handle(
        CreateOrderCommand request, CancellationToken ct)
    {
        // create the order...
        return Task.FromResult(newOrderId);
    }
}

注入依赖

handler 会从 DI 中解析,因此可以通过构造函数接收数据库 context、仓储或其他服务。

public class CreateOrderHandler(AppDbContext db)
    : IRequestHandler<CreateOrderCommand, int>
{
    public async Task<int> Handle(
        CreateOrderCommand request, CancellationToken ct)
    {
        var order = new Order { CustomerId = request.CustomerId };
        db.Orders.Add(order);
        await db.SaveChangesAsync(ct);
        return order.Id;
    }
}

ISender

要分发请求,请注入 ISender(或功能更广泛的 IMediator),然后调用 Send。MediatR 会找到匹配的 handler。

public class OrdersController(ISender sender) : ControllerBase
{
    [HttpPost]
    public async Task<IActionResult> Create(CreateOrderCommand cmd)
    {
        int id = await sender.Send(cmd);
        return CreatedAtAction(nameof(Get), new { id }, null);
    }
}

在最小 API 中使用 Send

最小 API 会将 ISender 直接注入端点委托。

app.MapPost("/orders", async (
    CreateOrderCommand cmd, ISender sender) =>
{
    var id = await sender.Send(cmd);
    return Results.Created($"/orders/{id}", new { id });
});

查询也只是请求

查询使用相同的 IRequest / IRequestHandler 机制——唯一的区别在于意图:handler 只读取数据,绝不会修改数据。

public record GetOrderQuery(int Id) : IRequest<OrderDto?>;

public class GetOrderHandler(AppDbContext db)
    : IRequestHandler<GetOrderQuery, OrderDto?>
{
    public async Task<OrderDto?> Handle(
        GetOrderQuery q, CancellationToken ct) =>
        await db.Orders
            .Where(o => o.Id == q.Id)
            .Select(o => new OrderDto(o.Id, o.Total))
            .SingleOrDefaultAsync(ct);
}

每个请求对应一个 handler

对于 Send,一个请求类型必须且只能匹配一个 handler。为同一个请求注册零个或两个 handler 都属于配置错误。

// CreateOrderCommand -> exactly one CreateOrderHandler

返回丰富的结果

响应可以是任意类型——DTO、结果包装器,甚至是区分式结果——让 handler 能够明确表达成功和失败。

public record Result(bool Ok, string? Error);
public record PlaceOrderCommand(int Id) : IRequest<Result>;

测试 handler

由于 handler 是一个带有注入依赖的普通类,您可以直接测试它——不需要 HTTP,也不需要控制器。

var handler = new CreateOrderHandler(inMemoryDb);
var id = await handler.Handle(
    new CreateOrderCommand(1, ["sku-1"]), CancellationToken.None);
Assert.True(id > 0);

快速检查

请确认 MediatR 的分发模型。

回顾

您实现了命令和 handler:

  • AddMediatR 会扫描程序集以注册 handler。
  • 消息实现 IRequest<T>;handler 实现 IRequestHandler<TRequest, T>。
  • 注入 ISender 并调用 Send 来分发请求;每个请求恰好匹配一个 handler。
  • 查询复用相同的机制,并且不产生副作用。

下一步:流水线行为。

免费开始

用 AI 导师学习 C# — 免费

在浏览器中编写并运行真实代码,获得全天候 AI 导师的即时帮助,并在网页或应用中继续学习。

课程
93
课程
346

常见问题解答

「使用 MediatR 处理命令和请求」课时是免费的吗?

是的 — 「使用 MediatR 处理命令和请求」的完整文本可在网页上免费阅读。要进行交互式练习(内置代码编辑器和全天候 AI 导师)并解锁 C# Academy 课程的其余内容,请升级到 CoddyKit PRO。 C# Academy 课程共包含 4 节课。

「使用 MediatR 处理命令和请求」这节课中我会学到什么?

将请求分派给专用处理程序。 你通过在浏览器中直接运行的动手代码来练习 C# Academy,全天候 AI 导师会在你学习这节课的过程中回答你的问题。

学习 C# Academy 需要有经验吗?

无需任何先前经验。CoddyKit 上的 C# Academy 课程适合初学者到高级学习者,你可以从这里开始或从头开始,按照自己的节奏学习。 这是第 2 节课,共 4 节。

「使用 MediatR 处理命令和请求」课时需要多长时间?

大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动,所以你能稳步进步,并在网页和应用中从离开的地方继续。

我能在这节 C# Academy 课中编写并运行代码吗?

能。每节 C# Academy 课都包含内置代码编辑器,你可以在浏览器中直接编写并运行真实代码,并获得即时 AI 反馈 — 无需本地设置。

此课程中的所有课时

  1. CQRS 概念
  2. 使用 MediatR 处理命令和请求
  3. 管道行为
  4. 通知与事件
← 返回 C# Academy