package com.jcdm.common.core.redis; import org.springframework.cache.Cache; import org.springframework.stereotype.Component; import javax.annotation.Resource; import java.util.Collection; import java.util.concurrent.TimeUnit; /** * spring redis 工具类 * * @author jc **/ @SuppressWarnings(value = { "unchecked", "rawtypes" }) @Component public class RedisCache { // @Autowired // public RedisTemplate redisTemplate; @Resource public MyCache myCache; /** * 缓å˜åŸºæœ¬çš„对象,Integerã€Stringã€å®žä½“ç±»ç‰ * * @param key 缓å˜çš„键值 * @param value 缓å˜çš„值 */ public <T> void setCacheObject(final String key, final T value) { myCache.put(key,value); // redisTemplate.opsForValue().set(key, value); } /** * 缓å˜åŸºæœ¬çš„对象,Integerã€Stringã€å®žä½“ç±»ç‰ * * @param key 缓å˜çš„键值 * @param value 缓å˜çš„值 * @param timeout 时间 * @param timeUnit 时间颗粒度 */ public <T> void setCacheObject(final String key, final T value, final Integer timeout, final TimeUnit timeUnit) { myCache.put(key,value); // redisTemplate.opsForValue().set(key, value, timeout, timeUnit); } /** * 设置有效时间 * * @param key Redisé”® * @param timeout 超时时间 * @return true=设置æˆåŠŸï¼›false=设置失败 */ public boolean expire(final String key, final long timeout) { return expire(key, timeout, TimeUnit.SECONDS); } /** * 设置有效时间 * * @param key Redisé”® * @param timeout 超时时间 * @param unit 时间å•ä½ * @return true=设置æˆåŠŸï¼›false=设置失败 */ public boolean expire(final String key, final long timeout, final TimeUnit unit) { return true; // return redisTemplate.expire(key, timeout, unit); } /** * 获å–有效时间 * * @param key Redisé”® * @return 有效时间 */ // public long getExpire(final String key) // { // return redisTemplate.getExpire(key); // } /** * åˆ¤æ– key是å¦å˜åœ¨ * * @param key é”® * @return true å˜åœ¨ falseä¸å˜åœ¨ */ public Boolean hasKey(String key) { return myCache.hasKey(key); // return redisTemplate.hasKey(key); } /** * 获得缓å˜çš„基本对象。 * * @param key 缓å˜é”®å€¼ * @return 缓å˜é”®å€¼å¯¹åº”çš„æ•°æ® */ public <T> T getCacheObject(final String key) { Cache.ValueWrapper valueWrapper = myCache.get(key); if (valueWrapper == null){ return null; }else { return (T) valueWrapper.get(); } // ValueOperations<String, T> operation = redisTemplate.opsForValue(); // return operation.get(key); } /** * åˆ é™¤å•ä¸ªå¯¹è±¡ * * @param key */ public boolean deleteObject(final String key) { myCache.evict(key); return true; // return redisTemplate.delete(key); } /** * åˆ é™¤é›†åˆå¯¹è±¡ * * @param collection 多个对象 * @return */ public boolean deleteObject(final Collection collection) { return myCache.deleteObject(collection); // return redisTemplate.delete(collection) > 0; } /** * 缓å˜Listæ•°æ® * * @param key 缓å˜çš„键值 * @param dataList 待缓å˜çš„Listæ•°æ® * @return 缓å˜çš„对象 */ // public <T> long setCacheList(final String key, final List<T> dataList) // { // Long count = redisTemplate.opsForList().rightPushAll(key, dataList); // return count == null ? 0 : count; // } /** * 获得缓å˜çš„list对象 * * @param key 缓å˜çš„键值 * @return 缓å˜é”®å€¼å¯¹åº”çš„æ•°æ® */ // public <T> List<T> getCacheList(final String key) // { // return redisTemplate.opsForList().range(key, 0, -1); // } /** * 缓å˜Set * * @param key 缓å˜é”®å€¼ * @param dataSet 缓å˜çš„æ•°æ® * @return 缓å˜æ•°æ®çš„对象 */ // public <T> BoundSetOperations<String, T> setCacheSet(final String key, final Set<T> dataSet) // { // BoundSetOperations<String, T> setOperation = redisTemplate.boundSetOps(key); // Iterator<T> it = dataSet.iterator(); // while (it.hasNext()) // { // setOperation.add(it.next()); // } // return setOperation; // } /** * 获得缓å˜çš„set * * @param key * @return */ // public <T> Set<T> getCacheSet(final String key) // { // return redisTemplate.opsForSet().members(key); // } /** * 缓å˜Map * * @param key * @param dataMap */ // public <T> void setCacheMap(final String key, final Map<String, T> dataMap) // { // if (dataMap != null) { // redisTemplate.opsForHash().putAll(key, dataMap); // } // } /** * 获得缓å˜çš„Map * * @param key * @return */ // public <T> Map<String, T> getCacheMap(final String key) // { // return redisTemplate.opsForHash().entries(key); // } /** * å¾€Hashä¸å˜å…¥æ•°æ® * * @param key Redisé”® * @param hKey Hashé”® * @param value 值 */ // public <T> void setCacheMapValue(final String key, final String hKey, final T value) // { // redisTemplate.opsForHash().put(key, hKey, value); // } /** * 获å–Hashä¸çš„æ•°æ® * * @param key Redisé”® * @param hKey Hashé”® * @return Hashä¸çš„对象 */ // public <T> T getCacheMapValue(final String key, final String hKey) // { // HashOperations<String, String, T> opsForHash = redisTemplate.opsForHash(); // return opsForHash.get(key, hKey); // } /** * 获å–多个Hashä¸çš„æ•°æ® * * @param key Redisé”® * @param hKeys Hashé”®é›†åˆ * @return Hashå¯¹è±¡é›†åˆ */ // public <T> List<T> getMultiCacheMapValue(final String key, final Collection<Object> hKeys) // { // return redisTemplate.opsForHash().multiGet(key, hKeys); // } /** * åˆ é™¤Hashä¸çš„æŸæ¡æ•°æ® * * @param key Redisé”® * @param hKey Hashé”® * @return 是å¦æˆåŠŸ */ // public boolean deleteCacheMapValue(final String key, final String hKey) // { // return redisTemplate.opsForHash().delete(key, hKey) > 0; // } /** * 获得缓å˜çš„基本对象列表 * * @param pattern å—符串å‰ç¼€ * @return 对象列表 */ public Collection<String> keys(final String pattern) { return myCache.keys(pattern); // return redisTemplate.keys(pattern); } }