redis 工具类

mingche

　　redis操作的工具类


import java.util.Map;
import org.apache.log4j.Logger;
import redis.clients.jedis.Jedis;
import com.chanjet.gov.service.Const;

public class RedisUtil {
public static Logger logger = Logger.getLogger(RedisUtil.class);

private Jedis jedis;
private Jedis jedisForIP;
private RedisHelper() {//每次从池里取新连接
this.jedis = Const.pool.getResource();
this.jedis.select(11);
this.jedisForIP = this.jedis;
}
public static RedisHelper getInstance() {
RedisHelper instance = new RedisHelper();

//        if(!instance.jedis.isConnected()){
//            instance.jedis.connect();
//        }
//
//        //如果读取失败,关闭并重新连接
//        try{
//            String v = instance.jedis.get("test_connect");
//        }catch(Exception e){
//            instance.jedis.close();
//            instance.jedis.connect();
//        }
return instance;
}
public Jedis getClient() {
return jedis;
}
public Jedis getClientForIP() {
return jedisForIP;
}
public void saveCache(String k, String v) {
try{
jedis.set(k, v);
}catch (Exception e){
e.printStackTrace();
logger.error("saveCache",e);
Const.pool.returnBrokenResource(jedis);
}finally {
Const.pool.returnResource(jedis);
}
}
public void saveKeyCache(String id, String k, String v) {
try{
jedis.hset(id, k, v);
}catch (Exception e){
e.printStackTrace();
logger.error("saveKeyCache",e);
Const.pool.returnBrokenResource(jedis);
}finally {
Const.pool.returnResource(jedis);
}
}
public void saveAllKeyCache(String id, Map kv) {
try{
jedis.hmset(id, kv);
}catch (Exception e){
e.printStackTrace();
logger.error("saveAllKeyCache",e);
Const.pool.returnBrokenResource(jedis);
}finally {
Const.pool.returnResource(jedis);
}
}
public void clearKeyCache(String id, String k) {
try{
jedis.hdel(id, k);
}catch (Exception e){
e.printStackTrace();
logger.error("clearKeyCache",e);
Const.pool.returnBrokenResource(jedis);
}finally {
Const.pool.returnResource(jedis);
}
}
public String getCache(String k) {
String v = "";
try{
v = jedis.get(k);
}catch (Exception e){
e.printStackTrace();
logger.error("getCache",e);
Const.pool.returnBrokenResource(jedis);
}finally {
Const.pool.returnResource(jedis);
}
return v;
}
public String getKeyCache(String id,  String k) {
String v = "";
try{
v = jedis.hget(id, k);
}catch (Exception e){
e.printStackTrace();
logger.error("getKeyCache",e);
Const.pool.returnBrokenResource(jedis);
}finally {
Const.pool.returnResource(jedis);
}
return v;
}
public Map getAllKeyCache(String id) {
Map v = null;
try{
v = jedis.hgetAll(id);
}catch (Exception e){
e.printStackTrace();
logger.error("getAllKeyCache",e);
Const.pool.returnBrokenResource(jedis);
}finally {
Const.pool.returnResource(jedis);
}
return v;
//        Map v = jedis.hgetAll(id);
//        return v;
}
public void clearCache(String id) {
try{
jedis.del(id);
}catch (Exception e){
e.printStackTrace();
logger.error("clearCache",e);
Const.pool.returnBrokenResource(jedis);
}finally {
Const.pool.returnResource(jedis);
}
//        jedis.del(id);
}
}

　　使用

String needLogin = RedisUtil.getInstance().getKeyCache(cid,"needJsonp");
String password = RedisUtil.getInstance().getKeyCache(id,"password");