/**

 * 直接连接 redis

 * @throws Exception

 */

@Test

public void test1() throws Exception {

    //创建一个 jedis 对象，参数：host、post

    Jedis jedis = new Jedis("192.168.25.128", 6379);

    //直接通过 jedis 操作 redis，每个 redis 命令都对应一个方法

    jedis.set("a", "hello");

    String str = jedis.get("a");

    System.out.println(str);

    //关闭连接

    jedis.close();

}

/**

 * 通过连接池连接 redis

 * @throws Exception

 */

@Test

public void test2() throws Exception{

    //创建一个连接池对象，两个参数 host、post

    JedisPool pool = new JedisPool("192.168.25.128", 6379);

    //从连接池获得一个连接，就是一个 jedis 对象

    Jedis jedis = pool.getResource();

    //使用 jedis 操作 redis

    String str = jedis.get("a");

    System.out.println(str);

    //关闭连接(每次使用完毕后都要关闭连接)

    jedis.close();

    //关闭连接池

    pool.close();

}

/**

 * jedis 连接 redis 集群

 * @throws Exception

 */

@Test

public void test3() throws Exception{

    //创建一个 JedisCluster 对象(单例)。有一个参数 nodes，是一个 set 类型。set 中包含若干个 HostAndPort 对象

    Set<HostAndPort> nodes = new HashSet();

    nodes.add(new HostAndPort("192.168.25.128", 7001));

    nodes.add(new HostAndPort("192.168.25.128", 7002));

    nodes.add(new HostAndPort("192.168.25.128", 7003));

    nodes.add(new HostAndPort("192.168.25.128", 7004));

    nodes.add(new HostAndPort("192.168.25.128", 7005));

    nodes.add(new HostAndPort("192.168.25.128", 7006));

    JedisCluster jedisCluster = new JedisCluster(nodes);

    //直接使用 JedisCluster对象操作 redis。(JedisCluster 自带连接池，不用关闭)

    jedisCluster.set("b", "123");

    String str = jedisCluster.get("b");

    System.out.println(str);

    //系统关闭之前，关闭 JedisCluster

    jedisCluster.close();

}