34 | MediatR：輕松實現(xiàn)命令查詢職責(zé)分離模式（CQRS）

核心對象

IMeditator

IRequese、IRequest

IRequestHandler<in TRequest, TResponse>

源碼鏈接：
https://github.com/witskeeper/geektime/tree/master/samples/MediatorDemo

首先我們安裝了 MediatR 的 8.0 的組件包，還安裝了依賴注入框架的擴展包，以及依賴注入框架的核心組件包

• MediatR

• MediatR.Extensions.Microsoft.DependencyInjection

• Microsoft.Extensions.DependencyInjection

大家可以觀察到 MediatR 的包名和命名空間少了一個 o，猜測是作者故意這樣設(shè)計的，因為它具體實現(xiàn)里面會有一個接口和類是 Mediator，如果設(shè)置同名的話會有一些引用上的問題

var services = new ServiceCollection();services.AddMediatR(typeof(Program).Assembly);

我們在這里構(gòu)建一個 ServiceCollection，然后通過一行代碼將我們當(dāng)前的程序集注入進去，它就可以掃描我們當(dāng)前程序集相關(guān)的類，下面看一下我們定義的兩個類

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執(zhí)行命令：{request.CommandName}");return Task.FromResult(10L);} }

第一個類是 MyCommand，它實現(xiàn)了 IRequest 接口，這個接口就代表中介者要執(zhí)行的命令

第二個類是 MyCommandHandler，它實現(xiàn)了 IRequestHandler 的接口，這個就是我們對命令的處理器的定義

var serviceProvider = services.BuildServiceProvider();var mediator = serviceProvider.GetService<IMediator>();await mediator.Send(new MyCommand { CommandName = "cmd01" });

我們從容器里面獲取一個 IMediator，然后通過 send 方法發(fā)送一個 MyCommand 命令，我們構(gòu)造了一個新的 MyCommand 的實例傳給它

啟動程序，輸出如下：

MyCommandHandler執(zhí)行命令：cmd01

我們可以看到 MyCommandHandler 的 Handle 方法執(zhí)行了，它輸出了 MyCommandHandler 的執(zhí)行命令 cmd01

這樣子，這個中介者它有什么好處呢?

大家可以看到，通過中介者模式，我們將命令的構(gòu)造和命令的處理可以分離開，那么命令的處理如何知道要處理哪個命令呢，就是通過我們泛型的約束來定義的，我們這里為 IRequestHandler 填入了 MyCommand 類型，所以我們能明確知道 MyCommandHandler 是用來處理 MyCommand 的

如果說我在程序里面實現(xiàn)了多個 Handler，我們可以試驗一下

internal class MyEventHandlerV2 : INotificationHandler<MyEvent> {public Task Handle(MyEvent notification, CancellationToken cancellationToken){Console.WriteLine($"MyEventHandlerV2執(zhí)行：{notification.EventName}");return Task.CompletedTask;} }

啟動程序，輸出如下：

MyCommandHandlerV2執(zhí)行命令：cmd01

大家可以看到我們輸出的是 V2 執(zhí)行命令

我們把代碼進行一個調(diào)整，把這個定義移到后面

internal class MyEventHandler : INotificationHandler<MyEvent> {public Task Handle(MyEvent notification, CancellationToken cancellationToken){Console.WriteLine($"MyEventHandler執(zhí)行：{notification.EventName}");return Task.CompletedTask;} }internal class MyEventHandlerV2 : INotificationHandler<MyEvent> {public Task Handle(MyEvent notification, CancellationToken cancellationToken){Console.WriteLine($"MyEventHandlerV2執(zhí)行：{notification.EventName}");return Task.CompletedTask;} }

啟動程序，輸出如下：

MyCommandHandler執(zhí)行命令：cmd01

大家可以看到我們這次輸出的并不是 V2，而是之前的那個命令，為什么會這樣子呢？是因為實際上 mediator 對于 IRequestHandler 的掃描，它是有順序的，后面掃描到的會替換前面掃描到的 Handler，它只會識別其中最后注冊進去的一個，也就是說我們在處理 RequestHandler 的時候，我們要注意在注冊時僅注冊需要的那個

我們再來看看我們的應(yīng)用程序，回到我們之前的工程里

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 實現(xiàn)的是 IRequestHandler，這也就是解釋了為什么之前我們并沒有顯示的調(diào)用 CreateOrderCommandHandler，代碼卻能夠執(zhí)行到這里的原因

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎勵來咯，堅持創(chuàng)作打卡瓜分現(xiàn)金大獎

總結(jié)

以上是生活随笔為你收集整理的.NET Core开发实战（第34课：MediatR：轻松实现命令查询职责分离模式（CQRS））--学习笔记（上）...的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。