快捷導(dǎo)航

基于Django的樂(lè)觀鎖與悲觀鎖解決訂單并發(fā)問(wèn)題詳解

更新時(shí)間：2019年07月31日 10:33:33 作者：躬耕于數(shù)

這篇文章主要介紹了基于Django的樂(lè)觀鎖與悲觀鎖解決訂單并發(fā)問(wèn)題詳解,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

前言

訂單并發(fā)這個(gè)問(wèn)題我想大家都是有一定認(rèn)識(shí)的，這里我說(shuō)一下我的一些淺見(jiàn)，我會(huì)盡可能的讓大家了解如何解決這類問(wèn)題。

在解釋如何解決訂單并發(fā)問(wèn)題之前，需要先了解一下什么是數(shù)據(jù)庫(kù)的事務(wù)。(我用的是mysql數(shù)據(jù)庫(kù),這里以mysql為例)

1) 事務(wù)概念

一組mysql語(yǔ)句，要么執(zhí)行，要么全不不執(zhí)行。

2) mysql事務(wù)隔離級(jí)別

Read Committed（讀取提交內(nèi)容）

如果是Django2.0以下的版本，需要去修改到這個(gè)隔離級(jí)別，不然樂(lè)觀鎖操作時(shí)無(wú)法讀取已經(jīng)被修改的數(shù)據(jù)

RepeatableRead（可重讀）

這是這是Mysql默認(rèn)的隔離級(jí)別，可以到mysql的配置文件中去修改；

transcation-isolation = READ-COMMITTED

在mysql配置文件中添加這行然后重啟mysql就可以將事務(wù)隔離級(jí)別修改至Read Committed

其他事務(wù)知識(shí)這里不會(huì)用到就不浪費(fèi)時(shí)間去做介紹了。

悲觀鎖：開(kāi)啟事務(wù)，然后給mysql的查詢語(yǔ)句最后加上for update。

這是在干什么呢。可能大家有些不理解，其實(shí)就是給資源加上和多線程中加互斥鎖一樣的東西，確保在一個(gè)事務(wù)結(jié)束之前，別的事務(wù)無(wú)法對(duì)該數(shù)據(jù)進(jìn)行操作。

下面是悲觀鎖的代碼，加鎖和解鎖都是需要消耗CPU資源的，所以在訂單并發(fā)少的情況使用樂(lè)觀鎖會(huì)是一個(gè)更好的選擇。

