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

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

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

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







<!— Redis客户端 —>

<dependency>

       <groupId>redis.clients</groupId>

       <artifactId>jedis</artifactId>

       <version>2.7.2</version>

</dependency>

1、连接单机版

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

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

第三步：打印结果。

第四步：关闭Jedis







     @Test

     public void testJedis() throws Exception {

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

          Jedis jedis = new Jedis(“192.168.25.153”, 6379);

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

          jedis.set(“hello”,“你好”);

          String result = jedis.get(“hello”);

          // 第三步：打印结果。

          System.out.println(result);

          // 第四步：关闭Jedis

          jedis.close();

     }

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

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

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

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

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

第五步：关闭JedisPool对象。







     @Test

     public void testJedisPool() throws Exception {

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

          JedisPool jedisPool = new JedisPool(“192.168.25.153”, 6379);

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

          Jedis jedis = jedisPool.getResource();

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

          jedis.set(“jedis”, “test”);

          String result = jedis.get(“jedis”);

          System.out.println(result);

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

          jedis.close();

          // 第五步：关闭JedisPool对象。

          jedisPool.close();

     }

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

3、连接集群版

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

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

第三步：打印结果

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







     @Test

     public void testJedisCluster() throws Exception {

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

          Set<HostAndPort> nodes = new HashSet<>();

          nodes.add(new HostAndPort(“192.168.25.153”, 7001));

          nodes.add(new HostAndPort(“192.168.25.153”, 7002));

          nodes.add(new HostAndPort(“192.168.25.153”, 7003));

          nodes.add(new HostAndPort(“192.168.25.153”, 7004));

          nodes.add(new HostAndPort(“192.168.25.153”, 7005));

          nodes.add(new HostAndPort(“192.168.25.153”, 7006));

          JedisCluster jedisCluster = new JedisCluster(nodes);

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

          jedisCluster.set(“hello”, “100”);

          String result = jedisCluster.get(“hello”);

          // 第三步：打印结果

          System.out.println(result);

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

          jedisCluster.close();

     }

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

发表评论

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

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

相关阅读