2019-01-13

背景描述

目前使用redis的主要框架有：
Jedis：使用阻塞的I/O，且其方法调用都是同步的。Jedis客户端实例不是线程安全的，所以需要通过连接池来使用Jedis。
Redisson：基于Netty框架。支持更多数据结构，分布式锁实现了JDK中的Lock接口。
Lettuce：不了解。

常见用法

1.分布式锁
2.计数器
3.消息队列
以下省略。。。

注意事项

1.持久化键
不建议使用
2.分布式锁
缺陷多，没有完美的分布式锁，有更适合场景的分布式锁
3.缓存穿透
推荐使用数据库查不到的数据设置null值，并设置较短的存活时间
4.缓存雪崩
方案a)：设置存活时间时加上随机性
方案b)：剩余存活时间较小时,主动触发一次数据库查询然后更新缓存

代码演示

• 演示分布式锁

高版本redis
可以直接使用set命令 SET key value EX 400 NX
低版本redis
使用SETNX和EXPIRE,并且需要考虑到死锁情况
注意事项
1.在任意时刻，只有一个客户端能持有锁。
2.客户端在持有锁的期间崩溃而没有主动解锁，也能保证后续其他客户端能加锁。（死锁问题）
3.解锁时不能把别人加的锁给解了
PS:实现redis分布式锁的方式多样，如在setnx时把值设置为过期时间等。本文示例使用的是低版本的redis，使用setnx把值设置为随机值（解决问题1和3），随后使用setnxAndForceExpire方法来设置持久化键的存活时间（解决问题2）。

一个粘贴即用的Jedis分布式锁是这样

/**
 * 使用redis实现的分布式锁
 */
public class Lock {
    private static Jedis jedis = RedisPool.getJedis();
    private String key;
    private String uuid;
    private Lock(String key, String uuid) {
        this.uuid = uuid;
        this.key = key;
    }
    /**
     * setnx
     */
    private static boolean setnxAndForceExpire(String key, String value, int seconds) {
            long result = jedis.setnx(key, value);
        forceExpire(key, seconds);
        return result == 1;
    }
    /**
     * 强制取消持久化键
     */
    private static void forceExpire(String key, int seconds) {
        if (jedis.exists(key) && jedis.ttl(key) < 0) {
            jedis.expire(key, seconds);
        }
    }
    /**
     * 获取分布式锁
     */
    public static Lock getlock(String key, int expireTimeSec,long waitTimeSec) {
        long startTime = System.nanoTime();
        String uuid = UUID.randomUUID().toString();
        while (true) {
            if (setnxAndForceExpire(key, uuid, expireTimeSec)) {
                break;
            }
            try {
                //可以适当控制时间间隔大小
                Thread.sleep(100);
                if (System.nanoTime() - startTime > waitTimeSec*1000000) {
                    throw new TimeoutException("获取锁" + key + "超时");
                }
            } catch (Exception e) {
                throw new RuntimeException(e);
            }
        }
        return new Lock(key, uuid);
    }
    /**
     * 释放分布式锁
     */
    public void releaseLock() {
            String value = jedis.get(key);
            if (uuid.equals(value)) {
                jedis.del(key);
            }
    }

}

待更新...
a)演示解决持久化键
b)演示解决缓存穿透
c)演示解决缓存雪崩