Jedis

wang--lei 2021-08-29 原文

使用Jedis

需要把jedis依赖的jar包添加到工程中。Maven工程中需要把jedis的坐标添加到依赖。

1.1. 连接单机版

第一步：创建一个Jedis对象。需要指定服务端的ip及端口。

第二步：使用Jedis对象操作数据库，每个redis命令对应一个方法。

第三步：打印结果。

第四步：关闭Jedis

 1 @Test
 2 public void testJedis() throws Exception {
 3     // 第一步：创建一个Jedis对象。需要指定服务端的ip及端口。
 4     Jedis jedis = new Jedis("192.168.1.***", 6379);
 5     // 第二步：使用Jedis对象操作数据库，每个redis命令对应一个方法。
 6     String result = jedis.get("hello");
 7     // 第三步：打印结果。
 8     System.out.println(result);
 9     // 第四步：关闭Jedis
10     jedis.close();
11 }

1.2. 连接单机版使用连接池

第一步：创建一个JedisPool对象。需要指定服务端的ip及端口。

第二步：从JedisPool中获得Jedis对象。

第三步：使用Jedis操作redis服务器。

第四步：操作完毕后关闭jedis对象，连接池回收资源。

第五步：关闭JedisPool对象。

 1 @Test
 2 public void testJedisPool() throws Exception {
 3     // 第一步：创建一个JedisPool对象。需要指定服务端的ip及端口。
 4     JedisPool jedisPool = new JedisPool("192.168.1.***", 6379);
 5     // 第二步：从JedisPool中获得Jedis对象。
 6     Jedis jedis = jedisPool.getResource();
 7     // 第三步：使用Jedis操作redis服务器。
 8     jedis.set("jedis", "test");
 9     String result = jedis.get("jedis");
10     System.out.println(result);
11     // 第四步：操作完毕后关闭jedis对象，连接池回收资源。
12     jedis.close();
13     // 第五步：关闭JedisPool对象。
14     jedisPool.close();
15 }

1.3. 连接集群版

第一步：使用JedisCluster对象。需要一个Set<HostAndPort>参数。Redis节点的列表。

第二步：直接使用JedisCluster对象操作redis。在系统中单例存在。

第三步：打印结果

第四步：系统关闭前，关闭JedisCluster对象。

 1     @Test
 2     public void testJedisCluster() throws Exception {
 3         // 第一步：使用JedisCluster对象。需要一个Set<HostAndPort>参数。Redis节点的列表。
 4         Set<HostAndPort> nodes = new HashSet<>();
 5         nodes.add(new HostAndPort("192.168.1.***", 7001));
 6         nodes.add(new HostAndPort("192.168.1.***", 7002));
 7         nodes.add(new HostAndPort("192.168.1.***", 7003));
 8         nodes.add(new HostAndPort("192.168.1.***", 7004));
 9         nodes.add(new HostAndPort("192.168.1.***", 7005));
10         nodes.add(new HostAndPort("192.168.1.***", 7006));
11         JedisCluster jedisCluster = new JedisCluster(nodes);
12         // 第二步：直接使用JedisCluster对象操作redis。在系统中单例存在。
13         jedisCluster.set("hello", "100");
14         String result = jedisCluster.get("hello");
15         // 第三步：打印结果
16         System.out.println(result);
17         // 第四步：系统关闭前，关闭JedisCluster对象。
18         jedisCluster.close();
19     }