3、Redis工具类 。这里主要是对Redis操作进行了进一步的封装,简化了操作和提高代码重用,感兴趣的同样可以自行读一下,毕竟狗子我也是cv之后再重新读的? 。
@SuppressWarnings(value = https://www.isolves.com/it/cxkf/kj/2022-07-21/{"unchecked", "rawtypes" })@Componentpublic class RedisCache{@Autowiredpublic RedisTemplate redisTemplate;/*** 缓存基本的对象,Integer、String、实体类等* @param key 缓存的键值* @param value 缓存的值*/public void setCacheObject(final String key, final T value){redisTemplate.opsForValue().set(key, value);}/*** 缓存基本的对象,Integer、String、实体类等* @param key 缓存的键值* @param value 缓存的值* @param timeout 时间* @param timeUnit 时间颗粒度*/public void setCacheObject(final String key, final T value, final Integer timeout, final TimeUnit timeUnit){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 redisTemplate.expire(key, timeout, unit);}/*** 获得缓存的基本对象 。* @param key 缓存键值* @return 缓存键值对应的数据*/public T getCacheObject(final String key){ValueOperations operation = redisTemplate.opsForValue();return operation.get(key);}/*** 删除单个对象* @param key*/public boolean deleteObject(final String key){return redisTemplate.delete(key);}/*** 删除集合对象* @param collection 多个对象*/public long deleteObject(final Collection collection){return redisTemplate.delete(collection);}/*** 缓存List数据* @param key 缓存的键值* @param dataList 待缓存的List数据* @return 缓存的对象*/public long setCacheList(final String key, final List dataList){Long count = redisTemplate.opsForList().rightPushAll(key, dataList);return count == null ? 0 : count;}/*** 获得缓存的list对象* @param key 缓存的键值* @return 缓存键值对应的数据*/public List getCacheList(final String key){return redisTemplate.opsForList().range(key, 0, -1);}/*** 缓存Set* @param key 缓存键值* @param dataSet 缓存的数据* @return 缓存数据的对象*/public BoundSetOperations setCacheSet(final String key, final Set dataSet){BoundSetOperations setOperation = redisTemplate.boundSetOps(key);Iterator it = dataSet.iterator();while (it.hasNext()){setOperation.add(it.next());}return setOperation;}/*** 获得缓存的set* @param key* @return*/public Set getCacheSet(final String key){return redisTemplate.opsForSet().members(key);}/*** 缓存Map* @param key* @param dataMap*/public void setCacheMap(final String key, final Map dataMap){if (dataMap != null) {redisTemplate.opsForHash().putAll(key, dataMap);}}/*** 获得缓存的Map* @param key* @return*/public Map getCacheMap(final String key){return redisTemplate.opsForHash().entries(key);}/*** 往Hash中存入数据* @param key Redis键* @param hKey Hash键* @param value 值*/public 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 getCacheMapValue(final String key, final String hKey){HashOperations opsForHash = redisTemplate.opsForHash();return opsForHash.get(key, hKey);}/*** 删除Hash中的数据* @param key* @param hkey*/public void delCacheMapValue(final String key, final String hkey){HashOperations hashOperations = redisTemplate.opsForHash();hashOperations.delete(key, hkey);}/*** 获取多个Hash中的数据* @param key Redis键* @param hKeys Hash键集合* @return Hash对象集合*/public List getMultiCacheMapValue(final String key, final Collection4、fastjson对Redis工具类的配置 。这里有一个问题就是不要使用高版本的fastjson依赖,因为高版本的好像是已经将
ParserConfig.getGlobalInstance().setAutoTypeSupport(true); 去除了,从而后面导致报错 。
public class FastJsonRedisSerializer<T> implements RedisSerializer<T>{public static final Charset DEFAULT_CHARSET = Charset.forName("UTF-8");private Class<T> clazz;static{ParserConfig.getGlobalInstance().setAutoTypeSupport(true);}public FastJsonRedisSerializer(Class<T> clazz){super();this.clazz = clazz;}@Overridepublic byte[] serialize(T t) throws SerializationException{if (t == null){return new byte[0];}return JSON.toJSONString(t, SerializerFeature.WriteClassName).getBytes(DEFAULT_CHARSET);}@Overridepublic T deserialize(byte[] bytes) throws SerializationException{if (bytes == null || bytes.length <= 0){return null;}String str = new String(bytes, DEFAULT_CHARSET);return JSON.parseobject(str, clazz);}protected JavaType getJavaType(Class<?> clazz){return TypeFactory.defaultInstance().constructType(clazz);}}
推荐阅读
-
26名在老挝遭遇车祸的中国游客回国 伤者讲述异国他乡感受祖国力
-
-
老陈聊星座1|会运势旺,福气多的三大生肖,九一能遇到很多幸运
-
幼儿园的水果餐引来家长质疑,认为是"摆拍",园长回应却亮了
-
肖战|肖战寸头发型被公开,整个人看似年轻10岁!这颜值不火才怪
-
同比|太保前三季度净利润下降14.3%,寿险业务仍然承压
-
▲为么这么多人喜欢打造自己的私家庭院,原来是对生活方式的一种向往
-
比特币|一枚比特币6.4万,如果用家用电脑不停的挖,多久能挖到一枚?
-
-
辛德蕾拉“5分钟生产2000件不同衣服”真的要来了!阿里保密3年的“新制造”工厂今天曝光
-
「Bianews」华为手机一季度国内市场份额达39%,同比增长6%
-
迷途的羔羊|刚入秋,“米色”就火了!它的高级“配色穿搭”帮你备好,请照穿
-
老王技能厂Enco W31表示不服,入门级TWS耳机吃鸡困难?OPPO
-
「科技说说」能用奢侈品电商讲个好故事吗?,上线万里目的趣店
-
淮河流域沂沭泗水系发生大洪水,山东江苏启动Ⅲ级应急响应
-
『国际纵横』为何在中途岛大败?山本犯了一个兵家大忌,日本偷袭珍珠港成功
-
-
-
知名女星透露,最后一段感情是六年前,精力都用在工作上并不孤独
-
“90后”藏族女代表履职:牧区急缺医疗人才 忧妇女健康