本文主要是介绍秒杀系统的实现，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
方案一：数据库实现
秒杀系统的实现
按照正常的购买流程：查询商品库存，库存大于0时，生成订单，去库存。如果出现并发，导致在查询商品库存的时候，库存会一直出现大于0的情况，出现超卖现象。
基于mysql的事务和锁实现方式：
- 1：开启事务
- 2：查询库存，并显示的设置写锁（排他锁）：SELECT * FROM table_name WHERE … FOR UPDATE
- 3：生成订单
- 4：去库存，隐示的设置写锁（排他锁）：UPDATE goods SET counts = counts – 1 WHERE id = 1
- 5：commit，释放锁
注意：
如果不开启事务，第二步即使加锁，第一个会话读库存结束后，变会释放锁，第二个会话仍有机会在去库存前读库存，出现超卖。
如果开启事务，第二步不加锁，第一个会话读库存结束后，第二个会话容易出现【脏读】，出现超卖。
即加事务，又加读锁：开启事务，第一个会话读库存时加读锁，并发时，第二个会话也允许获得读库存的读锁，但是在第一个会话执行写操作时，写锁便会等待第二个会话的读锁，第二个会话执行写操作时，写锁便会等待第一个会话的读锁，出现死锁
即加事务，又加写锁：第一个会话读库存时加写锁，写锁会阻止其它事务的读锁和写锁。直到commit才会释放，允许第二个会话查询库存，不会出现超卖现象。
方案二：推荐使用redis原子操作+sql乐观锁
利用Redis increment 的原子操作，保证库存数安全
-
先查询redis中是否有库存信息，如果没有就去数据库查，这样就可以减少访问数据库的次数。 获取到后把数值填入redis，以商品id为key，数量为value。 注意要设置序列化方式为StringRedisSerializer，不然不能把value做加减操作。 还需要设置redis对应这个key的超时时间，以防所有商品库存数据都在redis中。
-
比较下单数量的大小，如果够就做后续逻辑。
-
执行redis客户端的increment，参数为负数，则做减法。因为redis是单线程处理，并且因为increment让key对应的value 减少后返回的是修改后的值。 有的人会不做第一步查询直接减，其实这样不太好，因为当库存为1时，很多做减3，或者减30情况，其实都是不够，这样就白减。
-
扣减数据库的库存，这个时候就不需要再select查询，直接乐观锁update，把库存字段值减1 。
-
做完扣库存就在订单系统做下单。
public void order(OrderReq req) {String key = "product:" + req.getProductId();// 第一步：先检查 库存是否充足Integer num = (Integer) redisTemplate.get(key);if (num == null){// 去查数据库的数据// 并且把数据库的库存set进redis，注意使用NX参数表示只有当没有redis中没有这个key的时候才set库存数量到redis//注意要设置序列化方式为StringRedisSerializer，不然不能把value做加减操作// 同时设置超时时间，因为不能让redis存着所有商品的库存数，以免占用内存。if (count >=0) {//设置有效期十分钟redisTemplate.expire(key, 60*10+随机数防止雪崩, TimeUnit.SECONDS);}// 减少经常访问数据库，因为磁盘比内存访问速度要慢}if (num < req.getNum()) {logger.info("库存不足");}// 第二步：减少库存long value = redisTemplate.increment(key, -req.getNum().longValue());// 库存充足if (value >= 0) {logger.info("成功购买");// update 数据库中商品库存和订单系统下单，单的状态未待支付// 分开两个系统处理时，可以用LCN做分布式事务，但是也是有概率会订单系统的网络超时// 也可以使用最终一致性的方式，更新库存成功后，发送mq，等待订单创建生成回调。boolean res= updateProduct(req);if (res)createOrder(req);} else {// 减了后小小于0 ，如两个人同时买这个商品，导致A人第一步时看到还有10个库存，但是B人买9个先处理完逻辑，// 导致B人的线程10-9=1, A人的线程1-10=-9，则现在需要增加刚刚减去的库存，让别人可以买1个redisTemplate.increment(key, req.getNum().longValue());logger.info("恢复redis库存");}}
这篇关于秒杀系统的实现的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
