国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 學院 > 開發(fā)設(shè)計 > 正文

redis分布式鎖處理并發(fā)問題

2019-11-14 09:37:01
字體:
供稿:網(wǎng)友

redis鎖處理并發(fā)問題

redis鎖處理高并發(fā)問題十分常見,使用的時候常見有幾種錯誤,和對應(yīng)的解決辦法,在此進行自己的總結(jié)和整理。

set方式setnx方式setnx+getset方式

set方式 作為redis小白,一開始能想到的使用redis加鎖的方式就是set。 加鎖:redis中set一個值,set(lock,1); 并發(fā)處理:其他線程必須拿到這個值,才可以往下進行,否則等待。

while(jedis.exists(lock)){ Thread.sleep(500); } set(lock,1); 執(zhí)行業(yè)務(wù)代碼; jedis.del(lock);

釋放鎖:執(zhí)行完業(yè)務(wù)代碼之后,釋放redis鎖,jedis.del(lock) 防止死鎖:set(lock,1) —>3秒后未釋放,則自動釋放setex(lock, 3, 1) 問題:高并發(fā)情況下,進程同時獲取鎖狀態(tài)為null,同時設(shè)置,鎖之間相互覆蓋,但是倆進程仍在并發(fā)執(zhí)行業(yè)務(wù)代碼。 setnx方式 后來發(fā)現(xiàn)有setnx的原子操作命令,鎖存在不能設(shè)置值,返回0;鎖不存在,則設(shè)置鎖,返回1; 加鎖:jedis.setnx(lock, 1) 并發(fā)處理:

while(jedis.setnx(lock,1)==0){ Thread.sleep(300);}執(zhí)行業(yè)務(wù)代碼;jedis.del(lock);

釋放鎖:執(zhí)行完業(yè)務(wù)代碼之后,釋放redis鎖,jedis.del(lock) 問題:當進程執(zhí)行出現(xiàn)問題,鎖未釋放,則其他進程永遠處于阻塞狀態(tài),出現(xiàn)死鎖。 防止死鎖:加鎖時帶上時間戳,setnx(lock, 時間戳+超時時間)

while(jedis.setnx(lock,now+超時時間)==0){ if(jedis.get(lock)<now){ jedis.del(lock); jedis.setnx(lock,now+超時時間); break; }else{ Thread.sleep(300); } } 執(zhí)行業(yè)務(wù)代碼; jedis.del(lock);

問題:當倆進程同時讀到發(fā)現(xiàn)鎖超時,都去釋放鎖,相互覆蓋,則倆進程同時獲得鎖,仍并發(fā)執(zhí)行業(yè)務(wù)代碼。 setnx+getset方式 為解決上面的問題,可以使用getset命令,getset設(shè)置鍵值,并返回原來的鍵值。 加鎖:setnx(lock, 時間戳+超時時間) 解決并發(fā):

while(jedis.setnx(lock, now+超時時間)==0){ if(now>jedis.get(lock) && now>jedis.getset(lock, now+超時時間)){ break; }else{ Thread.sleep(300); }}執(zhí)行業(yè)務(wù)代碼;jedis.del(lock);

釋放鎖:jedis.del(lock);


發(fā)表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發(fā)表
主站蜘蛛池模板: 茶陵县| 达州市| 夏河县| 永川市| 宁阳县| 哈密市| 阜康市| 河南省| 宾川县| 苍梧县| 西昌市| 米脂县| 凤台县| 环江| 双鸭山市| 长宁县| 珲春市| 柯坪县| 壤塘县| 阿图什市| 保康县| 河东区| 定陶县| 光泽县| 南通市| 婺源县| 沁阳市| 菏泽市| 扶余县| 康保县| 蒲江县| 丰顺县| 丹东市| 彰化县| 绥江县| 福建省| 湟中县| 酒泉市| 阿拉善盟| 那坡县| 石台县|