{
Logger logger LoggerFactory.getLogger(JedisUtils.);
JedisUtils()
{
}
JedisSlotBasedConnectionHandler jedisSlotBasedConnectionHandler SpringUtils.getBean(JedisSlotBasedConnectionHandler.);
get( key)
{
value ;
Jedis jedis ;
{
jedis getConnection(key);
(jedis.exists(key))
{
value jedis.get(key);
value StringUtils.isNotBlank(value) .equalsIgnoreCase(value) value : ;
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, key e.getMessage());
}
{
releaseConnection(jedis);
}
value;
}
set( key, value, cacheSeconds)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
result jedis.set(key, value);
(cacheSeconds )
{
jedis.expire(key, cacheSeconds);
}
}
(JedisDataException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
getObject( key)
{
value ;
Jedis jedis ;
{
jedis getConnection(key);
(jedis.exists(ObjectUtils.getBytes(key)))
{
value ObjectUtils.toObject(jedis.get(ObjectUtils.getBytes(key)));
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
value;
}
setObject( key, value, cacheSeconds)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
result jedis.set(ObjectUtils.getBytes(key), ObjectUtils.toBytes(value));
(cacheSeconds )
{
jedis.expire(key, cacheSeconds);
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
List getListString( key)
{
List value ;
Jedis jedis ;
{
jedis getConnection(key);
(jedis.exists(key))
{
value jedis.lrange(key, , );
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
value;
}
List getObjectList( key)
{
List value ;
Jedis jedis ;
{
jedis getConnection(key);
(jedis.exists(ObjectUtils.getBytes(key)))
{
List[] list jedis.lrange(ObjectUtils.getBytes(key), , );
value Lists.newArrayList();
([] bs : list)
{
value.add(ObjectUtils.toObject(bs));
}
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
value;
}
setList( key, List value, cacheSeconds)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
(jedis.exists(key))
{
jedis.del(key);
}
result jedis.rpush(key, ([]) value.toArray());
(cacheSeconds )
{
jedis.expire(key, cacheSeconds);
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
setObjectList( key, List value, cacheSeconds)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
(jedis.exists(ObjectUtils.getBytes(key)))
{
jedis.del(key);
}
List[] list Lists.newArrayList();
( o : value)
{
list.add(ObjectUtils.toBytes(o));
}
result jedis.rpush(ObjectUtils.getBytes(key), ([][]) list.toArray());
(cacheSeconds )
{
jedis.expire(key, cacheSeconds);
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
listAdd( key, ... value)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
result jedis.rpush(key, value);
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
listObjectAdd( key, ... value)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
List[] list Lists.newArrayList();
( o : value)
{
list.add(ObjectUtils.toBytes(o));
}
result jedis.rpush(ObjectUtils.getBytes(key), ([][]) list.toArray());
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
Set getSet( key)
{
Set value ;
Jedis jedis ;
{
jedis getConnection(key);
(jedis.exists(key))
{
value jedis.smembers(key);
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
value;
}
Set getObjectSet( key)
{
Set value ;
Jedis jedis ;
{
jedis getConnection(key);
(jedis.exists(ObjectUtils.getBytes(key)))
{
value Sets.newHashSet();
Set[] set jedis.smembers(ObjectUtils.getBytes(key));
([] bs : set)
{
value.add(ObjectUtils.toObject(bs));
}
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
value;
}
setSet( key, Set value, cacheSeconds)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
(jedis.exists(key))
{
jedis.del(key);
}
result jedis.sadd(key, ([]) value.toArray());
(cacheSeconds )
{
jedis.expire(key, cacheSeconds);
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
setObjectSet( key, Set value, cacheSeconds)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
(jedis.exists(ObjectUtils.getBytes(key)))
{
jedis.del(key);
}
Set[] set Sets.newHashSet();
( o : value)
{
set.add(ObjectUtils.toBytes(o));
}
result jedis.sadd(ObjectUtils.getBytes(key), ([][]) set.toArray());
(cacheSeconds )
{
jedis.expire(key, cacheSeconds);
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
setSetAdd( key, ... value)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
result jedis.sadd(key, value);
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
setSetObjectAdd( key, ... value)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
Set[] set Sets.newHashSet();
( o : value)
{
set.add(ObjectUtils.toBytes(o));
}
result jedis.rpush(ObjectUtils.getBytes(key), ([][]) set.toArray());
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
Map, getMap( key)
{
Map, value ;
Jedis jedis ;
{
jedis getConnection(key);
(jedis.exists(key))
{
value jedis.hgetAll(key);
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
value;
}
Map, getObjectMap( key)
{
Map, value ;
Jedis jedis ;
{
jedis getConnection(key);
(jedis.exists(ObjectUtils.getBytes(key)))
{
value Maps.newHashMap();
Map[], [] map jedis.hgetAll(ObjectUtils.getBytes(key));
(Map.Entry[], [] e : map.entrySet())
{
value.put( (e.getKey(), Charset.forName(CharsetConst.CHARSET_UT)), ObjectUtils.toObject(e.getValue()));
}
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
value;
}
setMap( key, Map, value, cacheSeconds)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
(jedis.exists(key))
{
jedis.del(key);
}
result jedis.hmset(key, value);
(cacheSeconds )
{
jedis.expire(key, cacheSeconds);
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
setObjectMap( key, Map, value, cacheSeconds)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
(jedis.exists(ObjectUtils.getBytes(key)))
{
jedis.del(key);
}
Map[], [] map Maps.newHashMap();
(Map.Entry, e : value.entrySet())
{
map.put(ObjectUtils.getBytes(e.getKey()), ObjectUtils.toBytes(e.getValue()));
}
result jedis.hmset(ObjectUtils.getBytes(key), (Map[], []) map);
(cacheSeconds )
{
jedis.expire(key, cacheSeconds);
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
mapPut( key, Map, value)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
result jedis.hmset(key, value);
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
mapObjectPut( key, Map, value)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
Map[], [] map Maps.newHashMap();
(Map.Entry, e : value.entrySet())
{
map.put(ObjectUtils.getBytes(e.getKey()), ObjectUtils.toBytes(e.getValue()));
}
result jedis.hmset(ObjectUtils.getBytes(key), (Map[], []) map);
logger.debug(, key, value);
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
mapRemove( key, mapKey)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
result jedis.hdel(key, mapKey);
logger.debug(, key, mapKey);
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, key mapKey e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
mapObjectRemove( key, mapKey)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
result jedis.hdel(ObjectUtils.getBytes(key), ObjectUtils.getBytes(mapKey));
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, key mapKey e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
mapExists( key, mapKey)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
result jedis.hexists(key, mapKey);
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, key mapKey e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
mapObjectExists( key, mapKey)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
result jedis.hexists(ObjectUtils.getBytes(key), ObjectUtils.getBytes(mapKey));
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, key mapKey e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
del( key)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
(jedis.exists(key))
{
result jedis.del(key);
}
{
logger.debug(, key);
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, key e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
delObject( key)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
(jedis.exists(ObjectUtils.getBytes(key)))
{
result jedis.del(ObjectUtils.getBytes(key));
logger.debug(, key);
}
{
logger.debug(, key);
}
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, key e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
exists( key)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
result jedis.exists(key);
logger.debug(, key);
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, key e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
existsObject( key)
{
result ;
Jedis jedis ;
{
jedis getConnection(key);
result jedis.exists(ObjectUtils.getBytes(key));
logger.debug(, key);
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, key e.getMessage());
}
{
releaseConnection(jedis);
}
result;
}
Jedis getConnection( key)
{
Jedis jedis ;
{
jedis jedisSlotBasedConnectionHandler.getConnectionFromSlot(JedisClusterCRC16.getSlot(key));
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
jedis;
}
releaseConnection(Jedis jedis)
{
{
jedisSlotBasedConnectionHandler.returnConnection(jedis);
}
(JedisHandleException e)
{
LoggerUtils.logError(logger, e.getMessage());
}
}
}jedis工具类
jedis工具类
2023-02-16 08:14:03 阅读次数：230
版权声明：本文内容来自第三方投稿或授权转载，原文地址：https://blog.51cto.com/u_11979904/5651201，作者：starmark1111，版权归原作者所有。本网站转在其作品的目的在于传递更多信息，不拥有版权，亦不承担相应法律责任。如因作品内容、版权等问题需要同本网站联系，请发邮件至ctyunbbs@chinatelecom.cn沟通。
上一篇：任务清单小功能的实现
下一篇：SQL：redis缓存数据库深入
作者介绍
天翼云用户
查看更多
最新文章
对话AI-Redis原理相关
2024-09-25 10:15:32
在java中构建高效的结果缓存
2024-09-25 10:13:57
elasticsearch预加载数据到文件系统缓存
2024-09-25 10:13:57
apache下用expires_module让浏览器缓存静态文件
2024-09-24 06:31:12
LRU手撸，说下时间复杂度和空间复杂度。
2024-09-24 06:30:20
Web Server 设置缓存响应字段的一些推荐方案
2024-07-29 08:02:08
查看更多
热门文章
查看Redis的默认设置的过期策略和内存淘汰机制
2022-12-28 07:22:30
精华推荐 | 【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的存储系统的实现原理和持久化机制
2023-02-24 10:12:47
leetcode数据结构-LRU
2023-03-02 10:21:35
elasticsearch预加载数据到文件系统缓存
2024-09-25 10:13:57
ajax get缓存问题+ajax post请求
2023-06-07 07:32:36
自定义注解
2023-06-16 06:11:10
售前咨询热线
400-810-9889转1
- 天翼云APP
- 微信公众号
©2024天翼云科技有限公司版权所有 增值电信业务经营许可证A2.B1.B2-20090001
公司地址：北京市东城区青龙胡同甲1号、3号2幢2层205-32室