class OrderCommitView(View):
  """悲觀鎖"""
  # 開(kāi)啟事務(wù)裝飾器
  @transaction.atomic
  def post(self,request):
    """訂單并發(fā) ———— 悲觀鎖"""
    # 拿到商品id
    goods_ids = request.POST.getlist('goods_ids')
 
    # 校驗(yàn)參數(shù)
    if len(goods_ids) == 0 :
      return JsonResponse({'res':0,'errmsg':'數(shù)據(jù)不完整'}) 
    # 當(dāng)前時(shí)間字符串
    now_str = datetime.now().strftime('%Y%m%d%H%M%S') 
    # 訂單編號(hào)
    order_id = now_str + str(request.user.id)
    # 地址
    pay_method = request.POST.get('pay_method')
    # 支付方式
    address_id = request.POST.get('address_id')
    try:
      address = Address.objects.get(id=address_id)
    except Address.DoesNotExist:
      return JsonResponse({'res':1,'errmsg':'地址錯(cuò)誤'}) 
    # 商品數(shù)量
    total_count = 0
    # 商品總價(jià)
    total_amount = 0 
     # 獲取redis連接
    conn = get_redis_connection('default')
    # 拼接key
    cart_key = 'cart_%d' % request.user.id  
    #
    # 創(chuàng)建保存點(diǎn)
    sid = transaction.savepoint() 
    order_info = OrderInfo.objects.create(
      order_id = order_id,
      user = request.user,
      addr = address,
      pay_method = pay_method,
      total_count = total_count,
      total_price = total_amount
    ) 
    for goods_id in goods_ids:
      # 嘗試查詢商品
      # 此處考慮訂單并發(fā)問(wèn)題,
      try:
        # goods = Goods.objects.get(id=goods_id) # 不加鎖查詢
        goods = Goods.objects.select_for_update().get(id=goods_id) # 加互斥鎖查詢
      except Goodsgoods.DoesNotExist:
        # 回滾到保存點(diǎn)
        transaction.rollback(sid)
        return JsonResponse({'res':2,'errmsg':'商品信息錯(cuò)誤'})
      # 取出商品數(shù)量
      count = conn.hget(cart_key,goods_id)
      if count is None:
        # 回滾到保存點(diǎn)
        transaction.rollback(sid)
        return JsonResponse({'res':3,'errmsg':'商品不在購(gòu)物車中'}) 
      count = int(count) 
      if goods.stock < count:
        # 回滾到保存點(diǎn)
        transaction.rollback(sid)
        return JsonResponse({'res':4,'errmsg':'庫(kù)存不足'}) 
      # 商品銷量增加
      goods.sales += count
      # 商品庫(kù)存減少
      goods.stock -= count
      # 保存到數(shù)據(jù)庫(kù)
      goods.save() 
      OrderGoods.objects.create(
        order = order_info,
        goods = goods,
        count = count,
        price = goods.price
      ) 
      # 累加商品件數(shù)
      total_count += count
      # 累加商品總價(jià)
      total_amount += (goods.price) * count 
    # 更新訂單信息中的商品總件數(shù)
    order_info.total_count = total_count
    # 更新訂單信息中的總價(jià)格
    order_info.total_price = total_amount + order_info.transit_price
    order_info.save()
 
    # 事務(wù)提交
    transaction.commit() 
    return JsonResponse({'res':5,'errmsg':'訂單創(chuàng)建成功'})

然后就是樂(lè)觀鎖查詢了，相比悲觀鎖，樂(lè)觀鎖其實(shí)并不能稱為是鎖，那么它是在做什么事情呢。

其實(shí)是在你要進(jìn)行數(shù)據(jù)庫(kù)操作時(shí)先去查詢一次數(shù)據(jù)庫(kù)中商品的庫(kù)存，然后在你要更新數(shù)據(jù)庫(kù)中商品庫(kù)存時(shí)，將你一開(kāi)始查詢到的庫(kù)存數(shù)量和商品的ID一起作為更新的條件，當(dāng)受影響行數(shù)返回為0時(shí)，說(shuō)明沒(méi)有修改成功，那么就是說(shuō)別的進(jìn)程修改了該數(shù)據(jù)，那么你就可以回滾到之前沒(méi)有進(jìn)行數(shù)據(jù)庫(kù)操作的時(shí)候，重新查詢，重復(fù)之前的操作一定次數(shù)，如果超過(guò)你設(shè)置的次數(shù)還是不能修改那么就直接返回錯(cuò)誤結(jié)果。

該方法只適用于訂單并發(fā)較少的情況，如果失敗次數(shù)過(guò)多，會(huì)帶給用戶不良體驗(yàn)，同時(shí)適用該方法要注意數(shù)據(jù)庫(kù)的隔離級(jí)別一定要設(shè)置為Read Committed 。

最好在使用樂(lè)觀鎖之前查看一下數(shù)據(jù)庫(kù)的隔離級(jí)別，mysql中查看事物隔離級(jí)別的命令為

select @@global.tx_isolation;

