jedis封装

不念不忘少年蓝@ 2023-01-15 15:24 191阅读 0赞

redisTemplate封装参考：
https://blog.csdn.net/leinminna/article/details/115999431

1.jedis 基础属性

  1. public class RedisUtils { 
  2.     private static JedisPool jedisPool;
  3.     public static final String PREFIX = "0621B4751BC607DAB5EF2F391E4D2B69_";
  4.     static Logger logger = Logger.getLogger(RedisUtils.class);
  6.     private static final String REDIS_HOST_DEFAULT = "271.0.0.1";
  7.     private static final int REDIS_PORT_DEFAULT = 6380;
  8.     private static final int REDIS_MAXTOTAL_DEFAULT = 200;
  9.     private static final int REDIS_MAXIDLE_DEFAULT = 25;
  10.     private static final int REDIS_MAXWAIT_DEFAULT = 1000;
  11.     private static final String REDIS_HOST = "redis.host";
  12.     private static final String REDIS_PORT = "redis.port";
  13.     private static final String REDIS_MAXTOTAL = "redis.maxTotal";
  14.     private static final String REDIS_MAXIDLE = "redis.maxIdle";
  15.     private static final String REDIS_MAXWAIT = "redis.maxWait";
  17.     private static final String REDIS_PASSWORD = "redis.password";
  19.     static { 
  20.         String host = SiteConfig.get(REDIS_HOST, REDIS_HOST_DEFAULT);
  21.         int port = SiteConfig.getInt(REDIS_PORT, REDIS_PORT_DEFAULT);
  22.         int maxTotal = SiteConfig.getInt(REDIS_MAXTOTAL, REDIS_MAXTOTAL_DEFAULT);
  23.         int maxIdle = SiteConfig.getInt(REDIS_MAXIDLE, REDIS_MAXIDLE_DEFAULT);
  24.         long maxWait = SiteConfig.getInt(REDIS_MAXWAIT, REDIS_MAXWAIT_DEFAULT);
  26.         String password = SiteConfig.get(REDIS_PASSWORD);
  28.         JedisPoolConfig config = new JedisPoolConfig();
  29.         config.setMaxTotal(maxTotal);
  30.         config.setMaxIdle(maxIdle);
  31.         config.setMaxWaitMillis(maxWait);
  33.         if (StringUtils.isEmpty(password)) { 
  34.             jedisPool = new JedisPool(config, host, port);
  35.         } else { 
  36.             jedisPool = new JedisPool(config, host, port, 180000, password);
  38.         }
  39.     }
  40.     ...
  41. }

