使用带CQRS和MongoDb的Dotnet Core实现微服务的CRUD操作

基础概念

CQRS（Command Query Responsibility Segregation） 是一种架构模式，它将应用程序的读操作（查询）和写操作（命令）分离。这种分离可以提高系统的性能、可扩展性和安全性。

MongoDB 是一个开源的、面向文档的NoSQL数据库，适用于需要灵活数据模型的应用。

微服务架构 是一种将应用程序拆分为一组小型、独立服务的架构风格，每个服务运行在自己的进程中，并通过轻量级机制通信。

优势

性能优化：CQRS允许针对读和写操作进行不同的优化策略。
可扩展性：读写分离可以独立扩展读和写的能力。
安全性：可以针对不同的操作实施不同的安全策略。
灵活性：MongoDB的文档模型适合处理复杂和变化的数据结构。

类型

简单CQRS：基本的读写分离。
事件驱动CQRS：通过事件来同步命令和查询模型。

应用场景

高并发读取：如电商网站的商品详情页。
复杂查询：需要聚合多个数据源的场景。
实时数据处理：如股票交易系统。

实现CRUD操作

以下是一个使用CQRS和MongoDB在Dotnet Core中实现微服务CRUD操作的简单示例。

1. 安装依赖

首先，安装必要的NuGet包：

dotnet add package MongoDB.Driver
dotnet add package MediatR

2. 定义命令和查询

// 命令
public class CreateProductCommand : IRequest
{
    public string Name { get; set; }
    public decimal Price { get; set; }
}

// 查询
public class GetProductQuery : IRequest<Product>
{
    public string Id { get; set; }
}

3. 创建处理器

public class CreateProductCommandHandler : IRequestHandler<CreateProductCommand>
{
    private readonly IMongoCollection<Product> _products;

    public CreateProductCommandHandler(IMongoCollection<Product> products)
    {
        _products = products;
    }

    public async Task<Unit> Handle(CreateProductCommand request, CancellationToken cancellationToken)
    {
        var product = new Product { Id = Guid.NewGuid().ToString(), Name = request.Name, Price = request.Price };
        await _products.InsertOneAsync(product, cancellationToken);
        return Unit.Value;
    }
}

public class GetProductQueryHandler : IRequestHandler<GetProductQuery, Product>
{
    private readonly IMongoCollection<Product> _products;

    public GetProductQueryHandler(IMongoCollection<Product> products)
    {
        _products = products;
    }

    public async Task<Product> Handle(GetProductQuery request, CancellationToken cancellationToken)
    {
        return await _products.Find(p => p.Id == request.Id).FirstOrDefaultAsync(cancellationToken);
    }
}

4. 配置MediatR和MongoDB

在Startup.cs中配置服务和数据库连接：

public void ConfigureServices(IServiceCollection services)
{
    services.AddMediatR(typeof(Program));
    services.AddSingleton<IMongoClient>(new MongoClient("your_connection_string"));
    services.AddScoped(sp => sp.GetRequiredService<IMongoClient>().GetDatabase("your_database_name").GetCollection<Product>("products"));
}

5. 使用MediatR进行调用

public class ProductController : ControllerBase
{
    private readonly IMediator _mediator;

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

    [HttpPost]
    public async Task<IActionResult> CreateProduct([FromBody] CreateProductCommand command)
    {
        await _mediator.Send(command);
        return Ok();
    }

    [HttpGet("{id}")]
    public async Task<IActionResult> GetProduct(string id)
    {
        var product = await _mediator.Send(new GetProductQuery { Id = id });
        return Ok(product);
    }
}