34 | MediatR：輕松實現命令查詢職責分離模式（CQRS）
核心對象
IMeditator
IRequese、IRequest
IRequestHandler<in TRequest, TResponse>
首先我們安裝了 MediatR 的 8.0 的組件包，還安裝了依賴注入框架的擴展包，以及依賴注入框架的核心組件包
- MediatR
- MediatR.Extensions.Microsoft.DependencyInjection
- Microsoft.Extensions.DependencyInjection
大家可以觀察到 MediatR 的包名和命名空間少了一個 o，猜測是作者故意這樣設計的，因為它具體實現里面會有一個接口和類是 Mediator，如果設置同名的話會有一些引用上的問題
var services = new ServiceCollection();
services.AddMediatR(typeof(Program).Assembly);
我們在這里構建一個 ServiceCollection，然后通過一行代碼將我們當前的程序集注入進去，它就可以掃描我們當前程序集相關的類，下面看一下我們定義的兩個類
internal class MyCommand : IRequest<long>
{
public string CommandName { get; set; }
}
internal class MyCommandHandler : IRequestHandler<MyCommand, long>
{
public Task<long> Handle(MyCommand request, CancellationToken cancellationToken)
{
Console.WriteLine($"MyCommandHandler執行命令：{request.CommandName}");
return Task.FromResult(10L);
}
}
第一個類是 MyCommand，它實現了 IRequest 接口，這個接口就代表中介者要執行的命令
第二個類是 MyCommandHandler，它實現了 IRequestHandler 的接口，這個就是我們對命令的處理器的定義
var serviceProvider = services.BuildServiceProvider();
var mediator = serviceProvider.GetService<IMediator>();
await mediator.Send(new MyCommand { CommandName = "cmd01" });
我們從容器里面獲取一個 IMediator，然后通過 send 方法發送一個 MyCommand 命令，我們構造了一個新的 MyCommand 的實例傳給它
啟動程序，輸出如下：
MyCommandHandler執行命令：cmd01
我們可以看到 MyCommandHandler 的 Handle 方法執行了，它輸出了 MyCommandHandler 的執行命令 cmd01
這樣子，這個中介者它有什么好處呢?
大家可以看到，通過中介者模式，我們將命令的構造和命令的處理可以分離開，那么命令的處理如何知道要處理哪個命令呢，就是通過我們泛型的約束來定義的，我們這里為 IRequestHandler 填入了 MyCommand 類型，所以我們能明確知道 MyCommandHandler 是用來處理 MyCommand 的
如果說我在程序里面實現了多個 Handler，我們可以試驗一下
internal class MyCommandHandlerV2 : IRequestHandler<MyCommand, long>
{
public Task<long> Handle(MyCommand request, CancellationToken cancellationToken)
{
Console.WriteLine($"MyCommandHandlerV2執行命令：{request.CommandName}");
return Task.FromResult(10L);
}
}
internal class MyCommandHandler : IRequestHandler<MyCommand, long>
{
public Task<long> Handle(MyCommand request, CancellationToken cancellationToken)
{
Console.WriteLine($"MyCommandHandler執行命令：{request.CommandName}");
return Task.FromResult(10L);
}
}
啟動程序，輸出如下：
MyCommandHandlerV2執行命令：cmd01
大家可以看到我們輸出的是 V2 執行命令
我們把代碼進行一個調整，把這個定義移到后面
internal class MyCommandHandler : IRequestHandler<MyCommand, long>
{
public Task<long> Handle(MyCommand request, CancellationToken cancellationToken)
{
Console.WriteLine($"MyCommandHandler執行命令：{request.CommandName}");
return Task.FromResult(10L);
}
}
internal class MyCommandHandlerV2 : IRequestHandler<MyCommand, long>
{
public Task<long> Handle(MyCommand request, CancellationToken cancellationToken)
{
Console.WriteLine($"MyCommandHandlerV2執行命令：{request.CommandName}");
return Task.FromResult(10L);
}
}
啟動程序，輸出如下：
MyCommandHandler執行命令：cmd01
大家可以看到我們這次輸出的並不是 V2，而是之前的那個命令，為什么會這樣子呢？是因為實際上 mediator 對於 IRequestHandler 的掃描，它是有順序的，后面掃描到的會替換前面掃描到的 Handler，它只會識別其中最后注冊進去的一個，也就是說我們在處理 RequestHandler 的時候，我們要注意在注冊時僅注冊需要的那個
我們再來看看我們的應用程序，回到我們之前的工程里
namespace GeekTime.API.Application.Commands
{
public class CreateOrderCommandHandler : IRequestHandler<CreateOrderCommand, long>
{
IOrderRepository _orderRepository;
ICapPublisher _capPublisher;
public CreateOrderCommandHandler(IOrderRepository orderRepository, ICapPublisher capPublisher)
{
_orderRepository = orderRepository;
_capPublisher = capPublisher;
}
public async Task<long> Handle(CreateOrderCommand request, CancellationToken cancellationToken)
{
var address = new Address("wen san lu", "hangzhou", "310000");
var order = new Order("xiaohong1999", "xiaohong", 25, address);
_orderRepository.Add(order);
await _orderRepository.UnitOfWork.SaveEntitiesAsync(cancellationToken);
return order.Id;
}
}
}
我們可以看到我們的 CreateOrderCommandHandler 實現的是 IRequestHandler，這也就是解釋了為什么之前我們並沒有顯示的調用 CreateOrderCommandHandler，代碼卻能夠執行到這里的原因
GitHub源碼鏈接：
https://github.com/witskeeper/geektime
本作品采用知識共享署名-非商業性使用-相同方式共享 4.0 國際許可協議進行許可。
歡迎轉載、使用、重新發布，但務必保留文章署名 鄭子銘 （包含鏈接： http://www.cnblogs.com/MingsonZheng/ ），不得用於商業目的，基於本文修改后的作品務必以相同的許可發布。
如有任何疑問，請與我聯系 (MingsonZheng@outlook.com) 。