使用Jedis,JedisPool,JedisCluster链接redis

一.使用Jedis对象连接(单机)

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

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

第三步:打印结果。

第四步:关闭Jedis

@Test

public void testJedis()throws Exception

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

Jedis jedis =new Jedis("ip", port);

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

 String result =jedis.get("hello");

// 第三步:打印结果。

System.out.println(result);

// 第四步:关闭Jedis

jedis.close();

}

 

二,使用连接池连接redis(单机)

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

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

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

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

第五步:关闭JedisPool对象。

@Test

public void testJedisPool()throws Exception {

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

JedisPool jedisPool = new JedisPool("ip", port);

// 第二步:从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();

}

 

三,使用JedisCluster连接jedis(集群版)

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

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

第三步:打印结果

第四步:系统关闭前,关闭JedisCluster对象。

// 连接redis集群

@Test

public void testJedisCluster() {

JedisPoolConfig config = new JedisPoolConfig();

// 最大连接数

config.setMaxTotal(30);

// 最大连接空闲数

config.setMaxIdle(2);

//集群结点

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

jedisClusterNode.add(new HostAndPort("ip", 7001));

jedisClusterNode.add(new HostAndPort("ip", 7002));

jedisClusterNode.add(new HostAndPort("ip", 7003));

jedisClusterNode.add(new HostAndPort("ip", 7004));

jedisClusterNode.add(new HostAndPort("ip", 7005));

jedisClusterNode.add(new HostAndPort("ip", 7006));

JedisCluster jcd = new JedisCluster(jedisClusterNode);

jcd.set("name","zhangsan");

String value = jcd.get("name");

System.out.println(value);

}

 

原文地址:https://www.cnblogs.com/libaowen609/p/12819645.html