Jedis客戶端操作redis
阿新 • • 發佈:2019-02-06
需要引入jedis jar包
單機版
public class JedisTest { @Test public void testJedisSingle() { //建立一個jedis的物件。 Jedis jedis = new Jedis("192.168.25.153", 6379); //呼叫jedis物件的方法,方法名稱和redis的命令一致。 jedis.set("key1", "jedis test"); String string = jedis.get("key1"); System.out.println(string); //關閉jedis。 jedis.close(); } /** * 使用連線池 */ @Test public void testJedisPool() { //建立jedis連線池 JedisPool pool = new JedisPool("192.168.25.153", 6379); //從連線池中獲得Jedis物件 Jedis jedis = pool.getResource(); String string = jedis.get("key1"); System.out.println(string); //關閉jedis物件 jedis.close(); pool.close(); } }
叢集版
@Test public void testJedisCluster() { HashSet<HostAndPort> nodes = new HashSet<>(); nodes.add(new HostAndPort("192.168.25.153", 7001)); nodes.add(new HostAndPort("192.168.25.153", 7002)); nodes.add(new HostAndPort("192.168.25.153", 7003)); nodes.add(new HostAndPort("192.168.25.153", 7004)); nodes.add(new HostAndPort("192.168.25.153", 7005)); nodes.add(new HostAndPort("192.168.25.153", 7006)); JedisCluster cluster = new JedisCluster(nodes); cluster.set("key1", "1000"); String string = cluster.get("key1"); System.out.println(string); cluster.close(); }