阅读数:78 评论数:0

不同版本和回收资源方式

1、jedis版本<3.0.0

JedisPool jedisPool = null;
Jedis jedis = null;
jedis = redisPool.getResource();
   //  此处业务处理
if (jedis != null) 
{
    redisPool.returnBrokenResource(redis);
    jedis = null;   
}

2、jedis版本>-3.0.0

Jedis jedis = null;
  if (jedis != null) {
        jedis.close();  
        jedis = null;
 }

连接单机

//单机版测试
@Test
public void testJedisSingle() throws Exception {
    //创建一个Jedis对象
    Jedis jedis = new Jedis("192.168.25.153", 6379);
    jedis.set("test", "hello jedis");
    String string = jedis.get("test");
    System.out.println(string);
    jedis.close();
}

//使用连接池
@Test
public void testJedisPool() throws Exception {
    //创建一个连接池对象
    //系统中应该是单例的。
    JedisPool jedisPool = new JedisPool("192.168.25.153", 6379);
    //从连接池中获得一个连接
    Jedis jedis = jedisPool.getResource();
    String result = jedis.get("test");
    System.out.println(result);
    //jedis必须关闭
    jedis.close();
    //系统关闭时关闭连接池
    jedisPool.close();
}

连接集群

@Test
public void testJedisCluster() throws Exception {
	//创建一连接，JedisCluster对象,在系统中是单例存在
	Set<HostAndPort> nodes = new HashSet<>();
	nodes.add(new HostAndPort("127.0.0.1", 7001));
	nodes.add(new HostAndPort("127.0.0.1", 7002));
	nodes.add(new HostAndPort("127.0.0.1", 7003));
	nodes.add(new HostAndPort("127.0.0.1", 7004));
	nodes.add(new HostAndPort("127.0.0.1", 7005));
	nodes.add(new HostAndPort("127.0.0.1", 7006));
	JedisCluster cluster = new JedisCluster(nodes);
	//执行JedisCluster对象中的方法，方法和redis一一对应。
	cluster.set("cluster-test", "my jedis cluster test");
	String result = cluster.get("cluster-test");
	System.out.println(result);
	//程序结束时需要关闭JedisCluster对象
	cluster.close();
}