在java中,咱们能够用synchronized进行加锁,也能够用lock的lock办法加锁和unlock办法开释锁。然而在多个过程或者夸服务器的状况下,这种加锁的形式就没方法用了,因为他没方法让其余客户端的人晓得是否被加锁了。所以咱们能够用redis、zookeeper、etcd等来实现。redis也有相似于lock的乐观锁,在redis - 商品交易中也展现了WATCH的应用,然而当key里的内容足够多时,监控频繁的变动反而导致性能的降落。
java的map,有putIfAbsent办法,意思是如果对应的key曾经赋值了,则不能持续赋值。redis中,也有相似的办法,setnx,SET if Not eXists,也是如果对应的key有值了,则不能持续赋值,所以咱们能够用他这个办法作为分布式锁。

// 锁的keystatic String lockName = "lock:";static int cnt = 1000;static CountDownLatch countDownLatch = new CountDownLatch(cnt);@Testpublic void testLock() throws InterruptedException {    JedisUtils.del(lockName);    // 锁的工夫,达到这个工夫就开释    int lockTime = 1;    // 锁的超时工夫,达到这个工夫就放弃获取    long timeOut = 2500;    for (int i = 0; i < cnt; i++) {        new Thread(new LockThread(i, lockTime, timeOut)).start();        countDownLatch.countDown();    }    TimeUnit.SECONDS.sleep(3);}static class LockThread implements Runnable {    int lockTime;    long timeOut;    int idx;    public LockThread(int idx, int lockTime, long timeOut) {        this.idx = idx;        this.lockTime = lockTime;        this.timeOut = timeOut;    }    @Override    public void run() {        try {            countDownLatch.await();        } catch (InterruptedException e) {            e.printStackTrace();        }        String lock = lock(lockName, lockTime, timeOut);        if (StringUtils.isNotEmpty(lock)) {            System.out.println(idx + ":获取到了锁");            //JedisUtils.del(lockName);        }    }}private static String lock(String lockName, int lockTime, long timeOut) {    long end = System.currentTimeMillis() + timeOut;    String value = UUID.randomUUID().toString();    while (System.currentTimeMillis() < end) {        long setnx = JedisUtils.setnx(lockName, value);        // 1阐明获取锁,返回        if (setnx == 1) {            JedisUtils.expire(lockName, lockTime);            return value;        }        try {            // 没获取则休眠100毫秒持续抢锁            TimeUnit.MILLISECONDS.sleep(100);        } catch (InterruptedException e) {            e.printStackTrace();        }    }    return null;}

失常状况下,下面的分布式锁能够运行的,然而有以下几个问题:

  1. 设置了生效工夫,如果在生效工夫内没执行完,则其余过程就会获取到锁,导致同一时间有多个过程获取同一个锁。
  2. 如果在生效工夫内获取到锁的过程曾经解体,锁仍然得不到开释,导致其余过程仍然在期待生效过期。
  3. 如果只有一个redis服务器,那服务器解体则不能失常运行。如果redis做主从, A过程获取锁,且在主服务器数据未同步到从服务器的时候解体,B过程读取曾经变成主服务器的原从服务器时,因为没有锁又获取到了锁,导致同一时间有多个过程获取同一个锁。