【天天速看料】Redis实战之Jedis使用技巧详解
2023-05-06 17:55:42 来源：清一色财经
刚知道服务端的操作知识，还是远远不够的，如果想要真正在项目中得到应用，我们还需要一个 redis 的客户端，然后将其集成到项目中，让程序自动根据我们的业务需要自动处理。
【资料图】
一、摘要
在上一篇文章中，我们详细的介绍了 redis 的安装和常见的操作命令，以及可视化工具的介绍。
刚知道服务端的操作知识，还是远远不够的，如果想要真正在项目中得到应用，我们还需要一个 redis 的客户端，然后将其集成到项目中，让程序自动根据我们的业务需要自动处理。
基于 redis 开放的通信协议，大神们纷纷开发了各种语言的 redis 客户端，有 c、c++、java、python、php、nodeJs 等等开发语言的客户端，准确来说其实这些客户端都是基于 redis 命令做了一层封装，然后打包成工具以便大家更佳方便的操作 redis，以 Java 项目为例，使用最广的就是以下三种客户端：
JedisLettuceRedisson由于篇幅的原因，我们分三篇文章来详细的讲解每个客户端的使用方式以及它的优缺点。
废话不多说，直奔主题！
二、Jedis
Jedis 是老牌的 Redis 的 Java 客户端，提供了比较全面的 Redis 命令的操作支持，也是目前使用最广泛的客户端。
官方网址如下：
https://github.com/redis/jedis
如何在项目中集成 Jedis 呢？请看下文！
2.1、基本使用
首先创建一个普通的 Maven 项目，然后添加Jedis依赖包！
redis.clients jedis 3.9.0
然后创建一个简单的测试，即可实现连接！
public class JedisMain { public static void main(String[] args){ // 1.构造一个 Jedis 对象，因为这里使用的默认端口 6379，所以不用配置端口 Jedis jedis = new Jedis("127.0.0.1", 6379); // 2.密码认证 jedis.auth("111111"); // 3.测试是否连接成功 String ping = jedis.ping(); // 4.返回 pong 表示连接成功 System.out.println(ping); }}对于 Jedis 而言，一旦连接上了 Redis 服务器，剩下的操作就非常容易了，由于 Jedis 中的 API 和 Redis 的命令高度一致，所以，Jedis 中的方法见名知意，直接使用即可。
2.2、连接池
虽然 redis 服务端是单线程操作，但是在实际项目中，使用 Jedis 对象来操作 redis 时，每次操作都需要新建/关闭 TCP 连接，连接资源开销很高，同时 Jedis 对象的个数不受限制，在极端情况下可能会造成连接泄漏，同时 Jedis 存在多线程不安全的问题。
为什么说 Jedis 线程不安全，更加详细的原因可以访问这个地址https://www.cnblogs.com/gxyandwmm/p/13485226.html！
所以我们需要将 Jedis 交给线程池来管理，使用 Jedis 对象时，从连接池获取 Jedis，使用完成之后，再还给连接池。
在使用之前，需要添加common-pool线程池依赖包！
org.apache.commons commons-pool2 2.11.1
创建一个简单的使用线程池测试用例。
public class JedisPoolMain { public static void main(String[] args){ // 1. 构造一个 Jedis 连接池 JedisPool pool = new JedisPool("127.0.0.1", 6379); // 2. 从连接池中获取一个 Jedis 连接 Jedis jedis = pool.getResource(); jedis.auth("111111"); // 3. Jedis 操作 String ping = jedis.ping(); System.out.println(ping); // 4. 归还连接 jedis.close(); }}2.3、连接池配置
在实际的使用过程中，我们常常会这样来初始化线程池JedisPool，详细代码如下：
public class RedisPoolUtils { private static JedisPool jedisPool = null; /** * redis服务器地址 */ private static String addr = "127.0.0.1"; /** * redis服务器端口 */ private static int port = 6379; /** * redis服务器密码 */ private static String auth = "111111"; static{ try { JedisPoolConfig config = new JedisPoolConfig(); //连接耗尽时是否阻塞, false报异常,ture阻塞直到超时, 默认true config.setBlockWhenExhausted(true); //设置的逐出策略类名, 默认DefaultEvictionPolicy(当连接超过最大空闲时间,或连接数超过最大空闲连接数) config.setEvictionPolicyClassName("org.apache.commons.pool2.impl.DefaultEvictionPolicy"); //是否启用pool的jmx管理功能, 默认true config.setJmxEnabled(true); //MBean ObjectName = new ObjectName("org.apache.commons.pool2:type=GenericObjectPool,name=" + "pool" + i); 默认为"pool", JMX不熟,具体不知道是干啥的...默认就好. config.setJmxNamePrefix("pool"); //是否启用后进先出, 默认true config.setLifo(true); //最大空闲连接数, 默认8个 config.setMaxIdle(8); //最大连接数, 默认8个 config.setMaxTotal(8); //获取连接时的最大等待毫秒数(如果设置为阻塞时BlockWhenExhausted),如果超时就抛异常, 小于零:阻塞不确定的时间, 默认-1 config.setMaxWaitMillis(-1); //逐出连接的最小空闲时间 默认1800000毫秒(30分钟) config.setMinEvictableIdleTimeMillis(1800000); //最小空闲连接数, 默认0 config.setMinIdle(0); //每次逐出检查时 逐出的最大数目 如果为负数就是 : 1/abs(n), 默认3 config.setNumTestsPerEvictionRun(3); //对象空闲多久后逐出, 当空闲时间>该值 且 空闲连接>最大空闲数 时直接逐出,不再根据MinEvictableIdleTimeMillis判断 (默认逐出策略) config.setSoftMinEvictableIdleTimeMillis(1800000); //在获取连接的时候检查有效性, 默认false config.setTestOnBorrow(false); //在空闲时检查有效性, 默认false config.setTestWhileIdle(false); //逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1 config.setTimeBetweenEvictionRunsMillis(-1); jedisPool = new JedisPool(config, addr, port, 3000, auth); } catch (Exception e) { e.printStackTrace(); } } /** * 获取 Jedis 资源 * @return */ public static Jedis getJedis(){ if (jedisPool != null) { return jedisPool.getResource(); } return null; } /** * 释放Jedis资源 */ public static void close(final Jedis jedis){ if (jedis != null) { jedis.close(); } }}简单测试:
public static void main(String[] args) throws InterruptedException { //获取 jedis 客户端 Jedis jedis = RedisPoolUtils.getJedis(); System.out.println("清空数据："+jedis.flushDB()); System.out.println("判断某个键是否存在："+jedis.exists("username")); System.out.println("新增<"username","xmr">的键值对："+jedis.set("username", "xmr")); System.out.println(jedis.exists("username")); System.out.println("新增<"password","password">的键值对："+jedis.set("password", "123")); System.out.print("系统中所有的键如下："); Set keys = jedis.keys("*"); System.out.println(keys); System.out.println("删除键password:"+jedis.del("password")); System.out.println("判断键password是否存在："+jedis.exists("password")); System.out.println("设置键username的过期时间为5s:"+jedis.expire("username", 8L)); TimeUnit.SECONDS.sleep(1); System.out.println("查看键username的剩余生存时间："+jedis.ttl("username")); System.out.println("移除键username的生存时间："+jedis.persist("username")); System.out.println("查看键username的剩余生存时间："+jedis.ttl("username")); System.out.println("查看键username所存储的值的类型："+jedis.type("username")); RedisPoolUtils.close(jedis);} 运行结果如下：
清空数据：OK判断某个键是否存在：false新增<"username","xmr">的键值对：OKtrue新增<"password","password">的键值对：OK系统中所有的键如下：[password, username]删除键password:1判断键password是否存在：false设置键username的过期时间为5s:1查看键username的剩余生存时间：7移除键username的生存时间：1查看键username的剩余生存时间：-1查看键username所存储的值的类型：string
2.4、字符串常用 API 操作
public class RedisClientUtil { private static final Logger log = LoggerFactory.getLogger(RedisClientUtil.class); /** * 获取指定key的值,如果key不存在返回null * 返回值：返回 key 的值，如果 key 不存在时，返回 nil * @param key * @return */ public static String get(String key){ try (Jedis jedis = jedisPool.getResource()) { return jedis.get(key); } catch (Exception e){ log.error("get命令操作失败，请求参数：{}", key,e); } return null; } /** * 设置key的值为value * 返回值：操作成功完成时返回 OK * @param key * @return */ public static String set(String key, String value){ try (Jedis jedis = jedisPool.getResource()) { return jedis.set(key, value); } catch (Exception e){ log.error("set命令操作失败，参数key：{}，参数value：{}", key, value,e); } return null; } /** * 删除指定的key，返回值：被删除 key 的数量 * 返回值：被删除 key 的数量 * @param key * @return */ public static Long del(String key){ try (Jedis jedis = jedisPool.getResource()) { Long result = jedis.del(key); return jedis.del(key); } catch (Exception e){ log.error("del命令操作失败，参数key：{}", key,e); } return 0L; } /** * 通过key向指定的value值追加值 * 返回值：追加指定值之后， key中字符串的长度 * @param key * @return */ public static Long append(String key, String value){ try (Jedis jedis = jedisPool.getResource()) { return jedis.append(key, value); } catch (Exception e){ log.error("append命令操作失败，参数key：{}，参数value：{}", key, value,e); } return 0L; } /** * 判断key是否存在 * 返回值：true/false * @param key * @return */ public static Boolean exists(String key){ try (Jedis jedis = jedisPool.getResource()) { return jedis.exists(key); } catch (Exception e){ log.error("exists命令操作失败，参数key：{}", key,e); } return false; } /** * 设置key的超时时间为seconds * 返回值：若 key 存在返回 1 ，否则返回 0 * @param key * @return */ public static Long expire(String key, long seconds){ try (Jedis jedis = jedisPool.getResource()) { return jedis.expire(key, seconds); } catch (Exception e){ log.error("expire命令操作失败，参数key：{}，参数seconds：{}", key, seconds,e); } return 0L; } /** * 返回 key 的剩余过期时间（单位秒） * 返回值：当 key 不存在时，返回 -2 。 当 key 存在但没有设置剩余生存时间时，返回 -1 。 否则，以秒为单位，返回 key 的剩余生存时间 * @param key * @return */ public static Long ttl(String key){ try (Jedis jedis = jedisPool.getResource()) { return jedis.ttl(key); } catch (Exception e){ log.error("ttl命令操作失败，参数key：{}", key,e); } return 0L; } /** * 设置指定key的值为value,当key不存在时才设置 * 返回值：设置成功返回 1，设置失败返回 0 * @param key * @return */ public static Long setnx(String key, String value){ try (Jedis jedis = jedisPool.getResource()) { return jedis.setnx(key, value); } catch (Exception e){ log.error("setnx命令操作失败，参数key：{}，参数value：{}", key, value,e); } return 0L; } /** * 设置指定key的值为value,并设置过期时间 * 返回值：设置成功时返回 OK * @param key * @return */ public static String setex(String key, String value, long seconds){ try (Jedis jedis = jedisPool.getResource()) { return jedis.setex(key, seconds, value); } catch (Exception e){ log.error("setex命令操作失败，参数key：{}，参数value：{}", key, value,e); } return null; } /** * 通过key 和offset 从指定的位置开始将原先value替换 * 返回值：被修改后的字符串长度 * @param key * @return */ public static Long setrange(String key, int offset, String value){ try (Jedis jedis = jedisPool.getResource()) { return jedis.setrange(key, offset, value); } catch (Exception e){ log.error("setrange命令操作失败，参数key：{}，参数value：{}，参数offset：{}", key, value, offset,e); } return null; } /** * 通过批量的key获取批量的value * 返回值：一个包含所有给定 key 的值的列表。 * @param keys * @return */ public static List mget(String... keys){ try (Jedis jedis = jedisPool.getResource()) { return jedis.mget(keys); } catch (Exception e){ log.error("mget命令操作失败，参数key：{}", keys.toString(),e); } return null; } /** * 批量的设置key:value,也可以一个 * 返回值：总是返回 OK * @param keysValues * @return */ public static String mset(String... keysValues){ try (Jedis jedis = jedisPool.getResource()) { return jedis.mset(keysValues); } catch (Exception e){ log.error("mset命令操作失败，参数key：{}", keysValues.toString(),e); } return null; } /** * 设置key的值,并返回一个旧值 * 返回值：返回给定 key 的旧值，当 key 没有旧值时，即 key 不存在时，返回 nil * @param key * @return */ public static String getSet(String key, String value){ try (Jedis jedis = jedisPool.getResource()) { return jedis.getSet(key, value); } catch (Exception e){ log.error("getSet命令操作失败，参数key：{}，参数value：{}", key, value,e); } return null; } /** * 通过下标和 key 获取指定下标位置的 value * 返回值：截取得到的子字符串 * @param key * @return */ public static String getrange(String key, int startOffset, int endOffset){ try (Jedis jedis = jedisPool.getResource()) { return jedis.getrange(key, startOffset, endOffset); } catch (Exception e){ log.error("getrange命令操作失败，参数key：{}，参数startOffset：{}，参数offset：{}", key, startOffset, endOffset,e); } return null; } /** * 通过key 对value进行加值+1操作,当value不是int类型时会返回错误,当key不存在是则value为1 * 返回值：执行INCR命令之后 key 的值 * @param key * @return */ public static Long incr(String key){ try (Jedis jedis = jedisPool.getResource()) { return jedis.incr(key); } catch (Exception e){ log.error("incr命令操作失败，参数key：{}", key, e); } return 0L; } /** * 通过key给指定的value加值 * 返回值：执行INCR命令之后 key 的值 * @param key * @return */ public static Long incrBy(String key, long increment){ try (Jedis jedis = jedisPool.getResource()) { return jedis.incrBy(key, increment); } catch (Exception e){ log.error("incrBy命令操作失败，参数key：{}，参数increment：{}", key, increment,e); } return 0L; } /** * 对key的值做减减操作 * 返回值：执行INCR命令之后 key 的值 * @param key * @return */ public static Long decr(String key){ try (Jedis jedis = jedisPool.getResource()) { return jedis.decr(key); } catch (Exception e){ log.error("decr命令操作失败，参数key：{}", key, e); } return 0L; } /** * 对key的值做减减操作,减去指定的值 * 返回值：执行INCR命令之后 key 的值 * @param key * @return */ public static Long decrBy(String key, long decrement){ try (Jedis jedis = jedisPool.getResource()) { return jedis.decrBy(key, decrement); } catch (Exception e){ log.error("decrBy命令操作失败，参数key：{}，参数decrement：{}", key, decrement,e); } return 0L; } /** * 通过key获取value值的长度 * 返回值：value值的长度 * @param key * @return */ public static Long strlen(String key){ try (Jedis jedis = jedisPool.getResource()) { return jedis.strlen(key); } catch (Exception e){ log.error("strlen命令操作失败，参数key：{}", key, e); } return 0L; }} 2.5、哈希常用 API 操作
public class RedisClientUtil { private static final Logger log = LoggerFactory.getLogger(RedisClientUtil.class); /** * 通过key 和 field 获取指定的 value * 返回值：对应的value值 * @param key * @return */ public static String hget(String key, String field){ try (Jedis jedis = jedisPool.getResource()) { return jedis.hget(key, field); } catch (Exception e){ log.error("hget命令操作失败，参数key：{}，参数field：{}", key, field,e); } return null; } /** * 通过key给field设置指定的值,如果key不存在,则先创建 * 返回值：如果字段是哈希表中的一个新建字段，并且值设置成功，返回 1 ;如果哈希表中域字段已经存在且旧值已被新值覆盖，返回 0 。 * @param key * @return */ public static Long hset(String key, String field, String value){ try (Jedis jedis = jedisPool.getResource()) { return jedis.hset(key, field, value); } catch (Exception e){ log.error("hset命令操作失败，参数key：{}，参数field：{}，参数value：{}", key, field, value,e); } return 0L; } /** * 通过key和field判断是否有指定的value存在 * 返回值：true/false * @param key * @return */ public static Boolean hexists(String key, String field){ try (Jedis jedis = jedisPool.getResource()) { return jedis.hexists(key, field); } catch (Exception e){ log.error("hexists命令操作失败，参数key：{}，参数field：{}", key, field,e); } return false; } /** * 通过key返回field的数量 * 返回值：field的数量 * @param key * @return */ public static Long hlen(String key){ try (Jedis jedis = jedisPool.getResource()) { return jedis.hlen(key); } catch (Exception e){ log.error("hlen命令操作失败，参数key：{}", key,e); } return 0L; } /** * 通过key 删除指定的 field * 返回值：删除的数量 * @param key * @return */ public static Long hdel(String key, String... fields){ try (Jedis jedis = jedisPool.getResource()) { return jedis.hdel(key, fields); } catch (Exception e){ log.error("hdel命令操作失败，参数key：{}，参数fields：{}", key, fields.toString(),e); } return 0L; } /** * 通过key返回所有的field * 返回值：field集合 * @param key * @return */ public static Set hkeys(String key){ try (Jedis jedis = jedisPool.getResource()) { return jedis.hkeys(key); } catch (Exception e){ log.error("hkeys命令操作失败，参数key：{}", key,e); } return null; } /** * 通过key获取所有的field和value * 返回值：map对象 * @param key * @return */ public static Map hgetAll(String key){ try (Jedis jedis = jedisPool.getResource()) { return jedis.hgetAll(key); } catch (Exception e){ log.error("hgetAll命令操作失败，参数key：{}", key,e); } return null; }} 2.6、列表常用 API 操作
public class RedisClientUtil { private static final Logger log = LoggerFactory.getLogger(RedisClientUtil.class); /** * 过key向list头部添加字符串 * 返回值：执行 LPUSH 命令后，列表的长度 * @param key * @return */ public static Long lpush(String key, String... strs){ try (Jedis jedis = jedisPool.getResource()) { return jedis.lpush(key, strs); } catch (Exception e){ log.error("lpush命令操作失败，参数key：{}，参数strs：{}", key, strs.toString(),e); } return null; } /** * 通过key向list尾部添加字符串 * 返回值：执行 RPUSH 命令后，列表的长度 * @param key * @return */ public static Long rpush(String key, String... strs){ try (Jedis jedis = jedisPool.getResource()) { return jedis.rpush(key, strs); } catch (Exception e){ log.error("rpush命令操作失败，参数key：{}，参数strs：{}", key, strs.toString(),e); } return null; } /** * 通过key设置list指定下标位置的value 如果下标超过list里面value的个数则报错 * 返回值：操作成功返回 ok ，否则返回错误信息 * @param key * @return */ public static String lset(String key, Long index, String value){ try (Jedis jedis = jedisPool.getResource()) { return jedis.lset(key, index, value); } catch (Exception e){ log.error("lset命令操作失败，参数key：{}，参数index：{}，参数value：{}", key, index, value,e); } return null; } /** * 通过key从对应的list中删除指定的count个 和 value相同的元素 * 返回值：返回被删除的个数 * @param key * @return */ public static Long lrem(String key, long count, String value){ try (Jedis jedis = jedisPool.getResource()) { return jedis.lrem(key, count, value); } catch (Exception e){ log.error("lrem命令操作失败，参数key：{}，参数count：{}，参数value：{}", key, count, value,e); } return null; } /** * 通过key保留list中从strat下标开始到end下标结束的value值 * 返回值：操作成功返回 ok ，否则返回错误信息 * @param key * @return */ public static String ltrim(String key, long start, long end){ try (Jedis jedis = jedisPool.getResource()) { return jedis.ltrim(key, start, end); } catch (Exception e){ log.error("ltrim命令操作失败，参数key：{}，参数start：{}，参数end：{}", key, start, end,e); } return null; } /** * 通过key从list的头部删除一个value,并返回该value * 返回值：value值 * @param key * @return */ public static String lpop(String key){ try (Jedis jedis = jedisPool.getResource()) { return jedis.lpop(key); } catch (Exception e){ log.error("lpop命令操作失败，参数key：{}", key,e); } return null; } /** * 通过key从list尾部删除一个value,并返回该元素 * 返回值：value值 * @param key * @return */ public static String rpop(String key){ try (Jedis jedis = jedisPool.getResource()) { return jedis.rpop(key); } catch (Exception e){ log.error("rpop命令操作失败，参数key：{}", key,e); } return null; } /** * 通过key获取list中指定下标位置的value * 返回值：value值 * @param key * @return */ public static String lindex(String key, long index){ try (Jedis jedis = jedisPool.getResource()) { return jedis.lindex(key, index); } catch (Exception e){ log.error("lindex命令操作失败，参数key：{}，参数index：{}", key, index,e); } return null; } /** * 通过key返回list的长度 * 返回值：value值 * @param key * @return */ public static Long llen(String key){ try (Jedis jedis = jedisPool.getResource()) { return jedis.llen(key); } catch (Exception e){ log.error("llen命令操作失败，参数key：{}", key,e); } return null; } /** * 通过key获取list指定下标位置的value 如果start 为 0 end 为 -1 则返回全部的list中的value * 返回值：value值 * @param key * @return */ public static List lrange(String key, long start, long end){ try (Jedis jedis = jedisPool.getResource()) { return jedis.lrange(key, start, end); } catch (Exception e){ log.error("lrange命令操作失败，参数key：{}，参数start：{}，参数end：{}", key, start, end,e); } return null; }} 2.7、集合常用 API 操作
public class RedisClientUtil { private static final Logger log = LoggerFactory.getLogger(RedisClientUtil.class); /** * 通过key向指定的set中添加value * 返回值：添加成功的个数 * @param key * @return */ public static Long sadd(String key, String... members){ try (Jedis jedis = jedisPool.getResource()) { return jedis.sadd(key, members); } catch (Exception e){ log.error("sadd命令操作失败，参数key：{}，参数members：{}", key, members.toString(),e); } return null; } /** * 通过key删除set中对应的value值 * 返回值：删除成功的个数 * @param key * @return */ public static Long srem(String key, String... members){ try (Jedis jedis = jedisPool.getResource()) { return jedis.srem(key, members); } catch (Exception e){ log.error("srem命令操作失败，参数key：{}，参数members：{}", key, members.toString(),e); } return null; } /** * 通过key获取set中value的个数 * 返回值：value的个数 * @param key * @return */ public static Long scard(String key){ try (Jedis jedis = jedisPool.getResource()) { return jedis.scard(key); } catch (Exception e){ log.error("scard命令操作失败，参数key：{}", key,e); } return 0L; } /** * 通过key判断value是否是set中的元素 * 返回值：true/false * @param key * @return */ public static Boolean sismember(String key, String member){ try (Jedis jedis = jedisPool.getResource()) { return jedis.sismember(key, member); } catch (Exception e){ log.error("sismember命令操作失败，参数key：{}，参数member：{}", key, member,e); } return false; } /** * 通过key获取set中所有的value * 返回值：所有的value * @param key * @return */ public static Set smembers(String key){ try (Jedis jedis = jedisPool.getResource()) { return jedis.smembers(key); } catch (Exception e){ log.error("smembers命令操作失败，参数key：{}", key,e); } return null; }} 2.8、有序集合常用 API 操作
public class RedisClientUtil { private static final Logger log = LoggerFactory.getLogger(RedisClientUtil.class); /** * 通过key向zset中添加value,score,其中score就是用来排序的 如果该value已经存在则根据score更新元素 * 返回值：被成功添加的新成员的数量，不包括那些被更新的、已经存在的成员 * @param key * @return */ public static Long zadd(String key, double score, String member){ try (Jedis jedis = jedisPool.getResource()) { return jedis.zadd(key, score, member); } catch (Exception e){ log.error("zadd命令操作失败，参数key：{}，参数score：{}，参数member：{}", key, score, member,e); } return null; } /** * 通过key删除在zset中指定的value * 返回值：删除个数 * @param key * @return */ public static Long zrem(String key, String... members){ try (Jedis jedis = jedisPool.getResource()) { return jedis.zrem(key, members); } catch (Exception e){ log.error("zrem命令操作失败，参数key：{}，参数members：{}", key, members.toString(),e); } return null; } /** * 通过key增加该zset中value的score的值 * 返回值：member 成员的新分数值 * @param key * @return */ public static Double zincrby(String key, double score, String member){ try (Jedis jedis = jedisPool.getResource()) { return jedis.zincrby(key, score, member); } catch (Exception e){ log.error("zincrby命令操作失败，参数key：{}，参数score：{}，参数member：{}", key, score, member,e); } return null; } /** * 通过key返回zset中value的排名 下标从小到大排序 * 返回值：返回 member 的排名 * @param key * @return */ public static Long zrank(String key, String member){ try (Jedis jedis = jedisPool.getResource()) { return jedis.zrank(key, member); } catch (Exception e){ log.error("zrank命令操作失败，参数key：{}，参数member：{}", key, member,e); } return null; } /** * 通过key将获取score从start到end中zset的value socre从大到小排序 当start为0 end为-1时返回全部 * 返回值：返回 member 集合 * @param key * @return */ public static Set zrevrange(String key, long start, long end){ try (Jedis jedis = jedisPool.getResource()) { return jedis.zrevrange(key, start, end); } catch (Exception e){ log.error("zrevrange命令操作失败，参数key：{}，参数start：{}，参数end：{}", key, start, end,e); } return null; } /** * 返回指定区间内zset中value的数量 * 返回值：返回 member 集合 * @param key * @return */ public static Long zcount(String key, String min, String max){ try (Jedis jedis = jedisPool.getResource()) { return jedis.zcount(key, min, max); } catch (Exception e){ log.error("zcount命令操作失败，参数key：{}，参数min：{}，参数max：{}", key, min, max,e); } return null; } /** * 通过key返回zset中的value个数 * 返回值：返回 member 集合 * @param key * @return */ public static Long zcard(String key){ try (Jedis jedis = jedisPool.getResource()) { return jedis.zcard(key); } catch (Exception e){ log.error("zcard命令操作失败，参数key：{}", key,e); } return null; } /** * 返回满足pattern表达式的所有key keys(*) 返回所有的key * 返回值：返回 key 集合 * @param pattern * @return */ public static Set keys(String pattern){ try (Jedis jedis = jedisPool.getResource()) { return jedis.keys(pattern); } catch (Exception e){ log.error("keys命令操作失败，参数pattern：{}", pattern,e); } return null; } /** * 通过key判断值得类型 * 返回值：值的类型 * @param key * @return */ public static String type(String key){ try (Jedis jedis = jedisPool.getResource()) { return jedis.type(key); } catch (Exception e){ log.error("type命令操作失败，参数key：{}", key,e); } return null; }} 三、集群配置
在实际的项目生产环境中，redis 通常不是以单台服务实例来运行的，因为一旦服务器挂了，可能所有的下游服务都会受到影响，因此为了保障单台服务器即使出现故障也能运行，通常运维组会搭建集群环境，来保证服务高可用。
搭建的方式有两种，哨兵模式和 Cluster 模式。
哨兵模式：对redis服务器进行监控，如果有宕机的，就从备机里面选一个出来作为主机，实现自动切换Cluster 模式：将数据进行分片存储，避免全部节点数据都一样，浪费空间3.1、哨兵模式
哨兵模式简单的说，就是一台主机，一台备机，外加一台监控服务，当监控服务观测到主机已经宕机，就会将备用机切换成主机，以便继续提供服务。
public class RedisPoolUtils { private static Jedis jedis; private static JedisSentinelPool jedisSentinelPool; static{ try { JedisPoolConfig config = new JedisPoolConfig(); //最大空闲连接数, 默认8个 config.setMaxIdle(8); //最大连接数, 默认8个 config.setMaxTotal(8); //最小空闲连接数, 默认0 config.setMinIdle(0); //获取连接时的最大等待毫秒数(如果设置为阻塞时BlockWhenExhausted),如果超时就抛异常, 小于零:阻塞不确定的时间, 默认-1 config.setMaxWaitMillis(3000); //在获取连接的时候检查有效性,表示取出的redis对象可用, 默认false config.setTestOnBorrow(true); //redis服务器列表 Set sentinels = new HashSet<>(); sentinels.add(new HostAndPort("192.168.43.212", 26379).toString()); sentinels.add(new HostAndPort("192.168.43.213", 26379).toString()); sentinels.add(new HostAndPort("192.168.43.214", 26379).toString()); //初始化连接池 jedisSentinelPool = new JedisSentinelPool("mymaster", sentinels, config, "111111"); // 从池中获取一个Jedis对象 jedis = jedisSentinelPool.getResource(); } catch (Exception e) { e.printStackTrace(); } } } 3.2、集群模式
为了保证高可用，redis-cluster集群通常会引入主从复制模型，一个主节点对应一个或者多个从节点，当主节点宕机的时候，就会启用从节点。
public class RedisPoolUtils { static{ try { JedisPoolConfig config = new JedisPoolConfig(); //最大空闲连接数, 默认8个 config.setMaxIdle(8); //最大连接数, 默认8个 config.setMaxTotal(8); //最小空闲连接数, 默认0 config.setMinIdle(0); //获取连接时的最大等待毫秒数(如果设置为阻塞时BlockWhenExhausted),如果超时就抛异常, 小于零:阻塞不确定的时间, 默认-1 config.setMaxWaitMillis(3000); //在获取连接的时候检查有效性,表示取出的redis对象可用, 默认false config.setTestOnBorrow(true); Set nodes = new HashSet<>(); nodes.add(new HostAndPort("192.168.43.212", 26379)); nodes.add(new HostAndPort("192.168.43.213", 26379)); nodes.add(new HostAndPort("192.168.43.214", 26379)); JedisCluster jedisCluster = new JedisCluster(nodes, config); jedisCluster.set("key", "hello world"); jedisCluster.close(); } catch (Exception e) { e.printStackTrace(); } }} 四、小结
jedis客户端是目前使用最广泛的一款 java 客户端，也是老牌的 Redis 的 Java 实现客户端。
优点很突出：
比较全面的提供了 Redis 的操作特性，也就是说你能用 redis 命令操作的，Jedis 包都也给你封装好了，直接使用即可使用广泛，易上手当然，缺点也有：
Jedis 客户端实例不是线程安全的，需要借助连接池来管理和使用 Jedis使用阻塞的I/O，且其方法调用都是同步的，程序流需要等到 sockets 处理完 I/O 才能执行，不支持异步本文主要是围绕jedis客户端做了一次知识总结，希望能帮助到大家，内容难免有所遗漏，欢迎批评指出！
五、参考
1、redis – 中文文档
2、腾讯云 – redis几种java客户端比较
3、runoob – redis教程
4、简书 – redis java 客户端
- 广东省一项研究揭示：新冠再次感染发生率有多高？阳后症状如何？ 全球热消息
- 光速光合朱嘉：新能源交通是未来几年最主要的投资方向
- 天山发展控股(02118.HK)：委任清盘人-今日讯
- 速递！海隆控股(01623.HK)附属签订1200万美元海底管道舖设合同
- 近7成应届生求职最关注薪酬福利，46.7%毕业生首选国企
- 助力 “赶烤”创业潮，澳柯玛商用创业季开启 当前速读
- 信息：世卫组织宣布新冠大流行紧急状态终结，利好国际旅游市场复苏
- 面向团队的嵌入式 Linux
- 全国大学生“智营销”大赛澳柯玛赛道圆满结束
- 北京冬奥组委财务收支报告公布：结余3.5亿元人民币-快播
- 多地政策和资金“来袭”，燃料电池产业迎来新一波发展机遇|热头条
- 【天天速看料】Redis实战之Jedis使用技巧详解
- 全球今头条！雅高控股(03313.HK)拟配发4600万股认购股份 净筹1283万港元
- 天天时讯：上海市网信办：上海首批两家企业通过数据出境安全评估
- 当前快报:复宏汉霖：HLX26联合汉斯状和化疗一线治疗晚期非小细胞肺癌2期临床试验申请获批
- 面试官提问：什么是前缀索引？|全球观焦点
- 勒索软件谈判的注意事项|新视野
- 纯净安装，微软 Windows 11 Build 22483 预览版 ISO 官方镜像下载-全球观察
- 微软2023年1月份于周二补丁日针对98个漏洞发布安全补丁_全球消息
- Flowable 流程实例的挂起（暂停）与激活
- 融创中国(01918.HK)首四月合同销售额人民币373.3亿元 精选
- AMD计划淘汰AGESA固件 改用openSIL与服务器统一 世界热推荐
- 董明珠4亿市值股份被冻结？格力电器：搞错了…… 天天快看
- 一个隐藏在图片中的恶意软件正在亚、非地区泛滥 全球讯息
- 天天观速讯丨长城汽车(02333.HK)申请增设人民币柜台
- 金地商置(00535.HK)首4月合约销售总额129.66亿元人民币
- 当前关注：南方锰业(01091.HK)：委任副总裁
- 银城国际控股(01902.HK)首4月合约销售额约人民币32.616亿元
- PS格式全介绍 jpg/jpeg/jpeg2000有啥区别
- 今日精选：2023年退休金涨幅预估:养老金19连涨来了！快看看你能涨多少？
- 天天即时看！比 SQL 快？这个数据库神器强的离谱！
- 儿童手表定位，活动范围监控—修改版
- 全球即时：No.6 – 时序数据库随笔 – InfluxDB&Flux调试环境搭建
- 播报：凯美特气：公司2022年度向特定对象发行股票的定价基准日为发行期首日，目前具体日期尚未确定
- CC好物折扣公园：生活折扣店赚钱要靠供应链！
- 【全球新视野】Apache Druid历险记
- 每日动态!建业地产(00832.HK)首4月物业合同销售总额人民币70.41亿元
- 世界今热点：好强的谷歌“Excel”，不用自己写代码就能爬虫，网友立马cue微软：慌不慌？
- 鄂州新名片！又一重点项目进展来了
- 中国光大控股(00165.HK)：王云获任执行董事等职务 讯息
- Hi3516的SAMGR–系统服务框架子系统-11-Client与Client的IPC来往
- 海尔智家大脑：未来家的样子是“深度智慧生活” 天天快报
- 微软 Windows 11 将重点优化 Windows 32 应用，为其带来现代化界面
- 碧生源(00926.HK)拟1.377亿元出售三家目标公司各51%股权
- MySQL的零拷贝技术
- 2023年度“琴岛e保”再升级，5月9日启动
- 怪可爱的店收藏物品攻略大全_世界快播报
- 万科企业(02202.HK)4月合同销售额334.7亿元人民币
- 石家庄市教育系统举行2023年新团员集体入团仪式暨“五四”表彰会
- 多家银行下调存款利率！
- 中原建业(09982.HK)首四月在管项目合约销售70.31亿人民币 同比增长5.5% 环球微速讯
- 民营银行晒2022年“成绩单”：部分银行存款增速“掉队”，差异化突围任重道远|微头条
- EntityFrameworkCore上下文如何实现继承？
- 读 MAUI 源代码 理解可绑定对象和可绑定属性的存储机制-环球新视野
- 把你的树莓派变成一个 HiFi 音乐系统|焦点
- 世界观焦点：教你在 Linux 中使用 Lsusb命令 显示有关USB设备信息
- Windows 10下发新补丁 修复蓝屏、打印出错等问题_世界滚动
- 世界新资讯：英国竞争管理局审查 AI 模型风险
- 天天快看点丨【盈喜】阿里健康(00241.HK)年度扭亏为盈净利润不少于人民币4.5亿元
- 凤祥股份(09977.HK)首季总收入降至约11.76亿元人民币 天天微头条
- 时代中国(01233.HK)前四个月合同销售额人民币69.45亿元 当前热点
- 今日最新！斐讯psg1218千兆口是哪个_斐讯psg1218是千兆口吗
- 上海新科脑康医院-上海看癫痫病医院排名【十佳医院】 世界信息
- 张文宏深夜发声：病毒还会存在，大流行已经过去_全球关注
- 客户导向重塑全“心”服务 “我家阳光”APP迎来全新体验升级
- 君实生物(01877.HK)与瑞迪博士实验室签署许可与商业化协议
- 世界通讯！2023年5月6日云南省西葫芦批发价格行情
- 中国心连心化肥(01866.HK)首季综合纯利同比减少11%-世界今日报
- 环球百事通！绿城中国(03900.HK)首四月总合同销售额约人民币884亿元
- 危机管理体系建设的关键_危机管理
- 世界热推荐：央行今日开展20亿元人民币7天期逆回购操作
- 环球速读：国网青岛供电公司：创新研发推广“数字员工”家族
- 室内装修要买保险吗？给装修工人买什么保险？
- 青春中国丨潜心寻古周强 最是坚韧系传承-当前热讯
- 【全球速看料】正荣地产(06158.HK)4月合约销售额约人民币16.54亿元
- 顺丰同城(09699.HK)拟1.24亿人民币出售线上团餐服务平台业务公司
- 交强险赔偿后商业险会上涨吗？交强险出多了会怎么样？
- 交强险第二年打几折？交强险第二年换保险公司还有优惠吗？
- 医院的wifi可以用吗(医院有wifi用吗)
- 车险的特点有哪些？车险定损有什么猫腻？
- 明源云(00909.HK)获执行董事兼控股股东合计增持200万股
- 美的去年净利296亿元背后：ToB业务突进科技领先战略提速-环球新消息
- 【国际大宗商品早报】美国就业数据高于预期纽约金价跌超1% 美油大涨超4%
- 世界关注：在昨天的推文里妲己宝宝提到了神秘的______炸弹在数字空间中肆意扩张。王者荣耀每日一题5月6日答案
- 信用卡很多影响征信吗？信用卡最低还款的坏处是什么？
- 什么是中央银行票据？中央银行票据分为哪几种？
- 公积金提取多久能到账？公积金一次能提取多少？
- 美股终结四连跌！区域性银行股大举反攻，苹果大涨近5%
- 5月5日基金净值：交银瑞和三年持有期混合最新净值0.9843，跌0.41%
- 预计2022年突破万亿元 大数据产业增长迅猛
- 美执法部门再下一城：取缔交易失窃登录凭证的SlilPP黑市
- 八成金融APP存在数据泄露严重漏洞
- 《塞尔达传说：王国之泪》开启预下载，5 月 12 日开放 世界快消息
- 英特尔最新补丁修补了CPU、蓝牙产品中的隐患 安全库中也被发现漏洞_世界观点
- 拜登撤销对TikTok、WeChat的禁令，启动对外国应用程序的审查 环球信息
- 鸭河口水库：开启文旅融合发展新局面
- 商务部：从未主管、指导或参与“世界汽车大会”
- 全球快报:充气蹦极安装_充气蹦极
- 谐音对联大全_谐音对联
- 每日短讯：“五一”假期蓟州旅游市场强劲复苏 打造全时全域旅游区
热门产品排行榜
编辑推荐排行榜
- 1 广东省一项研究揭示：新冠再次感染发生率有多高？阳后症状如何？ 全球热消息
- 2 光速光合朱嘉：新能源交通是未来几年最主要的投资方向
- 3 天山发展控股(02118.HK)：委任清盘人-今日讯
- 4 速递！海隆控股(01623.HK)附属签订1200万美元海底管道舖设合同
- 5 近7成应届生求职最关注薪酬福利，46.7%毕业生首选国企
- 6 助力 “赶烤”创业潮，澳柯玛商用创业季开启 当前速读
- 7 信息：世卫组织宣布新冠大流行紧急状态终结，利好国际旅游市场复苏
- 8 面向团队的嵌入式 Linux
- 9 全国大学生“智营销”大赛澳柯玛赛道圆满结束
- 10 北京冬奥组委财务收支报告公布：结余3.5亿元人民币-快播