- 一、简介
- 二、安装Nuget
- 三、信息配置
- startup.cs
- CreateOrderCommand
- IRequestHandler
- OrderController.cs
- 当写入多个处理
- 总结
二、安装NugetNET 中的简单中介实现
没有依赖关系的进程内消息传递。
支持请求/响应、命令、查询、通知和事件、同步和异步,通过 C# 通用方差进行智能调度。
三、信息配置Install-Package MediatR
创建weiapi项目
startup.cspublic void ConfigureServices(IServiceCollection services)
{
//注册MeditaR
services.AddMediatR(typeof(Startup));
services.AddControllers();
}
CreateOrderCommand
请求/响应接口处理命令和查询场景。首先,创建一条消息
public class CreateOrderCommand : IRequest{ public string OrderName { get; set; } }
IRequestHandler创建一个处理程序
public class CreateOrderCommandHandleSecond : IRequestHandlerOrderController.cs{ //实现Handle方法 public Task Handle(CreateOrderCommand request, CancellationToken cancellationToken) { var s = $"CreateOrderCommandHandlerSecond: Create Order ${request.OrderName}"; return Task.FromResult(s); } }
注入Mediator
private readonly IMediator _mediator;
public OrderController(IMediator mediator)
{
_mediator = mediator;
}
发送消息
[HttpPost]
public async Task CreateOrder([FromBody] CreateOrderCommand command)
{
return await _mediator.Send(command);
}
当写入多个处理
public class CreateOrderCommandHandleSecond : IRequestHandler{ public Task Handle(CreateOrderCommand request, CancellationToken cancellationToken) { var s = $"CreateOrderCommandHandlerSecond: Create Order ${request.OrderName}"; return Task.FromResult(s); } } public class CreateOrderCommandHandle : IRequestHandler { //实现Handle方法 public Task Handle(CreateOrderCommand request, CancellationToken cancellationToken) { var s = $"CreateOrderCommandHandler: Create Order ${request.OrderName}"; return Task.FromResult(s); } }
处理结果有有一个
当IRequestHandler有两个处理程序方法,只会处理一个。
总结通过一个中介者完成业务流程,显得控制器更加清晰,只负责提供接口、接收数据和权限标注
应用场景:通常会用来实现CQRS(命令查询职责分离),也可以用于模块解耦相关场景。



