1.數(shù)據(jù)庫表

a.庫存表

CREATE TABLE `stock` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `name` varchar(50) NOT NULL DEFAULT '' COMMENT '名稱',
  `count` int(11) NOT NULL COMMENT '庫存',
  `sale` int(11) NOT NULL COMMENT '已售',
  `version` int(11) NOT NULL COMMENT '樂觀鎖，版本號',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8

b.訂單表

CREATE TABLE `stock_order` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `sid` int(11) NOT NULL COMMENT '庫存ID',
  `name` varchar(30) NOT NULL DEFAULT '' COMMENT '商品名稱',
  `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '創(chuàng)建時(shí)間',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1072 DEFAULT CHARSET=utf8

2.訂單服務(wù)類

package com.allen.modules.api.service;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import javax.annotation.Resource;

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.allen.modules.api.bo.OrderInfo;
import com.allen.modules.api.dao.StockMapper;
import com.allen.modules.api.dao.StockOrderMapper;
import com.allen.modules.api.po.Stock;
import com.allen.modules.api.po.StockOrder;

@Service
@Transactional
public class OrderInfoService {
    
    @Resource
    private StockMapper stockMapper;
    
    @Resource
    private StockOrderMapper stockOrderMapper;
    
    /**
     * 下單服務(wù)
     */
    public Integer createOrder(Integer sid){
        //檢查庫存
        Stock stock=this.checkStock(sid);
        
        //扣減庫存
        //this.saleStock(stock);
        
        //扣減庫存（樂觀鎖）（防止超賣）
        this.saleStockByCAS(stock);

        //下單
        return this.newOrder(stock);
    }
    
    /**
     * 檢查庫存
     */
    public Stock checkStock(Integer sid){
        Stock stock=this.stockMapper.selectByPrimaryKey(sid);
        if(stock.getCount().compareTo(stock.getSale())<=0){
            throw new RuntimeException("庫存不足!");
        }
        return stock;
    }
    
    /**
     * 扣減庫存(常規(guī)方式，會出現(xiàn)超賣情況)
     */
    public void saleStock(Stock stock){
        Stock updateEntity=new Stock();
        updateEntity.setSale(stock.getSale()+1);
        updateEntity.setId(stock.getId());
        this.stockMapper.updateByPrimaryKeySelective(updateEntity);
    }
    
    /**
     * 扣減庫存（樂觀鎖）
     */
    public void saleStockByCAS(Stock stock){
        Stock updateEntity=new Stock();
        updateEntity.setSale(stock.getSale()+1);
        updateEntity.setId(stock.getId());
        updateEntity.setVersion(stock.getVersion());
        int count=this.stockMapper.updateByCAS(updateEntity);
        if(count==0)
            throw new RuntimeException("并發(fā)更新失敗!");
    }
    
    /**
     * 下單
     */
    public Integer newOrder(Stock stock){
        StockOrder order=new StockOrder();
        order.setSid(stock.getId());
        order.setName(stock.getName());
        order.setCreateTime(new Date());
        return this.stockOrderMapper.insertSelective(order);
    }
}

3.庫存持久化類

package com.allen.modules.api.dao;

import com.allen.modules.api.po.Stock;

public interface StockMapper {
    
    int deleteByPrimaryKey(Integer id);

    int insert(Stock record);

    int insertSelective(Stock record);

    Stock selectByPrimaryKey(Integer id);

    int updateByPrimaryKeySelective(Stock record);

    int updateByPrimaryKey(Stock record);
    
    /**
     * 根據(jù)樂觀鎖更新
     */
    int updateByCAS(Stock record);
}

4.Mybatis樂觀鎖更新庫存SQL

<!-- 根據(jù)樂觀鎖更新 -->
  <update id="updateByCAS" parameterType="com.allen.modules.api.po.Stock" >
    update stock
    <set >
      <if test="name != null" >
        name = #{name,jdbcType=VARCHAR},
      </if>
      <if test="count != null" >
        count = #{count,jdbcType=INTEGER},
      </if>
      <if test="sale != null" >
        sale = #{sale,jdbcType=INTEGER},
      </if>
      version = version+1
    </set>
    where id = #{id,jdbcType=INTEGER} and version = #{version,jdbcType=INTEGER}
  </update>

5.API代碼

    /**
     * 下單
     */
    @RequestMapping(value="/api/order/create",method=RequestMethod.POST)
    @ResponseBody
    public Result<Object> createOrder(@RequestBody CreateOrder request){
        return new Result<>(this.orderInfoService.createOrder(request.getSid()));
    }