本文共 1934 字，大约阅读时间需要 6 分钟。

引言

Catalog microservice（目录微服务）维护着所有产品信息，包括库存、价格。所以该微服务的核心业务为：

1. 产品信息的维护
2. 库存的更新
3. 价格的维护

架构模式

如上图所示，本微服务采用简单的数据驱动的CRUD微服务架构，来执行产品信息的创建、读取、更新和删除（CRUD）操作。

核心技术选型：

1. ASP.NET Core Web API
2. Entity Framework Core
3. SQL Server
4. Swashbuckle（可选）
5. Autofac
6. Eventbus
7. Polly

实体建模

该微服务的核心领域实体是商品，其类图如下：

对于实体这一块，有两个小知识点需要说明一下：

1. 进行数据库字段映射时，主键都使用了ForSqlServerUseSequenceHiLo指定使用HI-LO高低位序列进行主键生成。
2. 使用NoTracking提升查询速度
   在CatalogController的构造方法中，明确指定以下代码来进行查询优化，这一点也是我们值得学习的地方。 ((DbContext)context).ChangeTracker.QueryTrackingBehavior = QueryTrackingBehavior.NoTracking;
3. 在进行种子数据的预置时，使用了Polly开启了Retry机制。

private Policy CreatePolicy( ILogger
   
     logger, string prefix,int retries = 3){    return Policy.Handle
    
     ().        WaitAndRetryAsync(            retryCount: retries,            sleepDurationProvider: retry => TimeSpan.FromSeconds(5),            onRetry: (exception, timeSpan, retry, ctx) =>            {                logger.LogTrace($"[{prefix}] Exception {exception.GetType().Name} with message ${exception.Message} detected on attempt {retry} of {retries}");            }        );}public async Task SeedAsync(CatalogContext context,IHostingEnvironment env,IOptions
     
       settings,ILogger
      
        logger){    var policy = CreatePolicy(logger, nameof(CatalogContextSeed));    await policy.ExecuteAsync(async () =>    {        //...    });       }
      
     
    
   

数据库表结构

最后

如果eShopOnContainers采用的是单体式应用架构而非微服务架构，那么以上业务逻辑的实现并不复杂，使用简单的CRUD再辅以ACID事务就能很好的完成业务需求。本文的介绍也就可以到此为止了。

然而将其抽取出来成为独立的基础微服务，那么我们要考虑的问题就多了。比如：

1. 修改产品价格时，需要同步更新购物车中保存的产品信息的价格。
2. 下订单时，需要验证当前商品库存是否充足，进行锁库抢占，以避免库存不足导致的订单无效。

而这一切我们都不能再享受单体应用中直接使用ACID事务的便利了。因为在微服务应用里，产品表和购物篮表被各自的微服务所占有。任何微服务不应该在自己的事务中包含其他微服务的表或存储，即使是直接查询也是不可以的。目录微服务不能直接更新购物篮表，因为购物篮表被购物篮微服务占有。要更新购物篮微服务，产品微服务应该使用基于异步通信，如集成事件（消息和基于事件的通信）来实现最终一致性。

那下一节我们就来详细阐述eShopOnContainers是如何通过事件机制完成最终一致性的。

转载地址：http://cnpfz.baihongyu.com/