Java通过Jedis连接Redis单击版和集群版

秒速五厘米 2022-05-10 06:54 315阅读 0赞

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

添加如下坐标到pom.xml文件中

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> &lt;!-- Redis客户端 --&gt; &lt;dependency&gt; &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&lt;groupId&gt;redis.clients&lt;/groupId&gt; &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&lt;artifactId&gt;jedis&lt;/artifactId&gt; &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&lt;version&gt;2.7.2&lt;/version&gt; &lt;/dependency&gt; </td> 
 </tr> 
 </tbody> 
</table>

# 1、连接单机版 #

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

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

第三步：打印结果。

第四步：关闭Jedis

# 2、使用连接池连接单机版 #

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

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

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

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

第五步：关闭JedisPool对象。

应用系统关闭的时候才关闭连接池（JedisPool对象）

# 3、连接集群版 #

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

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

第三步：打印结果

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

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;width:426.1pt;"> &nbsp; &nbsp; &nbsp;@Test &nbsp;&nbsp;&nbsp;&nbsp; public void testJedisCluster() throws Exception { &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; // 第一步：使用JedisCluster对象。需要一个Set&lt;HostAndPort&gt;参数。Redis节点的列表。 &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; Set&lt;HostAndPort&gt; nodes = new HashSet&lt;&gt;(); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; nodes.add(new HostAndPort("192.168.25.153", 7001)); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; nodes.add(new HostAndPort("192.168.25.153", 7002)); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; nodes.add(new HostAndPort("192.168.25.153", 7003)); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; nodes.add(new HostAndPort("192.168.25.153", 7004)); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; nodes.add(new HostAndPort("192.168.25.153", 7005)); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; nodes.add(new HostAndPort("192.168.25.153", 7006)); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; JedisCluster jedisCluster = new JedisCluster(nodes); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; // 第二步：直接使用JedisCluster对象操作redis。在系统中单例存在。 &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; jedisCluster.set("hello", "100"); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; String result = jedisCluster.get("hello"); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; // 第三步：打印结果 &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; System.out.println(result); &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; // 第四步：系统关闭前，关闭JedisCluster对象。 &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; jedisCluster.close(); &nbsp;&nbsp;&nbsp;&nbsp; } </td> 
 </tr> 
 </tbody> 
</table>

JedisCluster封装了地址池，也是在应用系统关闭的时候关闭它