2. String 封装

  1. /** * string_key string_value * * @param key string_key * @return string_value */
  2.     public static String get(String key) { 
  3.         Jedis jedis = jedisPool.getResource();
  4.         try { 
  5.             return jedis.get(key);
  6.         } catch (Exception e) { 
  7.             logger.error(e, e);
  8.             jedisPool.returnBrokenResource(jedis);
  9.             jedis = null;
  10.             throw e;
  11.         } finally { 
  12.             if (jedis != null) { 
  13.                 jedisPool.returnResource(jedis);
  14.             }
  15.         }
  16.     }
  18.     /** * string_key string_value * * @param key string_key * @param value string_value * @param seconds 有效时间段 */
  19.     public static void set(String key, Serializable value, int seconds) { 
  20.         Jedis jedis = jedisPool.getResource();
  21.         try { 
  22.             byte[] keyBytes = key.getBytes();
  23.             jedis.set(keyBytes, SerializationUtil.serialize(value));
  24.             jedis.expire(keyBytes, seconds);
  25.         } catch (Exception e) { 
  26.             logger.error(e, e);
  27.             jedisPool.returnBrokenResource(jedis);
  28.             jedis = null;
  29.             throw e;
  30.         } finally { 
  31.             if (jedis != null) { 
  32.                 jedisPool.returnResource(jedis);
  33.             }
  34.         }
  35.     }
  37.     /** * string_key string_value * * @param key string_key * @param value string_value */
  38.     public static void set(String key, Serializable value) { 
  39.         Jedis jedis = jedisPool.getResource();
  40.         try { 
  41.             jedis.set(key.getBytes(), SerializationUtil.serialize(value));
  42.         } catch (Exception e) { 
  43.             logger.error(e, e);
  44.             jedisPool.returnBrokenResource(jedis);
  45.             jedis = null;
  46.             throw e;
  47.         } finally { 
  48.             if (jedis != null) { 
  49.                 jedisPool.returnResource(jedis);
  50.             }
  51.         }
  52.     }
  54.     /** * string_key string_value * * @param key string_key * @param clazz T类 * @param <T> T 对象 * @return T 对象 */
  55.     public static <T> T get(String key, Class<T> clazz) { 
  57.         Jedis jedis = jedisPool.getResource();
  58.         try { 
  59.             byte[] data = jedis.get(key.getBytes());
  60.             return data == null ? null : SerializationUtil.deserialize(data, clazz);
  61.         } catch (Exception e) { 
  62.             logger.error(e, e);
  63.             jedisPool.returnBrokenResource(jedis);
  64.             jedis = null;
  65.             throw e;
  66.         } finally { 
  67.             if (jedis != null) { 
  68.                 jedisPool.returnResource(jedis);
  69.             }
  70.         }
  71.     }
  73.     /** * string-key,string-value * * @param key string-key * @param clazz string-value 转 T 类 * @param seconds 重新设置过期时间(秒) * @param <T> T 的类型 * @return 返回 T 对象 */
  74.     public static <T> T gas(String key, Class<T> clazz, int seconds) { 
  75.         Jedis jedis = jedisPool.getResource();
  76.         try { 
  77.             byte[] keyBytes = key.getBytes();
  78.             byte[] data = jedis.get(keyBytes);
  79.             if (data != null) { 
  80.                 jedis.expire(keyBytes, seconds);
  81.                 return SerializationUtil.deserialize(data, clazz);
  82.             } else { 
  83.                 return null;
  84.             }
  85.         } catch (Exception e) { 
  86.             logger.error(e, e);
  87.             jedisPool.returnBrokenResource(jedis);
  88.             jedis = null;
  89.             throw e;
  90.         } finally { 
  91.             if (jedis != null) { 
  92.                 jedisPool.returnResource(jedis);
  93.             }
  94.         }
  95.     }
  97.     /** * string-key,string-value * * @param key string-key * @param seconds 重新设置过期时间(秒) * @return 返回 jsonString */
  98.     public static String gas(String key, int seconds) { 
  99.         Jedis jedis = jedisPool.getResource();
  100.         try { 
  101.             String str = jedis.get(key);
  102.             if (str != null) { 
  103.                 jedis.expire(str, seconds);
  104.             }
  105.             return str;
  106.         } catch (Exception e) { 
  107.             logger.error(e, e);
  108.             jedisPool.returnBrokenResource(jedis);
  109.             jedis = null;
  110.             throw e;
  111.         } finally { 
  112.             if (jedis != null) { 
  113.                 jedisPool.returnResource(jedis);
  114.             }
  115.         }
  116.     }
  118.     /** * 根据键删除值，批量操作，键不存不操作，返回键值对删除的个数，没有返回0 * * @param keys key 数组 */
  119.     public static void del(String... keys) { 
  121.         Jedis jedis = jedisPool.getResource();
  122.         try { 
  123.             jedis.del(keys);
  124.         } catch (Exception e) { 
  125.             logger.error(e, e);
  126.             jedisPool.returnBrokenResource(jedis);
  127.             jedis = null;
  128.             throw e;
  129.         } finally { 
  130.             if (jedis != null) { 
  131.                 jedisPool.returnResource(jedis);
  132.             }
  133.         }
  134.     }
  136.     /** * 删除 匹配的 key 对应的数据 * * @param pattern */
  137.     public static void delPattern(String pattern) { 
  138.         Jedis jedis = jedisPool.getResource();
  139.         try { 
  140.             Set<String> keys = jedis.keys(pattern);
  141.             if (keys != null && keys.size() > 0) { 
  142.                 Iterator<String> it = keys.iterator();
  143.                 while (it.hasNext()) { 
  144.                     String key = it.next();
  145.                     jedis.del(key);
  146.                 }
  147.             }
  148.         } catch (Exception e) { 
  149.             logger.error(e, e);
  150.             jedisPool.returnBrokenResource(jedis);
  151.             jedis = null;
  152.             throw e;
  153.         } finally { 
  154.             if (jedis != null) { 
  155.                 jedisPool.returnResource(jedis);
  156.             }
  157.         }
  158.     }
  160.     public static boolean exists(String key) { 
  162.         Jedis jedis = jedisPool.getResource();
  163.         try { 
  164.             return jedis.exists(key);
  165.         } catch (Exception e) { 
  166.             logger.error(e, e);
  167.             jedisPool.returnBrokenResource(jedis);
  168.             jedis = null;
  169.             throw e;
  170.         } finally { 
  171.             if (jedis != null) { 
  172.                 jedisPool.returnResource(jedis);
  173.             }
  174.         }
  175.     }
  177.     public static void expire(String key, int seconds) { 
  178.         Jedis jedis = jedisPool.getResource();
  179.         try { 
  180.             jedis.expire(key, seconds);
  181.         } catch (Exception e) { 
  182.             logger.error(e, e);
  183.             jedisPool.returnBrokenResource(jedis);
  184.             jedis = null;
  185.             throw e;
  186.         } finally { 
  187.             if (jedis != null) { 
  188.                 jedisPool.returnResource(jedis);
  189.             }
  190.         }
  191.     }
  193.     public static byte[] getBytes(String key) { 
  194.         Jedis jedis = jedisPool.getResource();
  195.         try { 
  196.             return jedis.get(key.getBytes());
  197.         } catch (Exception e) { 
  198.             logger.error(e, e);
  199.             jedisPool.returnBrokenResource(jedis);
  200.             jedis = null;
  201.             throw e;
  202.         } finally { 
  203.             if (jedis != null) { 
  204.                 jedisPool.returnResource(jedis);
  205.             }
  206.         }
  207.     }
  209.     public static void setBytes(String key, byte[] value, int expire) { 
  210.         Jedis jedis = jedisPool.getResource();
  211.         try { 
  212.             jedis.setex(key.getBytes(), expire, value);
  213.         } catch (Exception e) { 
  214.             logger.error(e, e);
  215.             jedisPool.returnBrokenResource(jedis);
  216.             jedis = null;
  217.             throw e;
  218.         } finally { 
  219.             if (jedis != null) { 
  220.                 jedisPool.returnResource(jedis);
  221.             }
  222.         }
  223.     }

