package com.qxueyou.scc.base.dao;
|
|
|
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Repository;
|
|
import redis.clients.jedis.ShardedJedis;
|
|
/***
|
* redis常用操作类
|
*
|
* @author kevin
|
* @date 2017-05-15 17:00
|
*/
|
@Repository(value="CommonRedisCache")
|
public class CommonRedisCache extends CommonRedisTemplate {
|
|
private static final Logger log = LogManager.getLogger(CommonRedisCache.class);
|
|
@Autowired
|
private ReidsSharedPoolWrapper reidsSharedPoolWrapper ;
|
|
protected ShardedJedis getJedisClient() {
|
ShardedJedis jedisClient = null;
|
try {
|
if (reidsSharedPoolWrapper != null) {
|
jedisClient = reidsSharedPoolWrapper.getResource();
|
}
|
} catch (Exception e) {
|
log.error("获取redisClient异常!");
|
}
|
return jedisClient;
|
}
|
|
protected void closeJedisClient(ShardedJedis jedisClient) {
|
try {
|
if (jedisClient != null) {
|
jedisClient.close();
|
}
|
} catch (Exception e) {
|
log.error("关闭redis连接失败");
|
}
|
}
|
|
public void setReidsSharedPoolWrapper(ReidsSharedPoolWrapper reidsSharedPoolWrapper) {
|
this.reidsSharedPoolWrapper = reidsSharedPoolWrapper;
|
}
|
|
|
}
|