redis 工具类
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");
页:
[1]