您好,登錄后才能下訂單哦!
前言
訂單并發(fā)這個(gè)問題我想大家都是有一定認(rèn)識(shí)的,這里我說一下我的一些淺見,我會(huì)盡可能的讓大家了解如何解決這類問題。
在解釋如何解決訂單并發(fā)問題之前,需要先了解一下什么是數(shù)據(jù)庫的事務(wù)。(我用的是mysql數(shù)據(jù)庫,這里以mysql為例)
1) 事務(wù)概念
一組mysql語句,要么執(zhí)行,要么全不不執(zhí)行。
2) mysql事務(wù)隔離級(jí)別
Read Committed(讀取提交內(nèi)容)
如果是Django2.0以下的版本,需要去修改到這個(gè)隔離級(jí)別,不然樂觀鎖操作時(shí)無法讀取已經(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í)間去做介紹了。
悲觀鎖:開啟事務(wù),然后給mysql的查詢語句最后加上for update。
這是在干什么呢??赡艽蠹矣行┎焕斫?,其實(shí)就是給資源加上和多線程中加互斥鎖一樣的東西,確保在一個(gè)事務(wù)結(jié)束之前,別的事務(wù)無法對(duì)該數(shù)據(jù)進(jìn)行操作。
下面是悲觀鎖的代碼,加鎖和解鎖都是需要消耗CPU資源的,所以在訂單并發(fā)少的情況使用樂觀鎖會(huì)是一個(gè)更好的選擇。
class OrderCommitView(View): """悲觀鎖""" # 開啟事務(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ā)問題, 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':'商品不在購物車中'}) count = int(count) if goods.stock < count: # 回滾到保存點(diǎn) transaction.rollback(sid) return JsonResponse({'res':4,'errmsg':'庫存不足'}) # 商品銷量增加 goods.sales += count # 商品庫存減少 goods.stock -= count # 保存到數(shù)據(jù)庫 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)建成功'})
然后就是樂觀鎖查詢了,相比悲觀鎖,樂觀鎖其實(shí)并不能稱為是鎖,那么它是在做什么事情呢。
其實(shí)是在你要進(jìn)行數(shù)據(jù)庫操作時(shí)先去查詢一次數(shù)據(jù)庫中商品的庫存,然后在你要更新數(shù)據(jù)庫中商品庫存時(shí),將你一開始查詢到的庫存數(shù)量和商品的ID一起作為更新的條件,當(dāng)受影響行數(shù)返回為0時(shí),說明沒有修改成功,那么就是說別的進(jìn)程修改了該數(shù)據(jù),那么你就可以回滾到之前沒有進(jìn)行數(shù)據(jù)庫操作的時(shí)候,重新查詢,重復(fù)之前的操作一定次數(shù),如果超過你設(shè)置的次數(shù)還是不能修改那么就直接返回錯(cuò)誤結(jié)果。
該方法只適用于訂單并發(fā)較少的情況,如果失敗次數(shù)過多,會(huì)帶給用戶不良體驗(yàn),同時(shí)適用該方法要注意數(shù)據(jù)庫的隔離級(jí)別一定要設(shè)置為Read Committed 。
最好在使用樂觀鎖之前查看一下數(shù)據(jù)庫的隔離級(jí)別,mysql中查看事物隔離級(jí)別的命令為
select @@global.tx_isolation;
class OrderCommitView(View): """樂觀鎖""" # 開啟事務(wù)裝飾器 @transaction.atomic def post(self,request): """訂單并發(fā) ———— 樂觀鎖""" # 拿到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ā)問題, # redis中取出商品數(shù)量 count = goods.hget(cart_key, goods_id) if count is None: # 回滾到保存點(diǎn) transaction.savepoint_rollback(sid) return JsonResponse({'res': 3, 'errmsg': '商品不在購物車中'}) 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':'庫存不足'}) # # 商品銷量增加 # goods.sales += count # # 商品庫存減少 # goods.stock -= count # # 保存到數(shù)據(jù)庫 # goods.save() # 如果下單成功后的庫存 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 ) # 刪除購物車中記錄 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)建成功'})
以上就是本文的全部內(nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持億速云。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請(qǐng)聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。