资讯专栏INFORMATION COLUMN

基于redis实现的锁(用于控制nodejs的并发)

pkhope / 2687人阅读

摘要:场景使用搭建应用时,常常遇到并发问题导致创建一条数据的时候会同时创建多条。通过方法配合选项即可实现锁机制。主要的方法有三个加锁解锁更改锁过期时间用法支持实现比较简单,行内,有兴趣的可以在这里查看源码

场景:使用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

相关文章

  • 基于redis实现用于控制nodejs并发

    摘要:场景使用搭建应用时,常常遇到并发问题导致创建一条数据的时候会同时创建多条。通过方法配合选项即可实现锁机制。主要的方法有三个加锁解锁更改锁过期时间用法支持实现比较简单,行内,有兴趣的可以在这里查看源码 场景:使用node+mongo搭建web应用时,常常遇到并发问题导致创建一条数据的时候会同时创建多条。 通过redis set 方法 配合 ‘NX’ 选项即可实现锁机制。 主要的方法有三个...

    NervosNetwork 评论0 收藏0
  • 分布式锁机制原理及实现方式

    摘要:分布式锁实现方式前言目前几乎很多大型网站及应用都是分布式部署的,分布式场景中的数据一致性问题一直是一个比较重要的话题。基于数据库实现分布式锁基于缓存等实现分布式锁基于实现分布式锁。 前言 分布式锁,是控制分布式系统之间同步访问共享资源的一种方式 在分布式系统中,常常需要协调他们的动作。如果不同的系统或是同一个系统的不同主机之间共享了一个或一组资源,那么访问这些资源的时候,往往需要互斥...

    yacheng 评论0 收藏0
  • 分布式锁机制原理及实现方式

    摘要:分布式锁实现方式前言目前几乎很多大型网站及应用都是分布式部署的,分布式场景中的数据一致性问题一直是一个比较重要的话题。基于数据库实现分布式锁基于缓存等实现分布式锁基于实现分布式锁。 前言 分布式锁,是控制分布式系统之间同步访问共享资源的一种方式 在分布式系统中,常常需要协调他们的动作。如果不同的系统或是同一个系统的不同主机之间共享了一个或一组资源,那么访问这些资源的时候,往往需要互斥...

    Travis 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<