基于协同过滤算法的网上饮品商城系统.zip

package com.zyt.utils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Component; import java.util.*; import java.util.concurrent.TimeUnit; /** * @ProjectName: ssm * @Package: com.zyt.utils * @ClassName: RedisUtil * @Author: zhou_yangtao@yeah.net * @Description: * @Date: 21:08 2020/6/16 * @Version: 1.0 */ @Component//在实现类中用到了@Autowired注解，被注解的这个类是从Spring容器中取出来的，那调用的实现类也需要被Spring容器管理，加上@Component public class RedisUtil { private static final Logger logger = LoggerFactory.getLogger(RedisUtil.class); @Autowired private RedisTemplate redisTemplate; private static String CACHE_PREFIX; private static boolean CACHE_CLOSED; private RedisUtil() { } @SuppressWarnings("rawtypes") 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() { logger.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 boolean hasKey(String key) { try { if (isClose() || isEmpty(key)) { return false; } key = buildKey(key); return redisTemplate.hasKey(key); } catch (Exception e) { logger.error(e.getMessage(), e); } return false; } /** * 匹配符合正则的key * @param patternKey * @return key的集合 */ public Set<String> keys(String patternKey) { try { if (isClose() || isEmpty(patternKey)) { return Collections.emptySet(); } return redisTemplate.keys(patternKey); } catch (Exception e) { logger.error(e.getMessage(), e); } return Collections.emptySet(); } /** * 根据key删除缓存 * @param key * @return true:成功 * false:失败 */ public boolean del(String key){ try { if(isClose() || isEmpty(key)){ return false; } redisTemplate.delete(key); return true; }catch (Exception e){ logger.error(e.getMessage(),e); } return false; } /** * 根据key删除缓存 多个key * @param key * @return true:成功 * false:失败 */ public boolean del(String... key) { 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) { logger.error(e.getMessage(), e); } return false; } /** * 根据key删除缓存 * @param key * @return true:成功 * false:失败 */ public boolean delPattern(String key) { logger.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) { logger.error(e.getMessage(), e); } return false; } /** * 删除一组key值 * @param keys * @return true:成功 * false:失败 */ public boolean del(Set<String> keys) { 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) { logger.error(e.getMessage(), e); } return false; } /** * 设置过期时间 * @param key 缓存key * @param seconds 过期秒数 * @return true:成功 * false:失败 */ public boolean setExp(String key, long seconds) { try { if (isClose() || isEmpty(key) || seconds > 0) { return false; } key = buildKey(key); return redisTemplate.expire(key, seconds, TimeUnit.SECONDS); } catch (Exception e) { logger.error(e.getMessage(), e); } return false; } /** * 普通缓存放入