分布式缓存获取以及设置

 1. 通用代码

   public SysUser getCache(String sysUserId) {         String cacheKey = "litgery:warehouse:" + sysUserId;         // 尝试从缓存中获取数据         CacheData cacheData = redisUtils.get(cacheKey);         if (null != cacheData) {             if (Boolean.TRUE.equals(cacheData.getExist())) {                 return cacheData.getSysUser();             } else {                 return null;             }         }                  //   RedisLockClient 获取锁         RLock rLock = redisLockClient.getRLock("litgery:warehouse:lock");         try {             // 尝试获取锁，如果锁已被其他线程持有，则等待             rLock.lock();             // 再次检查数据是否存在，因为可能在等待锁的过程中，其他线程已经填充了数据             cacheData = redisUtils.get(cacheKey);             if (null != cacheData && Boolean.TRUE.equals(cacheData.getExist())) {                 return cacheData.getSysUser();             }             //随机过期时间，随机生成0.5小时-1小时之内的时间（减少缓存同时失效的机会）             Long expireTime = CacheUtils.getRandomExpireTimeInOneOrTowDay();                                     SysUser sysUser = sysUserService.getById(sysUserId);             if (null == sysUser) {                 // 如果数据仍然不存在，从数据库中获取数据并填充缓存，避免不存在的数据一直请求打到数据库                 CacheData emptyCache = new CacheData();                 emptyCache.setExist(Boolean.FALSE);                 redisUtils.setEx(cacheKey, emptyCache, expireTime);                 return null;             }             CacheData cache = new CacheData();             cache.setSysUser(sysUser);             cache.setExist(Boolean.TRUE);             redisUtils.setEx(cacheKey, cache, expireTime);             return sysUser;         } finally {             // 释放锁             rLock.unlock();         }     }

 

redisUtils 为redis工具类，例如：设置缓存获取缓存等等。

redisLockClient  为：RedisLockClient 的分布式锁

2.整体步骤

1. 获取缓存，若有值直接返回

2.获取一个分布式锁。

3. 加锁

4. 再次检查数据是否存在，因为可能在等待锁的过程中，其他线程已经填充了数据

5.从数据库获取。若为空，设置一个空值到redis。若不为空，直接返回，最好设置随机过期时间

6.释放锁

可优化的点，可添加布隆过滤器