摘要:場景使用搭建應用時,常常遇到并發問題導致創建一條數據的時候會同時創建多條。通過方法配合選項即可實現鎖機制。主要的方法有三個加鎖解鎖更改鎖過期時間用法支持實現比較簡單,行內,有興趣的可以在這里查看源碼
場景:使用node+mongo搭建web應用時,常常遇到并發問題導致創建一條數據的時候會同時創建多條。
通過redis set 方法 配合 ‘NX’ 選項即可實現鎖機制。
主要的方法有三個:
lock(加鎖)
unlock(解鎖)
extend(更改鎖過期時間)
Redlock.prototype.lock = function(resource,ttl,callback){ var self = this; var _val = _random(); return new Promise(function(resolve, reject) { var lock = new Lock(self, resource, _val); self.client.SET(resource,_val,"EX",ttl,"NX",function(err,data){ if(!err && data === "OK"){ return resolve(lock); }else{ var err = err || "resource: "+resource+" is locked."; self.emit("lockError", err); return reject(err); } }) }).asCallback(callback); }
Redlock.prototype.unlock = function(lock,callback){ var self = this; return new Promise(function(resolve, reject) { if(typeof lock !== "object") return reject("unlockError:lock is not object."); self.client.GET(lock.resource,function(err,data){ if(!err && data === lock.value){ self.client.DEL(lock.resource,function(err){ if(err){ self.emit("unlockError",err); return reject("unlockError:"+err); }else{ return resolve(lock); } }) }else{ self.emit("unlockError",err || "resource:" + lock.resource + " unable to unlock.") return reject("unlockError:" + err || ("resource:" + lock.resource + " unable to unlock.")); } }) }).asCallback(callback); }
Redlock.prototype.extend = function(lock,ttl,callback){ var self = this; return new Promise(function(resolve, reject){ if(typeof lock !== "object") return reject("unlockError:lock is not object."); self.client.GET(lock.resource,function(err,data){ if(!err && data === lock.value){ self.client.expire(lock.resource,ttl,function(err,data){ if(!err && data === 1){ return resolve(lock); }else{ self.emit("extendError", err); return reject("extendError:"+err); } }); }else{ self.emit("extendError", err); return reject("extendError:"+err); } }) }).asCallback(callback); }用法
var client = require("redis").createClient("port","host"); var redlock = new RedLock(client); var lock; `callback`: //lock redlock.lock("test-resource-lock",3,function(err,lockInstance){ lock = lockInstance; done(err); }); //unlock redlock.unlock(lock,function(err,data){ done(err); }); `promise`: redlock.lock("test-resource-lock-promise",3).done( function(lock){ //todo redlock.unlock(lock); }, function(){ } )
PS:支持callback and promise.
實現比較簡單,100行內,有興趣的可以在 這里https://github.com/navyxie/redlock-node 查看源碼
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/18834.html
摘要:場景使用搭建應用時,常常遇到并發問題導致創建一條數據的時候會同時創建多條。通過方法配合選項即可實現鎖機制。主要的方法有三個加鎖解鎖更改鎖過期時間用法支持實現比較簡單,行內,有興趣的可以在這里查看源碼 場景:使用node+mongo搭建web應用時,常常遇到并發問題導致創建一條數據的時候會同時創建多條。 通過redis set 方法 配合 ‘NX’ 選項即可實現鎖機制。 主要的方法有三個...
摘要:分布式鎖實現方式前言目前幾乎很多大型網站及應用都是分布式部署的,分布式場景中的數據一致性問題一直是一個比較重要的話題。基于數據庫實現分布式鎖基于緩存等實現分布式鎖基于實現分布式鎖。 前言 分布式鎖,是控制分布式系統之間同步訪問共享資源的一種方式 在分布式系統中,常常需要協調他們的動作。如果不同的系統或是同一個系統的不同主機之間共享了一個或一組資源,那么訪問這些資源的時候,往往需要互斥...
摘要:分布式鎖實現方式前言目前幾乎很多大型網站及應用都是分布式部署的,分布式場景中的數據一致性問題一直是一個比較重要的話題。基于數據庫實現分布式鎖基于緩存等實現分布式鎖基于實現分布式鎖。 前言 分布式鎖,是控制分布式系統之間同步訪問共享資源的一種方式 在分布式系統中,常常需要協調他們的動作。如果不同的系統或是同一個系統的不同主機之間共享了一個或一組資源,那么訪問這些資源的時候,往往需要互斥...
閱讀 466·2021-10-09 09:57
閱讀 470·2019-08-29 18:39
閱讀 811·2019-08-29 12:27
閱讀 3028·2019-08-26 11:38
閱讀 2667·2019-08-26 11:37
閱讀 1286·2019-08-26 10:59
閱讀 1377·2019-08-26 10:58
閱讀 989·2019-08-26 10:48