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="commonRedisTemplate")
|
public class CommonRedisTemplate extends AbstractRedisTemplate {
|
|
private static final Logger log = LogManager.getLogger(CommonRedisTemplate.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;
|
}
|
|
|
}
|