基于redis实现的分布式锁

我们知道，在多线程环境中，锁是实现共享资源互斥访问的重要机制，以保证任何时刻只有一个线程在访问共享资源。锁的基本原理是：用一个状态值表示锁，对锁的占用和释放通过状态值来标识，因此基于redis实现的分布式锁主要依赖redis的SETNX命令和DEL命令，SETNX相当于上锁，DEL相当于释放锁，当然，在下面的具体实现中会更复杂些。之所以称为分布式锁，是因为客户端可以在redis集群环境中向集群中任一个可用Master节点请求上锁（即SETNX命令存储key到redis缓存中是随机的）。

现在相信你已经对在基于redis实现的分布式锁的基本概念有了解，需要注意的是，这个和前面文章提到的使用WATCH 命令对key值进行锁操作没有直接的关系。java中synchronized和Lock对象都能对共享资源进行加锁，下面我们将学习用java实现的redis分布式锁。

java中的锁技术

在分析java实现的redis分布式锁之前，我们先来回顾下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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
public class LockTest {
    //不加锁
    static class Outputer {
        public void output(String name) {
            for(int i=0; i<name.length(); i++) {
                System.out.print(name.charAt(i));
            }
            System.out.println();
        }
    }
    public static void main(String[] args) {
        final Outputer output = new Outputer();
        //线程1打印zhangsan
        new Thread(new Runnable(){
            @Override
            public void run() {
                while(true) {
                     try{
                         Thread.sleep(1000);
                     }catch(InterruptedException e) {
                         e.printStackTrace();
                     }
                     output.output("zhangsan");
                }  
            }
        }).start();
         
        //线程2打印lingsi
        new Thread(new Runnable(){
            @Override
            public void run() {
                while(true) {
                     try{
                         Thread.sleep(1000);
                     }catch(InterruptedException e) {
                         e.printStackTrace();
                     }
                     output.output("lingsi");
                }
            }
        }).start();
         
        //线程3打印wangwu
        new Thread(new Runnable(){
            @Override
            public void run() {
                while(true) {
                     try{
                         Thread.sleep(1000);
                     }catch(InterruptedException e) {
                         e.printStackTrace();
                     }
                     output.output("huangwu");
                }
            }
        }).start();
    }
}

上面例子中，三个线程同时共享输出设备output，线程1需要打印zhangsan，线程2需要打印lingsi，线程3需要打印wangwu。在不加锁的情况，这三个线程会不会因为得不到输出设备output打架呢，我们来看看运行结果：

1
2
3
4
5
6
7
8
9
10
11
huangwu
zhangslingsi
an
huangwu
zlingsi
hangsan
huangwu
lzhangsan
ingsi
huangwu
lingsi

　　

从运行结果可以看出，三个线程打架了，线程1没打印完zhangsan，线程2就来抢输出设备......可见，这不是我们想要的，我们想要的是线程之间能有序的工作，各个线程之间互斥的使用输出设备output。

http://www.cnblogs.com/hjwublog/p/5749929.html

https://my.oschina.net/91jason/blog/517996?p=1

最新文章

  1. TRUNCATE TABLE (Transact-SQL)
  2. TypeScript - Classes
  3. 【POJ 2250】Compromise(最长公共子序列LCS)
  4. iOS CALayer动画中使用的3个tree
  5. HTML标签_Form
  6. &lt;c:if&gt;判断两个&lt;c:forEach&gt;里的数据是否相等
  7. 每天一个Linux命令（18）--locate命令
  8. KafKa介绍（分布式架构）
  9. Hadoop的safeMode
  10. Python通过future处理并发
  11. shell编程之环境变量配置文件(4)
  12. Java多线程-概念与原理
  13. Windows下NetBeans中文乱码解决办法
  14. Said
  15. python基础之lambda,sort,filter,map,递归函数的运用
  16. Android解决自定义View获取不到焦点的情况
  17. C++Primer，C++标准IO库阅读心得
  18. elasticsearch环境搭建
  19. sgu 137. Funny Strings 线性同余,数论,构造 难度:3
  20. es学习-索引管理

热门文章

  1. java学习笔记_GUI(3)
  2. Windows Phone开发之&rdquo;给我好评&ldquo;
  3. Mysql单实例脚本自动化安装
  4. 1.ssh访问限制
  5. javascript dom追加内容的例子
  6. （转载）SQLServer存储过程返回值总结
  7. 长安铃木经销商爬取（解析xml、post提交、python中使用js代码）
  8. PHP微信开发代码
  9. ViewData，ViewBag和TempData
  10. chm文件打开，有目录没有内容