klg-redlock

2019-12-03

klg-redlock是什么

什么是klg-redlock,一个基于 redis 的分布式锁

klg-redlock使用教程帮助文档

klg-redlock

一个基于 redis 的分布式锁

Quick Start

准备好 redis client

let client = redis.createClient('redis://localhost:6379')

排队锁

const bufferLock = new Redlock({
  client,
  retryConfig: {
    retryCount: Math.floor(1000 * 60 * 5 / 400), // 重试次数 这里需要重试一分钟
    retryDelay: 400   // 重试间隔
  }
})

await bufferLock.using(async (lock) => {
    // code
}, {ttl: 1000 * 30, resource: 'key'})

相同 key 的操作会排队执行,遇到冲突会重试,默认重试总时长是 1 分钟,注意重试的实现是非公平的,有可能某个操作会一直无法执行,直至超时。

排他锁

把重试功能关闭就是排它锁了

const mutexLock = new Redlock({
  client,
  retryConfig: {
    retryCount: 0
  }
})

await mutexLock.using(async (lock) => {
    // code
}, {ttl: 1000 * 30, resource: 'key'})

相同 key 的操作具有排他性,遇到冲突会 throw 一个 Error 对象, message 为‘系统繁忙,请稍后再试’

占位锁

去掉自动解锁功能就是占位锁了。

const lockConfig = {
  retryCount: 0,
  retryDelay: 0
}
const ttl = 60*100
const redLock = new Redlock(lockConfig)
try {
    return await redLock.lock(param.message, async function () {
      // code
    }, ttl)
} catch (err) {
    logger.info('lock Error ', err)
    return
}

不管执行成功与否,都不释放锁,等待资源自然到期释放。 应用场景一般是控制单位之间内只做一次操作的业务,例如发送报警短信,10min 内有重复的需要忽略,控制短信发送频率。

Test

$ npm i
$ npm test

上一篇:klg-request
下一篇:klg-mq-koa
相关文章

首次访问,人机识别验证

扫描下方二维码回复 1024 获取验证码,验证完毕后 永久 无须验证

操作步骤:[打开微信]->[扫描上侧二维码]->[关注 FedJavaScript 的微信] 输入 1024 获取验证码

验证码有误,请重新输入