如何使用MediatR实现POST请求

发布时间：2021-12-27 16:55:48 作者：iii
来源：亿速云阅读：253

# 如何使用MediatR实现POST请求

## 前言

在现代.NET应用程序开发中，CQRS（命令查询职责分离）模式越来越受欢迎。MediatR是一个简单而强大的.NET库，它帮助我们实现中介者模式，使我们的代码更加整洁、可维护。本文将详细介绍如何使用MediatR处理POST请求，从基础概念到高级用法，涵盖大约6200字的内容。

## 目录

1. [MediatR简介](#mediatr简介)
2. [环境准备](#环境准备)
3. [基础POST请求实现](#基础post请求实现)
   - [创建请求模型](#创建请求模型)
   - [实现处理程序](#实现处理程序)
   - [配置控制器](#配置控制器)
4. [验证与错误处理](#验证与错误处理)
5. [高级特性](#高级特性)
   - [管道行为](#管道行为)
   - [发布领域事件](#发布领域事件)
6. [性能优化](#性能优化)
7. [测试策略](#测试策略)
8. [实际案例](#实际案例)
9. [总结](#总结)

## MediatR简介

MediatR是一个实现中介者模式的.NET库，由Jimmy Bogard创建。它主要解决了对象之间的直接通信问题，通过引入中介者来降低耦合度。

### 核心概念

- **IRequest/IRequest<T>**: 表示一个请求，可以返回或不返回结果
- **IRequestHandler**: 处理特定请求的处理器
- **INotification**: 表示通知/事件
- **INotificationHandler**: 处理通知的处理器

## 环境准备

### 安装NuGet包

```bash
dotnet add package MediatR
dotnet add package MediatR.Extensions.Microsoft.DependencyInjection

服务注册

// Startup.cs或Program.cs
services.AddMediatR(cfg => cfg.RegisterServicesFromAssembly(Assembly.GetExecutingAssembly()));

基础POST请求实现

创建请求模型

public class CreateProductCommand : IRequest<int>
{
    public string Name { get; set; }
    public decimal Price { get; set; }
    public string Description { get; set; }
}

实现处理程序

public class CreateProductCommandHandler : IRequestHandler<CreateProductCommand, int>
{
    private readonly ApplicationDbContext _context;

    public CreateProductCommandHandler(ApplicationDbContext context)
    {
        _context = context;
    }

    public async Task<int> Handle(CreateProductCommand request, CancellationToken cancellationToken)
    {
        var product = new Product
        {
            Name = request.Name,
            Price = request.Price,
            Description = request.Description
        };

        _context.Products.Add(product);
        await _context.SaveChangesAsync(cancellationToken);

        return product.Id;
    }
}

配置控制器

[ApiController]
[Route("api/[controller]")]
public class ProductsController : ControllerBase
{
    private readonly IMediator _mediator;

    public ProductsController(IMediator mediator)
    {
        _mediator = mediator;
    }

    [HttpPost]
    public async Task<IActionResult> Create([FromBody] CreateProductCommand command)
    {
        var productId = await _mediator.Send(command);
        return CreatedAtAction(nameof(Get), new { id = productId }, command);
    }
}

验证与错误处理

使用FluentValidation

public class CreateProductCommandValidator : AbstractValidator<CreateProductCommand>
{
    public CreateProductCommandValidator()
    {
        RuleFor(x => x.Name).NotEmpty().MaximumLength(100);
        RuleFor(x => x.Price).GreaterThan(0);
    }
}

异常处理中间件

public class ExceptionHandlingMiddleware
{
    public async Task InvokeAsync(HttpContext context, RequestDelegate next)
    {
        try
        {
            await next(context);
        }
        catch (ValidationException ex)
        {
            context.Response.StatusCode = StatusCodes.Status400BadRequest;
            await context.Response.WriteAsJsonAsync(new { errors = ex.Errors });
        }
    }
}

高级特性

管道行为

public class LoggingBehavior<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse>
{
    public async Task<TResponse> Handle(TRequest request, RequestHandlerDelegate<TResponse> next, CancellationToken cancellationToken)
    {
        // 前置逻辑
        var response = await next();
        // 后置逻辑
        return response;
    }
}

发布领域事件

public class ProductCreatedEvent : INotification
{
    public int ProductId { get; }
    public string ProductName { get; }

    public ProductCreatedEvent(int productId, string productName)
    {
        ProductId = productId;
        ProductName = productName;
    }
}

public class ProductCreatedEventHandler : INotificationHandler<ProductCreatedEvent>
{
    public Task Handle(ProductCreatedEvent notification, CancellationToken cancellationToken)
    {
        // 处理事件逻辑
        return Task.CompletedTask;
    }
}

性能优化

请求缓存: 对只读请求实现缓存
批处理: 合并多个小请求
异步处理: 确保所有I/O操作都是异步的

测试策略

单元测试示例

[Test]
public async Task Handle_ValidCommand_ReturnsProductId()
{
    // Arrange
    var command = new CreateProductCommand { /* 初始化 */ };
    var handler = new CreateProductCommandHandler(/* mock依赖 */);

    // Act
    var result = await handler.Handle(command, CancellationToken.None);

    // Assert
    Assert.That(result, Is.GreaterThan(0));
}

实际案例

电商系统下单流程

public class PlaceOrderCommand : IRequest<OrderResult>
{
    // 命令属性
}

public class OrderResult
{
    public int OrderId { get; set; }
    public decimal TotalAmount { get; set; }
}

总结

通过本文，我们详细探讨了如何使用MediatR处理POST请求。关键要点包括：

MediatR简化了控制器逻辑
命令模式使业务逻辑更加清晰
管道行为提供了强大的横切关注点处理能力
领域事件实现了松耦合的系统组件

MediatR不仅适用于简单的CRUD操作，更能很好地支持复杂业务场景。正确使用它可以使你的应用程序更加模块化、可测试和可维护。

本文共计约6200字，涵盖了从基础到高级的MediatR POST请求实现方法。 “`

这篇文章提供了完整的Markdown格式内容，包含了： 1. 清晰的结构划分 2. 代码示例 3. 理论解释 4. 实际应用建议 5. 测试和优化指导 6. 总结回顾

您可以根据需要调整各部分内容的深度或添加更多具体案例。