JAVA高级面试进阶训练营视频教程

admin

引言

　　本文主要描述，服务端做相关秒杀活动的时候，对应的解决方案，即高并发下的数据安全。

优化方案

乐观锁思路

　　Redis中的watch，请求时，通过Redis查询当前抢购数据，如果当前抢购数据已经到达临界值，则直接提示相应的页面/信息，如返回已抢购完的页面。

分布式限流

　　当然，对于很大量的秒杀，可以准备多个Redis实例，用户请求时，可以随机数或者散列取模，找对应实例来进行抢购。

　　采用Redis有一个好处，比如支持很多应用服务器一起抢……

提高吞吐量

　　Nigix反向代理+负载均衡

实现流程

　　其实抛开秒杀这个场景来说正常的一个下单流程可以简单分为以下几步：

• 校验库存
• 扣库存
• 创建订单
• 支付

Transactional(rollbackFor = Exception.class)
@Service(value = "DBOrderService")
public class OrderServiceImpl implements OrderService {
    @Resource(name = "DBStockService")
    private com.crossoverJie.seconds.kill.service.StockService stockService;

    @Autowired
    private StockOrderMapper orderMapper;
    
    @Override
    public int createWrongOrder(int sid) throws Exception{

        //校验库存
        Stock stock = checkStock(sid);

        //扣库存
        saleStock(stock);

        //创建订单
        int id = createOrder(stock);

        return id;
    }
    
    private Stock checkStock(int sid) {
        Stock stock = stockService.getStockById(sid);
        if (stock.getSale().equals(stock.getCount())) {
            throw new RuntimeException("库存不足");
        }
        return stock;
    }
    
    private int saleStock(Stock stock) {
        stock.setSale(stock.getSale() + 1);
        return stockService.updateStockById(stock);
    }
    
    private int createOrder(Stock stock) {
        StockOrder order = new StockOrder();
        order.setSid(stock.getId());
        order.setName(stock.getName());
        int id = orderMapper.insertSelective(order);
        return id;
    }        
        
}

　　其实其他的都没怎么改，主要是 Service 层。

  @Override
    public int createOptimisticOrder(int sid) throws Exception {

        //校验库存
        Stock stock = checkStock(sid);

        //乐观锁更新库存
        saleStockOptimistic(stock);

        //创建订单
        int id = createOrder(stock);

        return id;
    }
    
    private void saleStockOptimistic(Stock stock) {
        int count = stockService.updateStockByOptimistic(stock);
        if (count == 0){
            throw new RuntimeException("并发更新库存失败") ;
        }
    }

　　对应的 XML：

<update id="updateByOptimistic" parameterType="com.crossoverJie.seconds.kill.pojo.Stock">
        update stock
        <set>
            sale = sale + 1,
            version = version + 1,
        </set>

        WHERE id = #{id,jdbcType=INTEGER}
        AND version = #{version,jdbcType=INTEGER}

    </update>

如何保持高并发下数据一致性

　　对多个更新操作的业务加事物注解。在数据库表中加一个vesion版本控制字段（初始值为0)在更新操作前查询并记录该字段，更新操作完成vesion+1,再次查询vesion与更新操作前记录的值相差1说明前后数据一致，否则回滚更新操作