图书信息管理系统后台.zip

package com.biyesheji.bookmanagerservice.utils; import java.util.Collections; import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.TimeUnit; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Component; @Component public class RedisUtils { private static final Logger LOG = LoggerFactory.getLogger(RedisUtils.class); private static RedisTemplate<String, Object> redisTemplate; private static StringRedisTemplate stringRedisTemplate; private static String CACHE_PREFIX; private static boolean CACHE_CLOSED; @Autowired @Qualifier("redisTemplate") public void setRedisTemplate(RedisTemplate<String, Object> redisTemplate) { RedisUtils.redisTemplate = redisTemplate; } @Autowired @Qualifier("stringRedisTemplate") public void setStringRedisTemplate(StringRedisTemplate stringRedisTemplate) { RedisUtils.stringRedisTemplate = stringRedisTemplate; } public RedisUtils() { } @SuppressWarnings({ "rawtypes", "unchecked" }) private static boolean isEmpty(Object obj) { if (obj == null) { return true; } if (obj instanceof String) { String str = obj.toString(); if ("".equals(str.trim())) { return true; } return false; } if (obj instanceof List) { List<Object> list = (List<Object>) obj; if (list.isEmpty()) { return true; } return false; } if (obj instanceof Map) { Map map = (Map) obj; if (map.isEmpty()) { return true; } return false; } if (obj instanceof Set) { Set set = (Set) obj; if (set.isEmpty()) { return true; } return false; } if (obj instanceof Object[]) { Object[] objs = (Object[]) obj; if (objs.length <= 0) { return true; } return false; } return false; } /** * 构建缓存key值 * * @param key * 缓存key * @return */ private static String buildKey(String key) { if (CACHE_PREFIX == null || "".equals(CACHE_PREFIX)) { return key; } return CACHE_PREFIX + ":" + key; } /** * 返回缓存的前缀 * * @return CACHE_PREFIX_FLAG */ public static String getCachePrefix() { return CACHE_PREFIX; } /** * 设置缓存的前缀 * * @param cachePrefix */ public static void setCachePrefix(String cachePrefix) { if (cachePrefix != null && !"".equals(cachePrefix.trim())) { CACHE_PREFIX = cachePrefix.trim(); } } /** * 关闭缓存 * * @return true:成功 false:失败 */ public static boolean close() { LOG.debug(" cache closed ! "); CACHE_CLOSED = true; return true; } /** * 打开缓存 * * @return true:存在 false:不存在 */ public static boolean openCache() { CACHE_CLOSED = false; return true; } /** * 检查缓存是否开启 * * @return true:已关闭 false:已开启 */ public static boolean isClose() { return CACHE_CLOSED; } /** * 判断key值是否存在 * * @param key * 缓存的key * @return true:存在 false:不存在 */ public static boolean hasKey(String key) { LOG.debug(" hasKey key :{}", key); try { if (isClose() || isEmpty(key)) { return false; } key = buildKey(key); return redisTemplate.hasKey(key); } catch (Exception e) { LOG.error(e.getMessage(), e); } return false; } /** * 匹配符合正则的key * * @param patternKey * @return key的集合 */ public static Set<String> keys(String patternKey) { LOG.debug(" keys key :{}", patternKey); try { if (isClose() || isEmpty(patternKey)) { return Collections.emptySet(); } return redisTemplate.keys(patternKey); } catch (Exception e) { LOG.error(e.getMessage(), e); } return Collections.emptySet(); } /** * 根据key删除缓存 * * @param key * @return true:成功 false:失败 */ public static boolean del(String... key) { LOG.debug(" delete key :{}", key.toString()); try { if (isClose() || isEmpty(key)) { return false; } Set<String> keySet = new HashSet<>(); for (String str : key) { keySet.add(buildKey(str)); } redisTemplate.delete(keySet); return true; } catch (Exception e) { LOG.error(e.getMessage(), e); } return false; } /** * 根据key删除缓存 * * @param key * @return true:成功 false:失败 */ public static boolean delPattern(String key) { LOG.debug(" delete Pattern keys :{}", key); try { if (isClose() || isEmpty(key)) { return false; } key = buildKey(key); redisTemplate.delete(redisTemplate.keys(key)); return true; } catch (Exception e) { LOG.error(e.getMessage(), e); } return false; } /** * 删除一组key值 * * @param keys * @return true:成功 false:失败 */ public static boolean del(Set<String> keys) { LOG.debug(" delete keys :{}", keys.toString()); try { if (isClose() || isEmpty(keys)) { return false; } Set<String> keySet = new HashSet<>(); for (String str : keys) { keySet.add(buildKey(str)); } redisTemplate.delete(keySet); return true; } catch (Exception e) { LOG.error(e.getMessage(), e); } return false; } /** * 设置过期时间 * * @param key * 缓存key * @param seconds * 过期秒数 * @return true:成功 false:失败 */ public static boolean setExp(String key, long seconds) { LOG.debug(" setExp key :{}, seconds: {}", key, seconds); try { if (isClose() || isEmpty(key) || seconds > 0) { return false; } key = buildKey(key); return redisTemplate.expire(key, seconds, TimeUnit.SECONDS); } catch (Exception e) { LOG.error(e.getMessage(), e); } return false; } /** * 查询过期时间 * * @param key * 缓存key * @return 秒数 */ public static Long getExpire(String key) { LOG.debug(" getExpire key :{}", key); try { if (isClose() || isEmpty(key)) { return 0L; } key = buildKey(key); return redisTemplate.getExpire(key, TimeUnit.SECONDS); } catch