Spring Redis工具类

/*** spring redis 工具类**/
@Component
@SuppressWarnings(value = { "unchecked", "rawtypes" })
public class RedisService {@Autowiredprivate RedisTemplate redisTemplate;@Autowiredprivate StringRedisTemplate stringRedisTemplate;/*** 缓存基本的对象，Integer、String、实体类等* @param prefix redis前缀* @param key 缓存的键值* @param value 缓存的值* @param <T> T* @return 缓存的对象*/public <T> ValueOperations<String, T> setCacheObject(KeyPrefix prefix, String key, T value) {ValueOperations<String, T> operation = redisTemplate.opsForValue();// 生成真正的keyString realKey = prefix.getPrefix() + key;operation.set(realKey, value);return operation;}/*** 缓存基本的对象，Integer、String、实体类等* @param prefix redis前缀* @param key 缓存的键值* @param value 缓存的值* @param timeout 时间* @param timeUnit 时间颗粒度* @return 缓存的对象*/public <T> ValueOperations<String, T> setCacheObject(KeyPrefix prefix, String key, T value, Integer timeout, TimeUnit timeUnit) {ValueOperations<String, T> operation = redisTemplate.opsForValue();String realKey = prefix.getPrefix() + key;operation.set(realKey, value, timeout, timeUnit);return operation;}/*** 缓存基本的对象，Integer、String、实体类等（使用StringRedisSerializer序列化）* @param prefix redis前缀* @param key 缓存的键值* @param value 缓存的值* @param timeout 时间* @param timeUnit 时间颗粒度* @return 缓存的对象*/public ValueOperations<String, String> setCacheObjectByRedisSerializer(KeyPrefix prefix, String key, String value, Integer timeout, TimeUnit timeUnit) {ValueOperations<String, String> operation = stringRedisTemplate.opsForValue();String realKey = prefix.getPrefix() + key;operation.set(realKey, value, timeout, timeUnit);return operation;}/*** 设置值加一* @param prefix redis前缀* @param key 缓存键值* @return 缓存键值对应的数据*/public Long incrementCacheObject(KeyPrefix prefix, String key) {ValueOperations<String, Long> operation = redisTemplate.opsForValue();String realKey = prefix.getPrefix() + key;return operation.increment(realKey);}/*** 获得缓存的基本对象。* @param prefix redis前缀* @param key 缓存键值* @return 缓存键值对应的数据*/public <T> T getCacheObject(KeyPrefix prefix, String key) {ValueOperations<String, T> operation = redisTemplate.opsForValue();String realKey = prefix.getPrefix() + key;return operation.get(realKey);}/*** 获得缓存的基本对象。* @param prefix redis前缀* @return 缓存键值对应的数据*/public <T> T getCacheObject(KeyPrefix prefix) {ValueOperations<String, T> operation = redisTemplate.opsForValue();String realKey = prefix.getPrefix();return operation.get(realKey);}/*** 删除单个对象* @param prefix redis前缀* @param key 缓存键值*/public void deleteObject(KeyPrefix prefix, String key) {redisTemplate.delete(prefix.getPrefix() + key);}/*** 删除集合对象* @param collection collection*/public void deleteObject(Collection collection) {redisTemplate.delete(collection);}/*** 缓存List数据* @param prefix redis前缀* @param key 缓存的键值* @param dataList 待缓存的List数据* @return 缓存的对象*/public <T> ListOperations<String, T> setCacheList(KeyPrefix prefix, String key, List<T> dataList) {ListOperations listOperation = redisTemplate.opsForList();if (null != dataList) {String realKey = prefix.getPrefix() + key;listOperation.leftPushAll(realKey,dataList);}return listOperation;}/*** 获得缓存的list对象* @param prefix redis前缀* @param key 缓存的键值* @return 缓存键值对应的数据*/public <T> List<T> getCacheList(KeyPrefix prefix, String key) {List<T> dataList = new ArrayList<T>();ListOperations<String, T> listOperation = redisTemplate.opsForList();String realKey = prefix.getPrefix() + key;Long size = listOperation.size(realKey);if(size == null){return null;}for (int i = 0; i < size; i++) {dataList.add(listOperation.index(realKey, i));}return dataList;}/*** 删除List所以数据* @param prefix redis前缀* @param key 缓存的键值* @param value 缓存的键值* @param count= 0 删除所有匹配的元素; > 0 删除匹配元素开始，从左到右最多count个元素; < 0 删除匹配元素开始，从右到左最多count个元素*/public void deleteCacheList(KeyPrefix prefix, String key, String value, int count) {ListOperations listOperation = redisTemplate.opsForList();String realKey = prefix.getPrefix() + key;listOperation.remove(realKey, count, value);}/*** 缓存Set* @param prefix redis前缀* @param key 缓存键值* @param dataSet 缓存的数据* @return 缓存数据的对象*/public <T> BoundSetOperations<String, T> setCacheSet(KeyPrefix prefix, String key, Set<T> dataSet) {String realKey = prefix.getPrefix() + key;BoundSetOperations<String, T> setOperation = redisTemplate.boundSetOps(realKey);if(CollectionUtils.isEmpty(dataSet)){return null;}for (T t : dataSet) {setOperation.add(t);}return setOperation;}/*** 获得缓存的set* @param prefix redis前缀* @param key 缓存键值* @return Set<T>*/public <T> Set<T> getCacheSet(KeyPrefix prefix, String key) {Set<T> dataSet;String realKey = prefix.getPrefix() + key;BoundSetOperations<String, T> operation = redisTemplate.boundSetOps(realKey);dataSet = operation.members();return dataSet;}/*** 缓存Map* @param prefix redis前缀* @param key 缓存键值* @param dataMap dataMap* @return HashOperations*/public <T> HashOperations<String, String, T> setCacheMap(KeyPrefix prefix, String key, Map<String, T> dataMap) {HashOperations hashOperations = redisTemplate.opsForHash();String realKey = prefix.getPrefix() + key;if (null != dataMap) {for (Map.Entry<String, T> entry : dataMap.entrySet()) {hashOperations.put(realKey, entry.getKey(), entry.getValue());}}return hashOperations;}/*** 缓存Map key* @param prefix prefix* @param key key* @param hashKey hashKey* @param hashValue hashValue*/public void setCacheMapKey(KeyPrefix prefix, String key, String hashKey, String hashValue) {String realKey = prefix.getPrefix() + key;redisTemplate.opsForHash().put(realKey, hashKey, hashValue);}/*** 获得缓存的Map* @param prefix redis前缀* @param key 缓存键值* @return Map*/public <T> Map<String, T> getCacheMap(KeyPrefix prefix, String key) {String realKey = prefix.getPrefix() + key;return (Map<String, T>) redisTemplate.opsForHash().entries(realKey);}/*** 删除Hash缓存的一个或多个元素* @param prefix prefix* @param key key* @param hashKeys hashKeys* @return Long*/public Long deleteCacheMapFieId(KeyPrefix prefix, String key, Object... hashKeys) {String realKey = prefix.getPrefix() + key;return redisTemplate.opsForHash().delete(realKey, hashKeys);}/*** 获取缓存Map中key* @param prefix prefix* @param key key* @param hashKey hashKey* @return Object*/public Object getCacheMapFieId(KeyPrefix prefix, String key, String hashKey) {String realKey = prefix.getPrefix() + key;return redisTemplate.opsForHash().get(realKey, hashKey);}/*** 获得缓存的基本对象列表* * @param pattern 字符串前缀* @return 对象列表*/public Collection<String> keys(String pattern) {return redisTemplate.keys(pattern);}/*** 获取当前时间到第二天的秒数* @param date 当前时间* @return int*/private static int getTomorrowSeconds(Date date){LocalDateTime localDateTime = LocalDateTime.ofInstant(date.toInstant(), ZoneId.systemDefault());LocalDateTime tomorrow = LocalDateTime.ofInstant(date.toInstant(), ZoneId.systemDefault()).plusDays(1).withHour(0).withMinute(0).withSecond(0).withNano(0);long seconds = ChronoUnit.SECONDS.between(localDateTime, tomorrow);return (int)seconds;}/*** 插入ZSet数据* @param prefix prefix* @param key key* @param value value* @param score 排序权重* @param <T> T* @return Boolean*/public <T> Boolean setZSetObject(KeyPrefix prefix, String key, T value, Long score) {String realKey = prefix.getPrefix() + key;return redisTemplate.opsForZSet().add(realKey, value, score);}/*** 移除ZSet消息* @param prefix prefix* @param key key* @param value value* @param <T> T* @return Boolean*/public <T> Boolean removeZSet(KeyPrefix prefix, String key, T value) {String realKey = prefix.getPrefix() + key;Long remove = redisTemplate.opsForZSet().remove(realKey, value);return remove != null && remove > 0;}/*** 拉取最新需要被消费的消息* @param prefix prefix* @param key key* @param <T> T* @return Set*/public <T> Set<T> pullZSetRecords(KeyPrefix prefix, String key) {String realKey = prefix.getPrefix() + key;Set<T> records = redisTemplate.opsForZSet().rangeByScore(realKey, 0, System.currentTimeMillis());if (records == null) {return null;}return records;}
}

引用接口
1、KeyPrefix

public interface KeyPrefix {int expireSeconds();String getPrefix();
}

2、BasePrefix

public abstract class BasePrefix implements KeyPrefix {private int expireSeconds;private String prefix;public BasePrefix(String prefix) {this(0, prefix);}public BasePrefix(int expireSeconds, String prefix) {this.expireSeconds = expireSeconds;this.prefix = prefix;}public int expireSeconds() {return this.expireSeconds;}public String getPrefix() {String className = this.getClass().getSimpleName();return className + ":" + this.prefix;}
}

3、CrmStuCodeKey

public class CrmStuCodeKey extends BasePrefix {public static CrmStuCodeKey CODE = new CrmStuCodeKey("code");public CrmStuCodeKey(String prefix) {super(prefix);}
}

Spring Redis工具类相关推荐

springboot 集成 redis 工具类
添加依赖 <dependency><groupId>org.springframework.boot&l ...
【Spring之轨迹】结合 @Scheduled 实现定时将 Redis 缓存刷入数据库（配 Redis 工具类与例子实战）
-- 目录 -- 0. 假设已配置好 SSM 环境 1. 配置文件 2. 定时服务 3. cron 解释 ① cron 参数(按顺序依次为) ② 特殊符号 4. Redis 工具类 5. 例子实战 0 ...
Redis工具类封装RedisUtils
本文参考:https://blog.it-follower.com/posts/2563248908.html SpringBoot项目集成Redis相当简单,只需要pom中加入对应依赖 <de ...
SpringBoot Redis工具类封装
SpringBoot整合Redis的博客很多,但是很多都不是我想要的结果.因为我只需要整合完成后,可以操作Redis就可以了,并不需要配合缓存相关的注解使用(如@Cacheable).看了很多博客后, ...
Springboot集成Redis和Redis工具类
目录 1.导入依赖 2.修改配置文件 3.测试 4.使用redis存入对象 5.redis自定义封装 RedisUtils工具类 1.导入依赖 <dependency><groupI ...
java实现redis工具类及其调用
网上很多redis工具类需要配套ssm,spring等,这是一套可以直接用的redis取参数的工具类(String类型) 一.jedis-2.1.0.jar下载,放到项目的lib下网盘地址(4tn5 ...
Java开发中的工具类——基于JedisPool的Redis工具类
目录一.Maven依赖二.Redis配置类三.使用@Cacheable注解进行数据缓存四.自定义Redis工具类及使用 4.1 序列化工具类 4.2 redis客户端工具类 4.3 redis ...
微服务使用redis操作实例包含redis工具类
1.单机redis使用工具类 application.properties配置内容 #redis配置 #单机模式 #redis数据库索引,默认为0 spring.redis.database=0 #r ...
Redis工具类封装RedisUtils（两种）
RedisTemplate工具类1 本文参考:https://blog.it-follower.com/posts/2563248908.html SpringBoot项目集成Redis相当简单,只需 ...

Spring Redis工具类

Spring Redis工具类相关推荐

最新文章

热门文章