摘要:场景使用搭建应用时,常常遇到并发问题导致创建一条数据的时候会同时创建多条。通过方法配合选项即可实现锁机制。主要的方法有三个加锁解锁更改锁过期时间用法支持实现比较简单,行内,有兴趣的可以在这里查看源码
场景:使用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 查看源码
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/79505.html
摘要:场景使用搭建应用时,常常遇到并发问题导致创建一条数据的时候会同时创建多条。通过方法配合选项即可实现锁机制。主要的方法有三个加锁解锁更改锁过期时间用法支持实现比较简单,行内,有兴趣的可以在这里查看源码 场景:使用node+mongo搭建web应用时,常常遇到并发问题导致创建一条数据的时候会同时创建多条。 通过redis set 方法 配合 ‘NX’ 选项即可实现锁机制。 主要的方法有三个...
摘要:分布式锁实现方式前言目前几乎很多大型网站及应用都是分布式部署的,分布式场景中的数据一致性问题一直是一个比较重要的话题。基于数据库实现分布式锁基于缓存等实现分布式锁基于实现分布式锁。 前言 分布式锁,是控制分布式系统之间同步访问共享资源的一种方式 在分布式系统中,常常需要协调他们的动作。如果不同的系统或是同一个系统的不同主机之间共享了一个或一组资源,那么访问这些资源的时候,往往需要互斥...
摘要:分布式锁实现方式前言目前几乎很多大型网站及应用都是分布式部署的,分布式场景中的数据一致性问题一直是一个比较重要的话题。基于数据库实现分布式锁基于缓存等实现分布式锁基于实现分布式锁。 前言 分布式锁,是控制分布式系统之间同步访问共享资源的一种方式 在分布式系统中,常常需要协调他们的动作。如果不同的系统或是同一个系统的不同主机之间共享了一个或一组资源,那么访问这些资源的时候,往往需要互斥...
阅读 2609·2021-11-18 10:02
阅读 2279·2021-09-30 09:47
阅读 1745·2021-09-27 14:01
阅读 3109·2021-08-16 11:00
阅读 3163·2019-08-30 11:06
阅读 2392·2019-08-29 17:29
阅读 1531·2019-08-29 13:19
阅读 445·2019-08-26 13:54