基于redis實(shí)現(xiàn)的鎖（用于控制nodejs的并發(fā)）

NervosNetwork 發(fā)布于2019-06-26 17:00 / 3373人閱讀

摘要：場(chǎng)景使用搭建應(yīng)用時(shí)，常常遇到并發(fā)問題導(dǎo)致創(chuàng)建一條數(shù)據(jù)的時(shí)候會(huì)同時(shí)創(chuàng)建多條。通過方法配合選項(xiàng)即可實(shí)現(xiàn)鎖機(jī)制。主要的方法有三個(gè)加鎖解鎖更改鎖過期時(shí)間用法支持實(shí)現(xiàn)比較簡(jiǎn)單，行內(nèi)，有興趣的可以在這里查看源碼

場(chǎng)景：使用node+mongo搭建web應(yīng)用時(shí)，常常遇到并發(fā)問題導(dǎo)致創(chuàng)建一條數(shù)據(jù)的時(shí)候會(huì)同時(shí)創(chuàng)建多條。

通過redis set 方法配合 ‘NX’ 選項(xiàng)即可實(shí)現(xiàn)鎖機(jī)制。

主要的方法有三個(gè)：

lock(加鎖)

unlock(解鎖)

extend(更改鎖過期時(shí)間)

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.

實(shí)現(xiàn)比較簡(jiǎn)單，100行內(nèi)，有興趣的可以在這里https://github.com/navyxie/redlock-node 查看源碼

GPU云服務(wù)器云服務(wù)器免費(fèi)基于角色的訪問控制 java高并發(fā)的控制基于c語言的控制算法 webrtc基于gcc的擁塞控制

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/18834.html

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

NervosNetwork

男|高級(jí)講師

我要關(guān)注我要私信

TA的文章

Hostodo：2核/3G/30G NVMe/5T/1Gbps/美國(guó)多機(jī)房/年付$45，多款優(yōu)惠套餐

閱讀 476·2021-10-09 09:57
CSS偽元素（content與counter）

閱讀 483·2019-08-29 18:39
頁面架構(gòu)HTML+CSS ヾ(o???)? 常用居中&多列布局

閱讀 820·2019-08-29 12:27
邊距重疊以及解決方案BFC

閱讀 3036·2019-08-26 11:38
小程序爬坑記

閱讀 2674·2019-08-26 11:37
通過實(shí)例學(xué)習(xí)正則表達(dá)式

閱讀 1300·2019-08-26 10:59
Vue——(1)父?jìng)髯?，子傳?傳值)

閱讀 1387·2019-08-26 10:58
Vue項(xiàng)目?jī)?yōu)化

閱讀 996·2019-08-26 10:48

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來選購(gòu)！

基于redis實(shí)現(xiàn)的鎖（用于控制nodejs的并發(fā)）

相關(guān)文章