jedis、jedisPool、jedisCluster的使用方法

jedis 链接redis(单机):node

    使用jedis如何操做redis,可是其实方法是跟redis的操做大部分是相对应的。redis

  全部的redis命令都对应jedis的一个方法 服务器

    一、在macen工程中引入jedis的jar包     测试

       <dependency>
          <groupId>redis.clients</groupId>
          <artifactId>jedis</artifactId>
       </dependency>

     二、创建测试工程spa

public class JedisTest {

    @Test
    public void testJedis()throws Exception{
        Jedis jedis = new Jedis("192.168.241.133",6379);
        jedis.set("test", "my forst jedis");
        String str = jedis.get("test");
        System.out.println(str);
        jedis.close();
    }
}

      3.点击运行code

         若报下面链接超时,则须关闭防火墙(命令 service iptables stop)对象

              

                再次运行blog

               

               每次链接须要建立一个链接、执行完后就关闭,很是浪费资源,因此使用jedispool(链接池)链接 ip

jedisPool链接redis (单机)        资源

@Test
    public void testJedisPool()throws Exception{
        //建立链接池对象
        JedisPool jedispool = new JedisPool("192.168.241.133",6379);
        //从链接池中获取一个链接
        Jedis  jedis = jedispool.getResource(); 
        //使用jedis操做redis
        jedis.set("test", "my forst jedis");
        String str = jedis.get("test");
        System.out.println(str);
        //使用完毕 ,关闭链接,链接池回收资源
        jedis.close();
        //关闭链接池
        jedispool.close();
    }

jedisCluster链接redis(集群)

      jedisCluster专门用来链接redis集群 

      jedisCluster在单例存在的

@Test
    public void testJedisCluster()throws Exception{
        //建立jedisCluster对象,有一个参数 nodes是Set类型,Set包含若干个HostAndPort对象
        Set<HostAndPort> nodes = new HashSet<>();
        nodes.add(new HostAndPort("192.168.241.133",7001));
        nodes.add(new HostAndPort("192.168.241.133",7002));
        nodes.add(new HostAndPort("192.168.241.133",7003));
        nodes.add(new HostAndPort("192.168.241.133",7004));
        nodes.add(new HostAndPort("192.168.241.133",7005));
        nodes.add(new HostAndPort("192.168.241.133",7006));
        JedisCluster jedisCluster = new JedisCluster(nodes);
        //使用jedisCluster操做redis
        jedisCluster.set("test", "my forst jedis");
        String str = jedisCluster.get("test");
        System.out.println(str);
        //关闭链接池
        jedisCluster.close();
    }

      进集群服务器查看值

       

相关文章
相关标签/搜索