redis 工具类

2022-05-08 14:50:58

redis操作的工具类

Java代码  redis 工具类
  1. import java.util.Map;  
  2.   
  3. import org.apache.log4j.Logger;  
  4.   
  5. import redis.clients.jedis.Jedis;  
  6.   
  7. import com.chanjet.gov.service.Const;  
  8.   
  9.   
  10. public class RedisUtil {  
  11.   
  12.     public static Logger logger = Logger.getLogger(RedisUtil.class);  
  13.   
  14.   
  15.     private Jedis jedis;  
  16.     private Jedis jedisForIP;  
  17.   
  18.     private RedisHelper() {//每次从池里取新连接  
  19.         this.jedis = Const.pool.getResource();  
  20.         this.jedis.select(11);  
  21.         this.jedisForIP = this.jedis;  
  22.     }  
  23.   
  24.     public static RedisHelper getInstance() {  
  25.         RedisHelper instance = new RedisHelper();  
  26.   
  27.   
  28.   
  29. //        if(!instance.jedis.isConnected()){  
  30. //            instance.jedis.connect();  
  31. //        }  
  32. //  
  33. //        //如果读取失败,关闭并重新连接  
  34. //        try{  
  35. //            String v = instance.jedis.get("test_connect");  
  36. //        }catch(Exception e){  
  37. //            instance.jedis.close();  
  38. //            instance.jedis.connect();  
  39. //        }  
  40.   
  41.         return instance;  
  42.     }  
  43.   
  44.     public Jedis getClient() {  
  45.         return jedis;  
  46.     }  
  47.   
  48.     public Jedis getClientForIP() {  
  49.         return jedisForIP;  
  50.     }  
  51.   
  52.     public void saveCache(String k, String v) {  
  53.   
  54.         try{  
  55.             jedis.set(k, v);  
  56.         }catch (Exception e){  
  57.             e.printStackTrace();  
  58.             logger.error("saveCache",e);  
  59.             Const.pool.returnBrokenResource(jedis);  
  60.         }finally {  
  61.             Const.pool.returnResource(jedis);  
  62.         }  
  63.   
  64.     }  
  65.   
  66.     public void saveKeyCache(String id, String k, String v) {  
  67.   
  68.         try{  
  69.             jedis.hset(id, k, v);  
  70.         }catch (Exception e){  
  71.             e.printStackTrace();  
  72.             logger.error("saveKeyCache",e);  
  73.             Const.pool.returnBrokenResource(jedis);  
  74.         }finally {  
  75.             Const.pool.returnResource(jedis);  
  76.         }  
  77.   
  78.     }  
  79.   
  80.     public void saveAllKeyCache(String id, Map kv) {  
  81.   
  82.         try{  
  83.             jedis.hmset(id, kv);  
  84.         }catch (Exception e){  
  85.             e.printStackTrace();  
  86.             logger.error("saveAllKeyCache",e);  
  87.             Const.pool.returnBrokenResource(jedis);  
  88.         }finally {  
  89.             Const.pool.returnResource(jedis);  
  90.         }  
  91.   
  92.     }  
  93.   
  94.     public void clearKeyCache(String id, String k) {  
  95.   
  96.         try{  
  97.             jedis.hdel(id, k);  
  98.         }catch (Exception e){  
  99.             e.printStackTrace();  
  100.             logger.error("clearKeyCache",e);  
  101.             Const.pool.returnBrokenResource(jedis);  
  102.         }finally {  
  103.             Const.pool.returnResource(jedis);  
  104.         }  
  105.   
  106.     }  
  107.   
  108.     public String getCache(String k) {  
  109.   
  110.         String v = "";  
  111.         try{  
  112.             v = jedis.get(k);  
  113.   
  114.         }catch (Exception e){  
  115.             e.printStackTrace();  
  116.             logger.error("getCache",e);  
  117.             Const.pool.returnBrokenResource(jedis);  
  118.         }finally {  
  119.             Const.pool.returnResource(jedis);  
  120.         }  
  121.   
  122.         return v;  
  123.     }  
  124.   
  125.     public String getKeyCache(String id,  String k) {  
  126.   
  127.         String v = "";  
  128.   
  129.         try{  
  130.             v = jedis.hget(id, k);  
  131.         }catch (Exception e){  
  132.             e.printStackTrace();  
  133.             logger.error("getKeyCache",e);  
  134.             Const.pool.returnBrokenResource(jedis);  
  135.         }finally {  
  136.             Const.pool.returnResource(jedis);  
  137.         }  
  138.   
  139.         return v;  
  140.     }  
  141.   
  142.     public Map getAllKeyCache(String id) {  
  143.   
  144.         Map v = null;  
  145.         try{  
  146.             v = jedis.hgetAll(id);  
  147.         }catch (Exception e){  
  148.             e.printStackTrace();  
  149.             logger.error("getAllKeyCache",e);  
  150.             Const.pool.returnBrokenResource(jedis);  
  151.         }finally {  
  152.             Const.pool.returnResource(jedis);  
  153.         }  
  154.         return v;  
  155. //        Map v = jedis.hgetAll(id);  
  156.   
  157. //        return v;  
  158.     }  
  159.   
  160.     public void clearCache(String id) {  
  161.   
  162.         try{  
  163.             jedis.del(id);  
  164.         }catch (Exception e){  
  165.             e.printStackTrace();  
  166.             logger.error("clearCache",e);  
  167.             Const.pool.returnBrokenResource(jedis);  
  168.         }finally {  
  169.             Const.pool.returnResource(jedis);  
  170.         }  
  171.   
  172. //        jedis.del(id);  
  173.     }  
  174.   
  175. }  

 使用

Java代码  redis 工具类
  1. String needLogin = RedisUtil.getInstance().getKeyCache(cid,"needJsonp");  
  2.                     String password = RedisUtil.getInstance().getKeyCache(id,"password");  
上一篇：BGP同步


下一篇：理解BGP同步问题