基于Go-micro微服务的秒杀系统 | 某中二的黑科技研究中心

type

status

date

slug

summary

系统架构

一个经典的秒杀场景可以分为如下几个步骤

创建商品的库存信息

检查库存数量，满足数量就扣库存，否则失败

成功扣取库存后创建订单

创建支付记录

依据这个流程，可以将微服务系统分为如下几个业务模块

库存 stock

订单 order

支付 payment

系统架构图如下：

准备工作

本项目采用Golang语言和Go-Micro开发框架，使用Postgres数据库，为了便于快速开发，微服务的服务发现和消息机制就直接使用了Micro自带的机制。

Go和Go-Micro

Golang环境

Micro开发框架和工具

protoc

gRPC使用protobuf协议，需要安装protoc编译器，protoc编译器可以在GitHub的protobuf项目下下载编译好的工具直接使用。

protoc compiler

安装好protoc编译器后还需要安装micro服务对应的生成插件。

Postgres

我在测试环境中搭建了docker服务，因而可以通过docker快速启动一个Postgres实例。

为了方便管理，同时启动了一个adminer服务。

创建一个dev用户和secbuy数据库。

服务开发

有了大体的架构思路后，我们可以开始开发每个微服务了，这里通过Go-Micro提供的工具，我们可以快速搭建起一个微服务的开发模板，同时基于为了尽量去复用代码，可以将微服务的配置相关提取出来，作为一个公共的功能让其余微服务来调用。

因此我们这里先搭建一个负责读取配置数据的basic模块：代码路径

每个微服务通过引用basic模块即可以完成读取自身的配置文件并初始化。

完成basic的逻辑编写后，通过Go-Micro的micro工具即可自动生成微服务代码模块，开始微服务的开发。这里以stock库存服务为例，执行如下命令，风别建立stock-srv和stock-web服务，分别提供stock服务的业务逻辑和web接口。

生成的代码模板目录如下：

stock-srv

stock-web

可以看见代码模板不但帮我们生成好了基本的代码开发文件，还有Makefile、Dockerfile、README这些一般项目所需的辅助文件也一并生成好了。

stock 服务

这里从stock库存服务开始整个项目的开发，先在Postgres数据库中建立stock服务需要的表。注意为了保证高并发下，数据可能出现的超卖情况，在stock表中除了必要的数据字段，还添加了version乐观锁字段。

在本项目中，为了快速完成数据库的开发，引入了gorm库，在代码的model/stock/stock.go需要定义对应的

有了数据表后，可以开始编写proto文件，定义stock微服务可以提供的接口。在sotock微服务中提供三种接口：

CreateCommodity 创建商品信息

GetCommodity 通过ID查询商品信息

Sell 对指定ID的商品进行销存操作

服务的接口定义如下：

在proto文件中还需对这些接口进一步定义各个类型的字段，完成后通过已编写的的Makefile文件，在终端执行make proto即可生成对应的go代码文件stock.pb.go和stock.micro.go的文件。里面定义了proto文件中对应的go代码数据接口和接口。

为了方便数据库的开发，在basic模块中引入了gorm，可以通过gorm来完成model的开发。在stock服务的/model/stock/stock.go中可以根据需要定义stock表对应的struct，方便gorm来使用。

同时在此文件中，定义了一个service struct，用来实现本服务各接口功能的数据库对应的crud功能。在func (s *service) SellCommodityByID(id int32) (commodity *proto.Commodity, err error) 方法中，实现了本服务最核心的使用乐观锁销存操作。

最后在/handler/stock.go中为微服务实现proto文件中定义的三个接口，stock-srv微服务的开发工作便基本完成了。通过make build即可编译生成微服务的可执行文件。完成后的stock-srv结构：

stock服务同时还提供了stock-web来提供web接口的stock创建和查询服务。初始化的模板基本已完成了大部分的开发工作。基本上只需要在handler/handler.go中引入stock的服务，编写好对应的web接口方法即可。

这里需要注意的是，调用stock服务需要引用stock-srv模块的proto文件，对于还在开发中的项目，对应的文件可能还没发布到代码库中，这时一个是可以将stock-srv的proto文件复制一份到web服务中来使用，但一旦srv中的proto文件有变动web的文件也要同步变更。更方便的是是使用go mod，可以直接引用stock-srv的代码库路径，同时在go.mod中添加： replace github.com/wanghaoxi3000/go-secbuy-mirco/stock-srv => ../stock-srv将代码库路径转换为本地相对路径即可。

order 服务

order服务是秒杀中的承上启下的服务，通过提供CreateOrder的接口和order-web中的web服务，接收参与秒杀的用户调用请求，完成如下的功能：

查询指定ID的商品信息

查询到指定ID信息后，检查商品此时的订单和库存信息，若订单已等于库存，则商品已销售完

若商品订单尚小于库存，则调用stock服务的SellCommodityByID接口，执行销存操作

根据销存的结果，创建订单数据和发送创建支付记录消息，将结果返回给调用用户

存放订单数据的数据库orders表结构定义如下：

order服务代码的开发的流程和stock大同小异，在创建完模板后，主要的不太的是在model的CreateOrder方法中创建订单记录时，需要通过stock服务客户端调用Sell方法来完成销存服务。

同时在成功销存后，会向payment服务pub一个创建支付记录的消息，创建publisher的方法很简单，通过publisher := micro.NewPublisher("payment.payevent", service.Client())即可创建一个payment.payevent主题的Publisher，此后通过PaymentPublisher.Publish()方法即可发布消息。

payment 服务

payment服务主要在接收到用户成功参与秒杀的消息后，创建此用户对应的订单支付记录，存放数据的payments表结构如下：

payment服务提供PayOrder接口，通过payment-web服务的web接口，用户可通过此服务完成支付服务。本微服务需要注意的是通过micro.RegisterSubscriber("payment.payevent", service.Server(), paymentHandle.Process)来订阅payment.payevent主题接收消息，和对应的处理函数。orders表中的state表示了支付和未支付订单状态，用户通过payment-web的rest api完成支付操作后state变为1的记录表示用户支付成功。