一 常规单应用框架集成redis
1)pom依赖配置
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
2)redis.properties 配置文件
#Matser的ip地址
redis.hostName=xx.xx.xx
#端口号
redis.port=6379
#如果有密码
#redis.password=
#客户端超时时间单位是毫秒 默认是2000
redis.timeout=10000
#最大空闲数
redis.maxIdle=300
#连接池的最大数据库连接数。设为0表示无限制,如果是jedis 2.4以后用redis.maxTotal
#redis.maxActive=600
#控制一个pool可分配多少个jedis实例,用来替换上面的redis.maxActive,如果是jedis 2.4以后用该属性
redis.maxTotal=1000
#最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制。
redis.maxWaitMillis=1000
#连接的最小空闲时间 默认1800000毫秒(30分钟)
redis.minEvictableIdleTimeMillis=300000
#每次释放连接的最大数目,默认3
redis.numTestsPerEvictionRun=1024
#逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1
redis.timeBetweenEvictionRunsMillis=30000
#是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个
redis.testOnBorrow=true
#在空闲时检查有效性, 默认false
redis.testWhileIdle=true
3)redis 初始链接工具类配置
@Configuration
@PropertySource("classpath:redis.properties")
public class RedisConfig {
@Value("${redis.hostName}")
private String hostName;
@Value("${redis.port}")
private Integer port;
@Value("${redis.maxIdle}")
private Integer maxIdle;
@Value("${redis.maxTotal}")
private Integer maxTotal;
@Value("${redis.maxWaitMillis}")
private Integer maxWaitMillis;
@Value("${redis.minEvictableIdleTimeMillis}")
private Integer minEvictableIdleTimeMillis;
@Value("${redis.numTestsPerEvictionRun}")
private Integer numTestsPerEvictionRun;
@Value("${redis.timeBetweenEvictionRunsMillis}")
private long timeBetweenEvictionRunsMillis;
@Value("${redis.testOnBorrow}")
private boolean testOnBorrow;
@Value("${redis.testWhileIdle}")
private boolean testWhileIdle;
/**
* JedisPoolConfig 连接池
* @return
*/
@Bean
public JedisPoolConfig jedisPoolConfig() {
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
// 最大空闲数
jedisPoolConfig.setMaxIdle(maxIdle);
// 连接池的最大数据库连接数
jedisPoolConfig.setMaxTotal(maxTotal);
// 最大建立连接等待时间
jedisPoolConfig.setMaxWaitMillis(maxWaitMillis);
// 逐出连接的最小空闲时间 默认1800000毫秒(30分钟)
jedisPoolConfig.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
// 每次逐出检查时 逐出的最大数目 如果为负数就是 : 1/abs(n), 默认3
jedisPoolConfig.setNumTestsPerEvictionRun(numTestsPerEvictionRun);
// 逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1
jedisPoolConfig.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
// 是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个
jedisPoolConfig.setTestOnBorrow(testOnBorrow);
// 在空闲时检查有效性, 默认false
jedisPoolConfig.setTestWhileIdle(testWhileIdle);
return jedisPoolConfig;
}
/**
* 单机版配置
* @Title: JedisConnectionFactory
* @param @param jedisPoolConfig
* @param @return
* @return JedisConnectionFactory
* @autor lpl
* @date 2018年2月24日
* @throws
*/
@Bean
public org.springframework.data.redis.connection.jedis.JedisConnectionFactory JedisConnectionFactory(JedisPoolConfig jedisPoolConfig){
org.springframework.data.redis.connection.jedis.JedisConnectionFactory JedisConnectionFactory = new org.springframework.data.redis.connection.jedis.JedisConnectionFactory(jedisPoolConfig);
//连接池
JedisConnectionFactory.setPoolConfig(jedisPoolConfig);
//IP地址
JedisConnectionFactory.setHostName(hostName);
//端口号
JedisConnectionFactory.setPort(port);
//如果Redis设置有密码
// JedisConnectionFactory.setPassword(password);
//客户端超时时间单位是毫秒
JedisConnectionFactory.setTimeout(5000);
return JedisConnectionFactory;
}
/**
* 实例化 RedisTemplate 对象
*
* @return
*/
@Bean
public RedisTemplate<String, Object> functionDomainRedisTemplate(RedisConnectionFactory redisConnectionFactory) {
RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
initDomainRedisTemplate(redisTemplate, redisConnectionFactory);
return redisTemplate;
}
/**
* 设置数据存入 redis 的序列化方式,并开启事务
*
* @param redisTemplate
* @param factory
*/
private void initDomainRedisTemplate(RedisTemplate<String, Object> redisTemplate, RedisConnectionFactory factory) {
//如果不配置Serializer，那么存储的时候缺省使用String，如果用User类型存储，那么会提示错误User can't cast to String！
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setHashKeySerializer(new StringRedisSerializer());
redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
// 开启事务
redisTemplate.setEnableTransactionSupport(true);
redisTemplate.setConnectionFactory(factory);
}
/**
* 注入封装RedisTemplate
* @Title: redisUtil
* @return RedisUtil
* @autor lpl
* @date 2017年12月21日
* @throws
*/
@Bean(name = "redisUtil")
public RedisUtil redisUtil(RedisTemplate<String, Object> redisTemplate) {
RedisUtil redisUtil = new RedisUtil();
redisUtil.setRedisTemplate(redisTemplate);
return redisUtil;
}
}
4)redis util 工具类配置
@Component
public class RedisUtil {
private RedisTemplate<String, Object> redisTemplate;
public void setRedisTemplate(RedisTemplate<String, Object> redisTemplate) {
this.redisTemplate = redisTemplate;
}
// =============================common============================
/**
* 指定缓存失效时间
*
* @param key 键
* @param time 时间(秒)
* @return
*/
public boolean expire(String key, long time) {
try {
if (time > 0) {
redisTemplate.expire(key, time, TimeUnit.SECONDS);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 根据key 获取过期时间
*
* @param key 键 不能为null
* @return 时间(秒) 返回0代表为永久有效
*/
public long getExpire(String key) {
return redisTemplate.getExpire(key, TimeUnit.SECONDS);
}
/**
* 判断key是否存在
*
* @param key 键
* @return true 存在 false不存在
*/
public boolean hasKey(String key) {
try {
return redisTemplate.hasKey(key);
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 删除缓存
*
* @param key 可以传一个值 或多个
*/
@SuppressWarnings("unchecked")
public void del(String... key) {
if (key != null && key.length > 0) {
if (key.length == 1) {
redisTemplate.delete(key[0]);
} else {
redisTemplate.delete(CollectionUtils.arrayToList(key));
}
}
}
// ============================String=============================
/**
* 普通缓存获取
*
* @param key 键
* @return 值
*/
public Object get(String key) {
return key == null ? null : redisTemplate.opsForValue().get(key);
}
/**
* 普通缓存放入
*
* @param key 键
* @param value 值
* @return true成功 false失败
*/
public boolean set(String key, Object value) {
try {
redisTemplate.opsForValue().set(key, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 普通缓存放入并设置时间
*
* @param key 键
* @param value 值
* @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期
* @return true成功 false 失败
*/
public boolean set(String key, Object value, long time) {
try {
if (time > 0) {
redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
} else {
set(key, value);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 递增
*
* @param key 键
* @param by 要增加几(大于0)
* @return
*/
public long incr(String key, long delta) {
if (delta < 0) {
throw new RuntimeException("递增因子必须大于0");
}
return redisTemplate.opsForValue().increment(key, delta);
}
/**
* 递减
*
* @param key 键
* @param by 要减少几(小于0)
* @return
*/
public long decr(String key, long delta) {
if (delta < 0) {
throw new RuntimeException("递减因子必须大于0");
}
return redisTemplate.opsForValue().increment(key, -delta);
}
// ================================Map=================================
/**
* HashGet
*
* @param key 键 不能为null
* @param item 项 不能为null
* @return 值
*/
public Object hget(String key, String item) {
return redisTemplate.opsForHash().get(key, item);
}
/**
* 获取hashKey对应的所有键值
*
* @param key 键
* @return 对应的多个键值
*/
public Map<Object, Object> hmget(String key) {
return redisTemplate.opsForHash().entries(key);
}
/**
* HashSet
*
* @param key 键
* @param map 对应多个键值
* @return true 成功 false 失败
*/
public boolean hmset(String key, Map<String, Object> map) {
try {
redisTemplate.opsForHash().putAll(key, map);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* HashSet 并设置时间
*
* @param key 键
* @param map 对应多个键值
* @param time 时间(秒)
* @return true成功 false失败
*/
public boolean hmset(String key, Map<String, Object> map, long time) {
try {
redisTemplate.opsForHash().putAll(key, map);
if (time > 0) {
expire(key, time);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 向一张hash表中放入数据,如果不存在将创建
*
* @param key 键
* @param item 项
* @param value 值
* @return true 成功 false失败
*/
public boolean hset(String key, String item, Object value) {
try {
redisTemplate.opsForHash().put(key, item, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 向一张hash表中放入数据,如果不存在将创建
*
* @param key 键
* @param item 项
* @param value 值
* @param time 时间(秒) 注意:如果已存在的hash表有时间,这里将会替换原有的时间
* @return true 成功 false失败
*/
public boolean hset(String key, String item, Object value, long time) {
try {
redisTemplate.opsForHash().put(key, item, value);
if (time > 0) {
expire(key, time);
}
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 删除hash表中的值
*
* @param key 键 不能为null
* @param item 项 可以使多个 不能为null
*/
public void hdel(String key, Object... item) {
redisTemplate.opsForHash().delete(key, item);
}
/**
* 判断hash表中是否有该项的值
*
* @param key 键 不能为null
* @param item 项 不能为null
* @return true 存在 false不存在
*/
public boolean hHasKey(String key, String item) {
return redisTemplate.opsForHash().hasKey(key, item);
}
/**
* hash递增 如果不存在,就会创建一个 并把新增后的值返回
*
* @param key 键
* @param item 项
* @param by 要增加几(大于0)
* @return
*/
public double hincr(String key, String item, double by) {
return redisTemplate.opsForHash().increment(key, item, by);
}
/**
* hash递减
*
* @param key 键
* @param item 项
* @param by 要减少记(小于0)
* @return
*/
public double hdecr(String key, String item, double by) {
return redisTemplate.opsForHash().increment(key, item, -by);
}
// ============================set=============================
/**
* 根据key获取Set中的所有值
*
* @param key 键
* @return
*/
public Set<Object> sGet(String key) {
try {
return redisTemplate.opsForSet().members(key);
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* 根据value从一个set中查询,是否存在
*
* @param key 键
* @param value 值
* @return true 存在 false不存在
*/
public boolean sHasKey(String key, Object value) {
try {
return redisTemplate.opsForSet().isMember(key, value);
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 将数据放入set缓存
*
* @param key 键
* @param values 值 可以是多个
* @return 成功个数
*/
public long sSet(String key, Object... values) {
try {
return redisTemplate.opsForSet().add(key, values);
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
/**
* 将set数据放入缓存
*
* @param key 键
* @param time 时间(秒)
* @param values 值 可以是多个
* @return 成功个数
*/
public long sSetAndTime(String key, long time, Object... values) {
try {
Long count = redisTemplate.opsForSet().add(key, values);
if (time > 0)
expire(key, time);
return count;
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
/**
* 获取set缓存的长度
*
* @param key 键
* @return
*/
public long sGetSetSize(String key) {
try {
return redisTemplate.opsForSet().size(key);
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
/**
* 移除值为value的
*
* @param key 键
* @param values 值 可以是多个
* @return 移除的个数
*/
public long setRemove(String key, Object... values) {
try {
Long count = redisTemplate.opsForSet().remove(key, values);
return count;
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
// ===============================list=================================
/**
* 获取list缓存的内容
*
* @param key 键
* @param start 开始
* @param end 结束 0 到 -1代表所有值
* @return
*/
public List<Object> lGet(String key, long start, long end) {
try {
return redisTemplate.opsForList().range(key, start, end);
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* 获取list缓存的长度
*
* @param key 键
* @return
*/
public long lGetListSize(String key) {
try {
return redisTemplate.opsForList().size(key);
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
/**
* 通过索引 获取list中的值
*
* @param key 键
* @param index 索引 index>=0时， 0 表头，1 第二个元素，依次类推；index<0时，-1，表尾，-2倒数第二个元素，依次类推
* @return
*/
public Object lGetIndex(String key, long index) {
try {
return redisTemplate.opsForList().index(key, index);
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* 将list放入缓存
*
* @param key 键
* @param value 值
* @param time 时间(秒)
* @return
*/
public boolean lSet(String key, Object value) {
try {
redisTemplate.opsForList().rightPush(key, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 将list放入缓存
*
* @param key 键
* @param value 值
* @param time 时间(秒)
* @return
*/
public boolean lSet(String key, Object value, long time) {
try {
redisTemplate.opsForList().rightPush(key, value);
if (time > 0)
expire(key, time);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 将list放入缓存
*
* @param key 键
* @param value 值
* @param time 时间(秒)
* @return
*/
public boolean lSet(String key, List<Object> value) {
try {
redisTemplate.opsForList().rightPushAll(key, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 将list放入缓存
*
* @param key 键
* @param value 值
* @param time 时间(秒)
* @return
*/
public boolean lSet(String key, List<Object> value, long time) {
try {
redisTemplate.opsForList().rightPushAll(key, value);
if (time > 0)
expire(key, time);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 根据索引修改list中的某条数据
*
* @param key 键
* @param index 索引
* @param value 值
* @return
*/
public boolean lUpdateIndex(String key, long index, Object value) {
try {
redisTemplate.opsForList().set(key, index, value);
return true;
} catch (Exception e) {
e.printStackTrace();
return false;
}
}
/**
* 移除N个值为value
*
* @param key 键
* @param count 移除多少个
* @param value 值
* @return 移除的个数
*/
public long lRemove(String key, long count, Object value) {
try {
Long remove = redisTemplate.opsForList().remove(key, count, value);
return remove;
} catch (Exception e) {
e.printStackTrace();
return 0;
}
}
}
5)使用的地方引入工具类,调用工具类方法不做详述.
二 dubbo框架中集成redis
1)common 模块加入服务链接部分
*** redis 缓存配置* @author sgy*/
@Component
public class RedisCache implements Serializable {/*** 日志记录*/private static final Log LOG = LogFactory.getLog(RedisCache.class);/*** redis 连接池*/public static JedisPool pool;static {//连接池的最大数据库连接数。设为0表示无限制int maxActive = Integer.parseInt("1000");//最大空闲数int maxIdle = Integer.parseInt("25");//客户端超时时间单位是毫秒int maxWait = Integer.parseInt("10000");//ipString host = "xx.xxx.xx.xx";//端口int port = Integer.parseInt("6379");//密码String pass = null;JedisPoolConfig config = new JedisPoolConfig();//设置最大连接数config.setMaxTotal(maxActive);//设置最大空闲数config.setMaxIdle(maxIdle);//设置超时时间config.setMaxWaitMillis(maxWait);// 每次逐出检查时 逐出的最大数目 如果为负数就是 : 1/abs(n), 默认3config.setNumTestsPerEvictionRun(1024);// 逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1config.setTimeBetweenEvictionRunsMillis(30000);// 是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个config.setTestOnBorrow(true);// 在空闲时检查有效性, 默认falseconfig.setTestWhileIdle(true);//初始化连接池 DB 9 测试dbpool = new JedisPool(config, host, port, 2000, pass,9);}/*** 获取jedis** @return jedis*/public Jedis getResource() {Jedis jedis = null;try {jedis = pool.getResource();} catch (Exception e) {LOG.info("can't get the redis resource");}return jedis;}/*** 关闭连接** @param jedis j*/public void disconnect(Jedis jedis) {jedis.disconnect();}/*** 将jedis 返还连接池** @param jedis j*/public void returnResource(Jedis jedis) {if (null != jedis) {try {pool.returnResource(jedis);} catch (Exception e) {e.printStackTrace();LOG.info("can't return jedis to jedisPool");}}}/*** 无法返还jedispool，释放jedis客户端对象** @param jedis j*/public void brokenResource(Jedis jedis) {if (jedis != null) {try {pool.returnBrokenResource(jedis);} catch (Exception e) {e.printStackTrace();LOG.info("can't release jedis Object");}}}
}
2)使用的模块获取bean
<bean id="redisCache" class="com.iyunshu.common.redis.RedisCache"></bean>
暴露模块抽象的service服务
<dubbo:service interface="com.iyunshu.search.service.RedisCacheStorageService" ref="redisCacheStorageServiceImpl" timeout="300000"/>
3)配置service服务
service
/*** 缓存存储接口** @param <K> key* @param <V> value* @author sgy*/
public interface RedisCacheStorageService<K, V> {/*** 在redis数据库中插入 key 和value** @param key* @param value* @return*/boolean set(K key, V value);/*** 在redis数据库中插入 key 和value 并且设置过期时间** @param key* @param value* @param exp 过期时间 s* @return*/boolean set(K key, V value, int exp);/*** 根据key 去redis 中获取value** @param key* @return*/V get(K key);/*** 删除redis库中的数据** @param key* @return*/boolean remove(K key);/*** 设置哈希类型数据到redis 数据库** @param cacheKey 可以看做一张表* @param key 表字段* @param value* @return*/boolean hset(String cacheKey, K key, V value);/*** 获取哈希表数据类型的值** @param cacheKey* @param key* @return*/V hget(String cacheKey, K key);/*** 获取哈希类型的数据** @param cacheKey* @return*/Map<K, V> hget(String cacheKey);/*** 获取key的剩余时间** @param cacheKey* @return*/Long ttl(String cacheKey);/*** 设置过期时间** @param cacheKey* @return*/boolean expire(String cacheKey, int exp);/*** 获取所有keys** @return*/Set<String> keys(String pattern);/*** 获取当前库所有key的数量** @return*/Long dbsize();/*** 随机获取库中的一个key** @return*/String randomkey();
}
serviceImpl
/*** redis 缓存存储器实现** @param <V>* @author sgy*/
@Service
public class RedisCacheStorageServiceImpl<V> implements RedisCacheStorageService<String, V> {/*** 日志记录*/public static final Log LOG = LogFactory.getLog(RedisCacheStorageServiceImpl.class);/*** 默认过时时间(60 * 60 * 24)*/private static final int EXPIRE_TIME = 86400;@Autowiredprivate RedisCache redisCache;private static StringRedisSerializer rs = new StringRedisSerializer();private static GenericJackson2JsonRedisSerializer rsV = new GenericJackson2JsonRedisSerializer();/*** 在redis数据库中插入 key和value** @param key k* @param value v* @return boolean*/@Overridepublic boolean set(String key, V value) {// 设置默认过时时间return set(key, value, EXPIRE_TIME);}/*** 在redis数据库中插入 key和value 并且设置过期时间** @param key k* @param value v* @param exp 过期时间 s* @return boolean*/@Overridepublic boolean set(String key, V value, int exp) {Jedis jedis = null;// 将key 和value 转换成 json 对象String jKey = serializerKey(key);//String jKey = JSON.toJSONString(key);// String jValue = JSON.toJSONString(value);String jValue = serializerValue(value);// 操作是否成功boolean isSucess = true;if (StringUtils.isEmpty(jKey)) {LOG.info("key is empty");return false;}try {jedis = redisCache.getResource();Transaction tx = jedis.multi();tx.setex(jKey, exp, jValue);tx.exec();} catch (Exception e) {e.printStackTrace();LOG.info("client can't connect server");isSucess = false;if (null != jedis) {// 释放jedis对象redisCache.brokenResource(jedis);}return false;} finally {if (isSucess) {// 返还连接池redisCache.returnResource(jedis);}}return true;}/*** 根据key去redis中获取value** @param key k* @return obj*/@Overridepublic V get(String key) {// 操作是否成功boolean isSucess = true;Jedis jedis = null;// 将key 和value 转换成 json 对象String jKey = serializerKey(key);// String jKey = JSON.toJSONString(key);V jValue = null;// key 不能为空if (StringUtils.isEmpty(jKey)) {LOG.info("key is empty");return null;}try {// 获取客户端对象jedis = redisCache.getResource();// 执行查询String value = jedis.get(jKey);// 判断值是否非空if (StringUtils.isEmpty(value)) {return null;} else {jValue = deserializeValue(value);}// 返还连接池// redisCache.returnResource(jedis);} catch (Exception e) {e.printStackTrace();LOG.info("client can't connect server");if (null != jedis) {// 释放jedis对象redisCache.brokenResource(jedis);}}finally {if (isSucess) {// 返还连接池redisCache.returnResource(jedis);}}return jValue;}/*** 删除redis库中的数据** @param key k* @return boolean*/@Overridepublic boolean remove(String key) {Jedis jedis = null;// 将key 和value 转换成 json 对象String jKey = serializerKey(key);// 操作是否成功boolean isSucess = true;if (StringUtils.isEmpty(jKey)) {LOG.info("key is empty");return false;}jedis = redisCache.getResource();// 执行删除jedis.del(jKey);try {jedis = redisCache.getResource();// 执行删除Transaction tx = jedis.multi();tx.del(jKey);tx.exec();} catch (Exception e) {e.printStackTrace();LOG.info("client can't connect server");isSucess = false;if (null != jedis) {// 释放jedis对象redisCache.brokenResource(jedis);}return false;} finally {if (isSucess) {// 返还连接池redisCache.returnResource(jedis);}}return true;}/*** 设置哈希类型数据到redis数据库** @param cacheKey 可以看做一张表* @param key 表字段* @param value v* @return boolean*/@Overridepublic boolean hset(String cacheKey, String key, V value) {Jedis jedis = null;// 将key 和value 转换成 json 对象String jKey = serializerKey(key);String jCacheKey = serializerKey(cacheKey);String jValue = serializerValue(value);// 操作是否成功boolean isSucess = true;if (StringUtils.isEmpty(jCacheKey)) {LOG.info("cacheKey is empty");return false;}try {// 执行插入哈希jedis = redisCache.getResource();Transaction tx = jedis.multi();tx.hset(jCacheKey, jKey, jValue);tx.exec();} catch (Exception e) {LOG.info("client can't connect server");isSucess = false;if (null != jedis) {// 释放jedis对象redisCache.brokenResource(jedis);}return false;} finally {if (isSucess) {// 返还连接池redisCache.returnResource(jedis);}}return true;}/*** 获取哈希表数据类型的值** @param cacheKey cacheK* @param key k* @return obj*/@Overridepublic V hget(String cacheKey, String key) {Jedis jedis = null;// 操作是否成功boolean isSucess = true;// 将key 和value 转换成 json 对象String jKey = serializerKey(key);String jCacheKey = serializerKey(cacheKey);V jValue = null;if (StringUtils.isEmpty(jCacheKey)) {LOG.info("cacheKey is empty");return null;}try {// 获取客户端对象jedis = redisCache.getResource();// 执行查询String value = jedis.hget(jCacheKey, jKey);// 判断值是否非空if (StringUtils.isEmpty(value)) {return null;} else {jValue = deserializeValue(value);}// 返还连接池redisCache.returnResource(jedis);} catch (Exception e) {LOG.info("client can't connect server");if (null != jedis) {// 释放jedis对象redisCache.brokenResource(jedis);}}finally {if (isSucess) {// 返还连接池redisCache.returnResource(jedis);}}return jValue;}/*** 获取哈希类型的数据** @param cacheKey cacheK* @return map*/@Overridepublic Map<String, V> hget(String cacheKey) {String jCacheKey = serializerKey(cacheKey);// 操作是否成功boolean isSucess = true;// 非空校验if (StringUtils.isEmpty(jCacheKey)) {LOG.info("cacheKey is empty!");return null;}Jedis jedis = null;Map<String, V> result = null;try {jedis = redisCache.getResource();// 获取列表集合Map<String, String> map = jedis.hgetAll(jCacheKey);if (null != map) {for (Map.Entry<String, String> entry : map.entrySet()) {if (result == null) {result = new HashMap<String, V>();}result.put((String) deserializeValue(entry.getKey()), (V) deserializeValue(entry.getValue()));}}} catch (Exception e) {LOG.info("client can't connect server");if (null != jedis) {// 释放jedis对象redisCache.brokenResource(jedis);}}finally {if (isSucess) {// 返还连接池redisCache.returnResource(jedis);}}return result;}@Overridepublic Long ttl(String key) {Jedis jedis = null;// 操作是否成功boolean isSucess = true;// 将key 和value 转换成 json 对象String jKey = serializerKey(key);Long jValue = -1L;// key 不能为空if (StringUtils.isEmpty(jKey)) {LOG.info("key is empty");return -1L;}try {// 获取客户端对象jedis = redisCache.getResource();jValue = jedis.ttl(jKey);// 返还连接池// redisCache.returnResource(jedis);} catch (Exception e) {e.printStackTrace();LOG.info("client can't connect server");if (null != jedis) {// 释放jedis对象redisCache.brokenResource(jedis);}}finally {if (isSucess) {// 返还连接池redisCache.returnResource(jedis);}}return jValue;}@Overridepublic boolean expire(String key, int exp) {Jedis jedis = null;// 将key 和value 转换成 json 对象String jKey = serializerKey(key);// 操作是否成功boolean isSucess = true;if (StringUtils.isEmpty(jKey)) {LOG.info("key is empty");return false;}try {// 获取客户端对象jedis = redisCache.getResource();// 执行插入Transaction tx = jedis.multi();tx.expire(jKey, exp);tx.exec();} catch (Exception e) {LOG.info("client can't connect server");isSucess = false;if (null != jedis) {// 释放jedis对象redisCache.brokenResource(jedis);}return false;} finally {if (isSucess) {// 返还连接池redisCache.returnResource(jedis);}}return true;}@Overridepublic Set<String> keys(String pattern) {// 操作是否成功boolean isSucess = true;Jedis jedis = null;Set<String> res = new HashSet<>();// 将key 和value 转换成 json 对象try {// 获取客户端对象jedis = redisCache.getResource();// 执行查询res = jedis.keys(pattern);// 返还连接池//redisCache.returnResource(jedis);} catch (Exception e) {e.printStackTrace();LOG.info("client can't connect server");if (null != jedis) {// 释放jedis对象redisCache.brokenResource(jedis);}}finally {if (isSucess) {// 返还连接池redisCache.returnResource(jedis);}}return res;}@Overridepublic Long dbsize(){// 操作是否成功boolean isSucess = true;Jedis jedis = null;Long res = 0L;// 将key 和value 转换成 json 对象try {// 获取客户端对象jedis = redisCache.getResource();// 执行查询res = jedis.dbSize();} catch (Exception e) {e.printStackTrace();LOG.info("client can't connect server");if (null != jedis) {// 释放jedis对象redisCache.brokenResource(jedis);}}finally {if (isSucess) {// 返还连接池redisCache.returnResource(jedis);}}return res;}@Overridepublic String randomkey(){// 操作是否成功boolean isSucess = true;Jedis jedis = null;String res ="";// 将key 和value 转换成 json 对象try {// 获取客户端对象jedis = redisCache.getResource();// 执行查询res =jedis.randomKey();res =(String)deserializeValue(res);} catch (Exception e) {e.printStackTrace();LOG.info("client can't connect server");if (null != jedis) {// 释放jedis对象redisCache.brokenResource(jedis);}}finally {if (isSucess) {// 返还连接池redisCache.returnResource(jedis);}}return res;}//序列化keyprivate String serializerKey(String key){return new String(rs.serialize(key));}//序列化Valueprivate String serializerValue(V value){return new String(rsV.serialize(value));}//反序列化Valueprivate V deserializeValue(String value) {V jValue= null;byte[] byteArray = value.getBytes();jValue = (V) rsV.deserialize(byteArray);return jValue;}
}
4)使用模块注入service服务
引入3中暴露的服务
<dubbo:reference interface="com.iyunshu.search.service.RedisCacheStorageService" id="redisCacheStorageService" url="${search_dubbo_url}" timeout="120000"/>注入service
@Resource
private RedisCacheStorageService redisCacheStorageService;
有问题欢迎留言, 交流QQ 1360215811