Jedis客戶端
-
單機版
需要把jedis的jar包添加到工程中味赃,如果是maven需要添加jar包的坐標隔嫡。
<properties> <jedis.version>2.7.2</jedis.version> </properties> <!-- Redis客戶端 --> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>${jedis.version}</version> </dependency>
測試方法
public class JedisTest { @Test public void testJedisSingle() { //創(chuàng)建一個jedis的對象。 Jedis jedis = new Jedis("192.168.25.153", 6379); //調(diào)用jedis對象的方法墓陈,方法名稱和redis的命令一致井仰。 jedis.set("key1", "jedis test"); String string = jedis.get("key1"); System.out.println(string); //關(guān)閉jedis埋嵌。 jedis.close(); } /** * 使用連接池 */ @Test public void testJedisPool() { //創(chuàng)建jedis連接池 JedisPool pool = new JedisPool("192.168.25.153", 6379); //從連接池中獲得Jedis對象 Jedis jedis = pool.getResource(); String string = jedis.get("key1"); System.out.println(string); //關(guān)閉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(); }