3. set 封装

  1. /** * 将指定的成员添加到key对应的set中。如果成员已是集合的成员，则不执行任何操作。 * 如果key不存在，则创建一个新的集，其中指定的成员为唯一成员。 * 如果key存在但不包含设置值，则返回错误。 * * @param key 键 * @param members 放入set集合的成员数组（值） */
  2.     public static void sadd(final String key, final String... members) { 
  3.         Jedis jedis = jedisPool.getResource();
  4.         try { 
  5.             jedis.sadd(key, members);
  6.         } catch (Exception e) { 
  7.             logger.error(e, e);
  8.             jedisPool.returnBrokenResource(jedis);
  9.             jedis = null;
  10.             throw e;
  11.         } finally { 
  12.             if (jedis != null) { 
  13.                 jedisPool.returnResource(jedis);
  14.             }
  15.         }
  16.     }
  18.     /** * 如果成员是存储在键上的集合的成员，则返回1，否则返回0。 * * @param key 键 * @param member 元素值 * @return true 键对应的list包含member,false不包含 */
  19.     public static Boolean sismember(final String key, final String member) { 
  20.         Jedis jedis = jedisPool.getResource();
  21.         try { 
  22.             return jedis.sismember(key, member);
  23.         } catch (Exception e) { 
  24.             logger.error(e, e);
  25.             jedisPool.returnBrokenResource(jedis);
  26.             jedis = null;
  27.             throw e;
  28.         } finally { 
  29.             if (jedis != null) { 
  30.                 jedisPool.returnResource(jedis);
  31.             }
  32.         }
  33.     }
  35.     /** * 从key 对应的set集合中随意删除一个元素，并返回给对象，如果redis中没有该key，返回null * * @param key redis的一个key * @return string value */
  36.     public static String spop(final String key) { 
  38.         // 获取jedis
  39.         Jedis jedis = jedisPool.getResource();
  40.         try { 
  41.             return jedis.spop(key);
  42.         } catch (Exception e) { 
  43.             logger.error(e, e);
  44.             jedisPool.returnBrokenResource(jedis);
  45.             jedis = null;
  46.             throw e;
  47.         } finally { 
  48.             if (jedis != null) { 
  49.                 jedisPool.returnResource(jedis);
  50.             }
  51.         }
  52.     }
  54.     /** * 设置key-value;key之前不存在,设置key-value,返回true；key已经存在，不操作，返回false * * @param key 键 * @param value 值 * @return true :key之前不存在,设置key-value;false:key已经存在，不操作 */
  55.     public static Boolean setnx(final String key, final String value) { 
  56.         Jedis jedis = jedisPool.getResource();
  57.         try { 
  58.             // jedis.setnx(key,value)：如果key已经存在，不设置value,返回0；key不存在，重新设置value,返回1；
  59.             return jedis.setnx(key, value) == 1;
  60.         } catch (Exception e) { 
  61.             logger.error(e, e);
  62.             jedisPool.returnBrokenResource(jedis);
  63.             jedis = null;
  64.             throw e;
  65.         } finally { 
  66.             if (jedis != null) { 
  67.                 jedisPool.returnResource(jedis);
  68.             }
  69.         }
  70.     }

