Detailed explanation of how inventory deduction is implemented in Go (multiple methods)

This article is introduced by the golang tutorial column to introduce several implementation methods of Go inventory deduction. I hope it will be helpful to friends in need!

Several implementation methods of Go inventory deduction

Grpc, proto, gorm, zap, go-redis, go-redsync and other packages are used here

Go Mutex implementation

var m sync.Mutexfunc (*InventoryServer) LockSell(ctx context.Context, req *proto.SellInfo) (*emptypb.Empty, error) {
    tx := global.DB.Begin()
    m.Lock() 
    for _, good := range req.GoodsInfo {
        var i model.Inventory        if result := global.DB.Where(&model.Inventory{Goods: good.GoodsId}).First(&i); 
             result.RowsAffected == 0 {
            tx.Rollback() // 回滚
            return nil, status.Errorf(codes.InvalidArgument, "未找到此商品的库存信息。")
        }
        if i.Stocks <h5>
<span class="header-link octicon octicon-link"></span>MySQL pessimistic lock implementation</h5><pre class="brush:php;toolbar:false">func (*InventoryServer) ForUpdateSell(ctx context.Context, req *proto.SellInfo) (*emptypb.Empty, error) {
    tx := global.DB.Begin()
    for _, good := range req.GoodsInfo {
        var i model.Inventory        if result := tx.Clauses(clause.Locking{
            Strength: "UPDATE",
        }).Where(&model.Inventory{Goods: good.GoodsId}).First(&i);
            result.RowsAffected == 0 {
            tx.Rollback()
            return nil, status.Errorf(codes.InvalidArgument, "未找到此商品的库存信息。")
        }
        if i.Stocks <h5>
<span class="header-link octicon octicon-link"></span>MySQL optimistic lock implementation</h5><pre class="brush:php;toolbar:false">func (*InventoryServer) VersionSell(ctx context.Context, req *proto.SellInfo) (*emptypb.Empty, error) {
    tx := global.DB.Begin()
    for _, good := range req.GoodsInfo {
        var i model.Inventory        for { // 并发请求相同条件比较多，防止放弃掉一些请求
            if result := global.DB.Where(&model.Inventory{Goods: good.GoodsId}).First(&i);
                result.RowsAffected == 0 {

                tx.Rollback()
                return nil, status.Errorf(codes.InvalidArgument, "未找到此商品的库存信息.")
            }
            if i.Stocks  <h5>
<span class="header-link octicon octicon-link"></span>Redis distributed lock implementation</h5><pre class="brush:php;toolbar:false">func (*InventoryServer) RedisSell(ctx context.Context, req *proto.SellInfo) (*emptypb.Empty, error) {
    // redis 分布式锁
    pool := goredis.NewPool(global.Redis)
    rs := redsync.New(pool)
    tx := global.DB.Begin()
    for _, good := range req.GoodsInfo {
        mutex := rs.NewMutex(fmt.Sprintf("goods_%d", good.GoodsId))
        if err := mutex.Lock(); err != nil {
            return nil, status.Errorf(codes.Internal, "redis:分布式锁获取异常")
        }
        var i model.Inventory        if result := global.DB.Where(&model.Inventory{Goods: good.GoodsId}).First(&i); result.RowsAffected == 0 {
            tx.Rollback()
            return nil, status.Errorf(codes.InvalidArgument, "未找到此商品的库存信息")
        }
        if i.Stocks <h4>
<span class="header-link octicon octicon-link"></span>Test</h4><blockquote><p>Involves services, databases and other environments, this test is pseudo code </p></blockquote><pre class="brush:php;toolbar:false">func main() {
  var w sync.WaitGroup
  w.Add(20)
  for i := 0; i 

The above is the detailed content of Detailed explanation of how inventory deduction is implemented in Go (multiple methods). For more information, please follow other related articles on the PHP Chinese website!