解决数据一致性方案（库存问题）

落日映苍穹つ 2022-12-28 09:22 313阅读 0赞

# 解决数据一致性方案 #

本文只讲述原理，均为伪代码，具体实现还得小伙伴实现。

## Redis ##

#### Redis中第一种库存存储方式 ####

1.  hset(key,value,goods) == set(key,goods)
2.  秒杀业务下单

代码：

//查询商品
            goods = redis.get(key);
            //判断库存
            if (goods.getStockCount <= 0) { 
                //已售馨
            } else { 
                //减redis库存
                //下单业务
            }

问题：

在第一步执行，如果有多个线程一起进来，都会拿到相同数量库存，会出现超卖现象。

#### Redis中第二种方式 ####

1.  hset(key,value,goods) == set(key,goods)
2.  库存：hset(key, value, stockCount)

//减库存
    		Long result = redis.increment(key, value, -1);
            if (result <= 0) { 
                //已售馨
            }
            //下单业务

#### Redis中第三种方式 ####

1.  hset(key,value,goods) == set(key,goods)
2.  lpush(key, ltemid) //使用队列存储商品id

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2gyNzM5Nzk1ODY_size_16_color_FFFFFF_t_70]

## 队列 ##

扣减缓存库存时候，发送消息通知数据库库存也进行扣减，从而到达缓存数据和数据库数据一致性。

//从redis扣减库存
            Long increment = redisTemplate.opsForValue().increment(商品id, -1);
            //判断扣减库存是否成功
            if (increment > 0) { 
                //发送下单信息
                boolean res = mq.send(商品id);
                if (!res) { 
                    //消息发送失败，库存回滚
                    redisTemplate.opsForValue().increment(商品id, 1);
                }
            } else if (increment == 0) { 
                //商品已售馨
            } else { 
                //扣减库存失败，库存回滚
                redisTemplate.opsForValue().increment(商品id, 1);
            }
    
            //下单业务

问题：

1.  异步消息发送失败——已解决（上述代码）
2.  扣减操作失败——已解决（上述代码）
3.  下单失败（数据无法正确回滚）发送事务型消息（半消息，提交）

#### 事务消息 ####

如果下单业务处理失败，那么数据库库存已经扣减，需要回滚消息。

Long increment = redisTemplate.opsForValue().increment(商品id, -1);
            //判断扣减库存是否成功
            if (increment > 0) { 
                //库存扣减成功
            } else if (increment == 0) { 
                //商品已售馨
            } else { 
                //扣减库存失败，库存回滚
                redisTemplate.opsForValue().increment(商品id, 1);
            }
    
            //下单业务
    
            //发送事务消息，没有发送成功抛异常回滚事务
            boolean res = Mq.sendTransaction(消息);
            if (!res) { 
                new RunnTimeException(“下单失败”);
            }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2gyNzM5Nzk1ODY_size_16_color_FFFFFF_t_70]: /images/20221120/02a16c5daa584ac5922dad7cce71872e.png