.netcore 3.1 MediatR：轻松实现命令查询职责分离模式（CQRS）

• .netcore 3.1 MediatR：轻松实现命令查询职责分离模式（CQRS）
  • 中介者模式
  • 单播消息传输(Demo)
  • 多播消息传输(Demo)

中介者模式

中介者的优点与缺点

优点：中介者模式的优点就是减少类间的依赖，把原有的一对多的依赖变成了一对一的依赖，同事类只依赖中介者，减少了依赖，当然同时也降低了类间的耦合
缺点：中介者模式的缺点就是中介者会膨胀得很大，而且逻辑复杂，原本N个对象直接的相互依赖关系转换为中介者和同事类的依赖关系，同事类越多，中介者的逻辑就越复杂。

单播消息传输(Demo)

创建项目

添加下列nuget包到项目中

  <ItemGroup>
    <PackageReference Include="MediatR" Version="9.0.0" />
    <PackageReference Include="MediatR.Extensions.Microsoft.DependencyInjection" Version="9.0.0" />
    <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="3.1.9" />
  </ItemGroup>

添加 MyCommand.cs

/// <summary>
/// 创建 消息请求
/// </summary>
internal class MyCommand : IRequest<long>
{
    public string CommandName { get; set; }
}
/// <summary>
/// 创建 消息处理
/// </summary>
internal class MyCommandHandler : IRequestHandler<MyCommand, long>
{
    public Task<long> Handle(MyCommand request, CancellationToken cancellationToken)
    {
        System.Console.WriteLine($"MyCommandHandler run command：{request.CommandName}");
        return Task.FromResult(10L);
    }
}

Program.cs

async static Task Main(string[] args)
{
    var services = new ServiceCollection();
    services.AddMediatR(typeof(Program).Assembly);
    var serviceProvider = services.BuildServiceProvider();
    var mediator = serviceProvider.GetService<IMediator>();
    await mediator.Send(new MyCommand { CommandName = "cmd01" });
    Console.WriteLine("Hello World!");
}

运行结果

多播消息传输(Demo)

添加 Ping.cs

public class Ping : INotification {
    public string Name { get; set; }
}
//构建 消息处理器1
public class Pong1 : INotificationHandler<Ping>
{
    public Task Handle(Ping notification, CancellationToken cancellationToken)
    {
        Console.WriteLine($"{notification.Name} Pong 1");
        return Task.CompletedTask;
    }
}
//构建 消息处理器2
public class Pong2 : INotificationHandler<Ping>
{
    public Task Handle(Ping notification, CancellationToken cancellationToken)
    {
        Console.WriteLine($"{notification.Name} Pong 2");
        return Task.CompletedTask;
    }
}

Program.cs

await mediator.Publish(new Ping() { Name="Start" });

运行结果