class OrderCommitView(View):
  """樂(lè)觀鎖"""
  # 開(kāi)啟事務(wù)裝飾器
  @transaction.atomic
  def post(self,request):
    """訂單并發(fā) ———— 樂(lè)觀鎖"""
    # 拿到id
    goods_ids = request.POST.get('goods_ids')
    
    if len(goods_ids) == 0 :
      return JsonResponse({'res':0,'errmsg':'數(shù)據(jù)不完整'})
    # 當(dāng)前時(shí)間字符串
    now_str = datetime.now().strftime('%Y%m%d%H%M%S')
    # 訂單編號(hào)
    order_id = now_str + str(request.user.id)
    # 地址
    pay_method = request.POST.get('pay_method')
    # 支付方式
    address_id = request.POST.get('address_id')
    try:
      address = Address.objects.get(id=address_id)
    except Address.DoesNotExist:
      return JsonResponse({'res':1,'errmsg':'地址錯(cuò)誤'}) 
    # 商品數(shù)量
    total_count = 0
    # 商品總價(jià)
    total_amount = 0
    # 訂單運(yùn)費(fèi)
    transit_price = 10 
    # 創(chuàng)建保存點(diǎn)
    sid = transaction.savepoint() 
    order_info = OrderInfo.objects.create(
      order_id = order_id,
      user = request.user,
      addr = address,
      pay_method = pay_method,
      total_count = total_count,
      total_price = total_amount,
      transit_price = transit_price
    )
    # 獲取redis連接
    goods = get_redis_goodsection('default')
    # 拼接key
    cart_key = 'cart_%d' % request.user.id
 
    for goods_id in goods_ids:
      # 嘗試查詢商品
      # 此處考慮訂單并發(fā)問(wèn)題, 
      # redis中取出商品數(shù)量
      count = goods.hget(cart_key, goods_id)
      if count is None:
        # 回滾到保存點(diǎn)
        transaction.savepoint_rollback(sid)
        return JsonResponse({'res': 3, 'errmsg': '商品不在購(gòu)物車中'})
      count = int(count) 
      for i in range(3):
        # 若存在訂單并發(fā)則嘗試下單三次
        try:
 
          goods = Goodsgoods.objects.get(id=goods_id) # 不加鎖查詢
          # goods = Goodsgoods.objects.select_for_update().get(id=goods_id) # 加互斥鎖查詢
        except Goodsgoods.DoesNotExist:
          # 回滾到保存點(diǎn)
          transaction.savepoint_rollback(sid)
          return JsonResponse({'res':2,'errmsg':'商品信息錯(cuò)誤'}) 
        origin_stock = goods.stock
        print(origin_stock, 'stock')
        print(goods.id, 'id') 
        if origin_stock < count: 
          # 回滾到保存點(diǎn)
          transaction.savepoint_rollback(sid)
          return JsonResponse({'res':4,'errmsg':'庫(kù)存不足'}) 
 
        # # 商品銷量增加
        # goods.sales += count
        # # 商品庫(kù)存減少
        # goods.stock -= count
        # # 保存到數(shù)據(jù)庫(kù)
        # goods.save() 
        # 如果下單成功后的庫(kù)存
        new_stock = goods.stock - count
        new_sales = goods.sales + count
        res = Goodsgoods.objects.filter(stock=origin_stock,id=goods_id).update(stock=new_stock,sales=new_sales)
        print(res)
        if res == 0:
          if i == 2:
            # 回滾
            transaction.savepoint_rollback(sid)
            return JsonResponse({'res':5,'errmsg':'下單失敗'})
          continue
        else:
          break 
      OrderGoods.objects.create(
        order = order_info,
        goods = goods,
        count = count,
        price = goods.price
      ) 
      # 刪除購(gòu)物車中記錄
      goods.hdel(cart_key,goods_id)
      # 累加商品件數(shù)
      total_count += count
      # 累加商品總價(jià)
      total_amount += (goods.price) * count 
    # 更新訂單信息中的商品總件數(shù)
    order_info.total_count = total_count
    # 更新訂單信息中的總價(jià)格
    order_info.total_price = total_amount + order_info.transit_price
    order_info.save() 
    # 事務(wù)提交
    transaction.savepoint_commit(sid) 
    return JsonResponse({'res':6,'errmsg':'訂單創(chuàng)建成功'})

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: