redis 工具类
Java代碼?? 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"); ?
?使用
Java代碼??總結
- 上一篇： Apache HBase快照介绍
- 下一篇： 海量Web日志分析 用Hadoop提取K