jedis 连接 redis

/**
* 直接连接 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();
}