Asp.Net Core6.0中MediatR的应用CQRS

1、前言

　　对于简单的系统而言模型与数据可以进行直接的映射，比如说三层模型就足够支撑项目的需求了。对于这种简单的系统我们过度设计说白了无异于增加成本，因为对于一般的CRUD来说我们不用特别区分查询和增删改的程序结构。高射炮打蚊子那就有点大材小用了。但是我们的系统具有一定复杂性的时候，可能源于访问频次、数据量或者数据模型这个时候我们的查询跟增删改的需求差距就逐渐变大。所以CQRS（Command Query Responsibility Segregation）命令查询的责任分离就出现了。CQRS本质上是一种读写分离设计思想，这种框架设计模式将命令型业务和查询型业务分开单独处理。我们运用MediatR就可以轻松的实现CQRS。

创新互联坚持“要么做到，要么别承诺”的工作理念，服务领域包括：成都网站建设、成都做网站、企业官网、英文网站、手机端网站、网站推广等服务，满足客户于互联网时代的宝山网站设计、移动媒体设计的需求，帮助企业找到有效的互联网解决方案。努力成为您成熟可靠的网络建设合作伙伴！

2、中介者模式

　　中介者模式，定义了一个中介对象来封装一系列对象之间的交互关系，中介者使各个对象之间不需要显式地相互引用，从而降低耦合性。也符合符合迪米特原则。MediatR本质就是中介者模式，实现命令的构造和命令的处理分开来。

3、MediatR简介

　　MediatR是一个跨平台通过一种进程内消息传递机制，进行请求/响应、命令、查询、通知和事件的消息传递，并通过C#泛型来支持消息的智能调度，其目的是消息发送和消息处理的解耦。它支持以单播和多播形式使用同步或异步的模式来发布消息，创建和侦听事件。

4、主要的几个对象

　　a.IMediator：主要提供Send与Publish方法，需要执行的命令都是通过这两个方法实现

　　b.IRequest、IRequest：命令查询 | 处理类所继承的接口，一个有返回类型，一个无返回类型，一个查询对应一个处理类，程序集只认第一个扫描到的类。

　　c.IRequestHandler（实现Handle方法）：命令处理接口。命令查询 | 处理类继承它，也可以继承AsyncRequestHandler（实现抽象Handle方法）、RequestHandler（实现抽象Handle方法）接口

　　d.INotification：命令查询 | 处理类所继承的接口这个没有返回，与IRequest不通的是可以对于多个处理类。

　　e.INotificationHandler：与IRequestHandler一样的只不过这是INotification的处理接口

5、IRequest栗子

a.IRequest：有返回值的类

　　说了那么多干巴巴的直接上代码看。我这里是Core6.0控制台应用程序，安装nuget包 MediatR与扩展包MediatR.Extensions.Microsoft.DependencyInjection。也可以通过命令行添加dotnet add package MediatRdotnet add package MediatR.Extensions.Microsoft.DependencyInjection先看命令的查询处理

　　这里我习惯性的将两个类放在一个文件里面方便查看，命名这里做查询就写XXXQuery 处理类的命名也是XXXQueryHandler

using MediatR;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Mrdiator.Query
{
/// 
    /// 查询信息命令类
/// 
    internal class GetInfoQuery:IRequest
    {
/// 
        /// 构造函数--就是查询的条件说白了
/// 
        /// 
        /// 
        /// 
        internal GetInfoQuery(int age, string name, DateTime nowTime)
        {
            Age= age;
            Name= name;
            NowTime= nowTime;
        }
        
public  int Age { get; set; }
public  string Name { get; set; }
public  DateTime NowTime { get; set; }
    }
/// 
    /// 查询命令的处理类
/// 
    internal class GetInfoQueryHandller : IRequestHandler
    {
public Task Handle(GetInfoQuery request, CancellationToken cancellationToken)
        {
            Console.WriteLine("GetObjCommandHandller");
object ret = new
            {
                request.Name,
                request.NowTime,
                request.Age,
            };
var result = new Result()
            {
                Code= 200,
                Message="Success",
                Data= ret
            };
return Task.FromResult(result);
        }
    }
}