redis分布式锁实现原理是什么


本文摘自PHP中文网,作者醉折花枝作酒筹,侵删。

借助于redis中的命令setnx(key, value),key不存在就新增,存在就什么都不做。同时有多个客户端发送setnx命令,只有一个客户端可以成功,返回1(true);其他的客户端返回0(false)。

本教程操作环境:windows7系统、Redis5.0.10版、DELL G3电脑。

分布式锁的实现

随着业务发展的需要,原单体单机部署的系统被演化成分布式集群系统后,由于分布式系统多线程、多进程并且分布在不同机器上,这将使原单机部署情况下的并发控制锁策略失效,单纯的Java API并不能提供分布式锁的能力。为了解决这个问题就需要一种跨JVM的互斥机制来控制共享资源的访问,这就是分布式锁要解决的问题!

分布式锁主流的实现方案:

  • 基于数据库实现分布式锁

  • 基于缓存(Redis等)

  • 基于Zookeeper

这里,我们就基于redis实现分布式锁。

基本实现

借助于redis中的命令setnx(key, value),key不存在就新增,存在就什么都不做。同时有多个客户端发送setnx命令,只有一个客户端可以成功,返回1(true);其他的客户端返回0(false)。

)OP_49E}STG[G]]GB(0PT$S.png

主要使用Redis Setnx 命令

在指定的 key 不存在时,为 key 设置指定的值

设置成功,返回 1 。 设置失败,返回 0

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

redis> EXISTS job                # job 不存在

 

(integer) 0

 

  

 

redis> SETNX job "programmer"    # job 设置成功

 

(integer) 1

 

  

 

redis> SETNX job "code-farmer"   # 尝试覆盖 job ,失败

 

(integer) 0

 

  

 

redis> GET job                   # 没有被覆盖

 

"programmer"

java代码

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

    public void testLock() {

 

        // 执行redis的setnx命令

 

        String uuid = UUID.randomUUID().toString();

 

        Boolean lock = redisTemplate.opsForValue().setIfAbsent("lock", uuid, 5, TimeUnit.SECONDS);

 

  

 

        // 判断是否拿到锁

 

        if (lock) {

 

            // 执行业务逻辑代码

 

            // ...

 

  

 

            // 释放锁资源 (保证获取值和删除操作的原子性) LUA脚本保证删除的原子性

 

            String script = "if redis.call('get', KEYS[1]) == ARGV[1] then

 return redis.call('del', KEYS[1]) else return 0 end";

 

            this.redisTemplate.execute(new DefaultRedisScript<>(script),

Arrays.asList("lock"), Arrays.asList(uuid));

 

//          if (StrUtil.equals(uuid,redisTemplate.opsForValue().get("lock"))){

 

//              redisTemplate.delete("lock");

 

//          }

 

        } else {

 

            // 其他请求尝试获取锁

 

            testLock();

 

        }

 

    }

为了确保分布式锁可用,我们至少要确保锁的实现同时满足以下四个条件:

互斥性。在任意时刻,只有一个客户端能持有锁。

不会发生死锁。即使有一个客户端在持有锁的期间崩溃而没有主动解锁,也能保证后续其他客户端能加锁。

解铃还须系铃人。加锁和解锁必须是同一个客户端,客户端自己不能把别人加的锁给解了。

相关教程推荐:Redis教程

以上就是redis分布式锁实现原理是什么的详细内容,更多文章请关注木庄网络博客

相关阅读 >>

为什么Redis是单线程的

实现从Redis中订阅消息转发到 websocket 客户端

Redis性能测试与客户端连接详解

为什么要使用Redis

Redis最多缓存多少数据

Redis怎么进行主从复制

Redis怎么存session

Redis实战之限制操作频率

Redis生存时间设置

Redis如何与mysql保持一致性

更多相关阅读请进入《Redis》频道 >>


数据库系统概念 第6版
书籍

数据库系统概念 第6版

机械工业出版社

本书主要讲述了数据模型、基于对象的数据库和XML、数据存储和查询、事务管理、体系结构等方面的内容。



打赏

取消

感谢您的支持,我会继续努力的!

扫码支持
扫码打赏,您说多少就多少

打开支付宝扫一扫,即可进行扫码打赏哦

分享从这里开始,精彩与您同在

评论

管理员已关闭评论功能...