服务器高并发时请求报错_基于redis的分布式锁防止高并发重复请求
需求:
我們先舉個(gè)某系統(tǒng)驗(yàn)證的列子:(A渠道系統(tǒng),業(yè)務(wù)B系統(tǒng),外部廠商C系統(tǒng))
(1)B業(yè)務(wù)系統(tǒng)調(diào)用A渠道系統(tǒng),驗(yàn)證傳入的手機(jī)、身份證、姓名三要素是否一致。
(2)A渠道系統(tǒng)再調(diào)用外部廠商C系統(tǒng)。
(3)A渠道系統(tǒng)將結(jié)果返回給B業(yè)務(wù)系統(tǒng)。
這3個(gè)過程中,(2)過程,調(diào)用外部廠商是需要計(jì)費(fèi)的。
當(dāng)B業(yè)務(wù)系統(tǒng)并發(fā)量很高時(shí),有100筆相同的三要素校驗(yàn),由于是相同的三要素,A渠道只要調(diào)用一次廠商即可知道結(jié)果。為了防止在某一請求還沒響應(yīng)結(jié)束的同時(shí),其他請求也去調(diào)用外部系統(tǒng),這個(gè)時(shí)候就需要加鎖處理
分布式鎖的特點(diǎn)
原子性:同一時(shí)刻,只能有一個(gè)機(jī)器的一個(gè)線程得到鎖;
可重入性:同一對象(如線程、類)可以重復(fù)、遞歸調(diào)用該鎖而不發(fā)生死鎖;
可阻塞:在沒有獲得鎖之前,只能阻塞等待直至獲得鎖;
高可用:哪怕發(fā)生程序故障、機(jī)器損壞,鎖仍然能夠得到被獲取、被釋放;
高性能:獲取、釋放鎖的操作消耗小。
要實(shí)現(xiàn):加鎖,減鎖,鎖超時(shí)
實(shí)現(xiàn)方式可以是:數(shù)據(jù)庫 mc redis 系統(tǒng)文件 zookeeper
我現(xiàn)在就是渠道系統(tǒng),當(dāng)100個(gè)相同的業(yè)務(wù)請求傳遞過來,我的第一個(gè)請求要先加鎖,然后請求外部廠商系統(tǒng),等響應(yīng)結(jié)果以后,插入另一個(gè)key中,然后再刪除鎖。
其他請求先去獲取下鎖,如果已經(jīng)存在鎖就輪尋等待,如果鎖不在了,直接去查詢結(jié)果。
如果第一個(gè)請求失敗了,結(jié)果并沒有插入到位,就繼續(xù)獲取鎖再去查詢外部系統(tǒng)。
獲取鎖:
$redis->set('lock:手機(jī)號(hào)&身份證&姓名', 1, ['nx', 'ex'=>10]);
釋放鎖:
就是直接刪除這個(gè)key
鎖超時(shí):
lock的key有超時(shí)時(shí)間
新版的redis set命令就可以實(shí)現(xiàn)分布式鎖,可以同時(shí)實(shí)現(xiàn)如果不存在時(shí)才去set和超時(shí)時(shí)間兩項(xiàng)。
<?php $redis=new Redis();$redis->connect("127.0.0.1",6379);//高并發(fā)時(shí)防止重復(fù)請求//渠道系統(tǒng)傳遞過來的key$lockKey='lock:18806767777&37781991111629092&taoshihan';$resultKey='res:18806767777&37781991111629092&taoshihan';//如果已經(jīng)查詢過值,可以直接返回$info=$redis->get($resultKey);if($info){ exit($info);}//如果沒有值的,獲取鎖$lock=$redis->set($lockKey, 1, ['nx', 'ex'=>10]);if($lock){ //請求外部系統(tǒng)獲取結(jié)果,比如響應(yīng)結(jié)果比較慢 sleep(8); $info='{"name":"taoshihan"}'; $ret=$redis->set($resultKey,$info); if($ret){ //刪除鎖 $redis->del($lockKey); exit($info); }}echo "請稍后重試!";總結(jié)
以上是生活随笔為你收集整理的服务器高并发时请求报错_基于redis的分布式锁防止高并发重复请求的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: sublime text3安装pytho
- 下一篇: redis五种数据类型的应用场景_Red