4. hash 封装

  1. /** * string-key,string-value * * @param key hash-key * @param field hashKey 对应的字段名称 * @param seconds 设置过期时间 * @param clazz value数据类型 * @return 返回 数据对象 */
  2.     public static <T> T hget(String key, String field, int seconds, Class<T> clazz) { 
  3.         Jedis jedis = jedisPool.getResource();
  4.         try { 
  5.             String str = jedis.hget(key, field);
  6.             if (!StringUtils.isEmpty(str)) { 
  7.                 jedis.expire(key, seconds);
  8.                 return JSON.parseObject(JSON.toJSONString(str), clazz);
  9.             }
  10.             return null;
  11.         } catch (Exception e) { 
  12.             logger.error(e, e);
  13.             jedisPool.returnBrokenResource(jedis);
  14.             jedis = null;
  15.             throw e;
  16.         } finally { 
  17.             if (jedis != null) { 
  18.                 jedisPool.returnResource(jedis);
  19.             }
  20.         }
  21.     }

发表评论

表情：
评论列表 （有 0 条评论，191人围观）

还没有评论，来说两句吧...

相关阅读

    相关 Jedis

    redis 应用场景 缓存（数据查询、短连接、新闻内容、商品内容等等） 聊天室的在线好友列表 任务队列。（秒杀、抢购、12306等等） 应用排行榜

    淡淡的烟草味﹌淡淡的烟草味﹌/ 0 赞/ 55 阅读

    相关 Jedis

    参考资料 Redis 单点模式和集群模式代码测试及问题记录：https://blog.csdn.net/boonya/article/details/49466003 Je

    末蓝、末蓝、/ 0 赞/ 207 阅读