SpringMVC+Mybatis+MySQL配置Redis缓存
package redisCache; import java.util.concurrent.locks.ReadWriteLock;import java.util.concurrent.locks.ReentrantReadWriteLock;
import org.apache.ibatis.cache.Cache;
import org.apache.log4j.Logger;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import tool.SerializeUtil;
public> private static Logger logger = Logger.getLogger(RedisCache.class);
/* 创建访问Redis数据库的Redis客户端 */
private Jedis redisClient = createReids();
/* 读写锁 */
private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
private String>
public RedisCache(final String> if (id == null) {
throw new IllegalArgumentException("Cache instances require an> }
logger.debug(">>>>>>>>>>>>>>>>>>>>>>>>RedisCache:id=" +>
this.id => }
@Override
public void clear() {
redisClient.flushDB();
}
@Override
public String getId() {
return this.id;
}
@Override
public Object getObject(Object key) {
Object value = SerializeUtil.unserialize(redisClient.get(SerializeUtil.serialize(key.toString())));
logger.debug(">>>>>>>>>>>>>>>>>>>>>>>>getObject:" + key + " value=" + value);
return value;
}
@Override
public ReadWriteLock getReadWriteLock() {
return readWriteLock;
}
@Override
public int getSize() {
return Integer.valueOf(redisClient.dbSize().toString());
}
@Override
public void putObject(Object key, Object value) {
logger.debug(">>>>>>>>>>>>>>>>>>>>>>>>putObject:" + key + " value=" + value);
redisClient.set(SerializeUtil.serialize(key.toString()), SerializeUtil.serialize(value));
}
@Override
public Object removeObject(Object key) {
return redisClient.expire(SerializeUtil.serialize(key.toString()), 0);
}
protected static Jedis createReids() {
JedisPool pool = new JedisPool(new JedisPoolConfig(), "127.0.0.1");
Jedis result = pool.getResource();
return result;
}
}
页:
[1]