Redis客戶端之Jedis（Key、String、Set、List、pub/sub、cluster、pool、pipleline）
阿新 • • 發佈：2019-01-26
環境：
OS：CentOS7 64位
server版本：Redis 3.2.0
client 版本：Jedis 2.8.0
在Maven中引用jedis的jar：
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope 1、Jedis客戶端介面
package com.digi_zones;
import org.junit.After;
import 2、jedis連線池及引數配置
package com.digi_zones;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.ScanResult;
import java.util.List;
/**
* Jedis連線池測試
* Created by yangxin on 2016/7/14.
*/
public class JedisPoolTest {
private JedisPool jedisPool;
@Before
public void before() {
JedisPoolConfig config = new JedisPoolConfig();
// 設定最大連線數
config.setMaxTotal(100);
// 最大空閒連線數
config.setMaxIdle(5);
// 最少空閒連線數（初始化連線數）
config.setMinIdle(1);
// 連線等待超時時長60秒
config.setMaxWaitMillis(60 * 1000);
// 在獲取redis連線時，自動測試連線是否可用，保證返回可用的連線
config.setTestOnBorrow(true);
// 連接回收到連線池時，自動測試連線是否可用（ping()），如果連線不可用，則不會放回連線池
config.setTestOnReturn(true);
// 自動檢測空閒連線是否可用
config.setTestWhileIdle(true);
// 檢測空閒連線是否可用的間隔時間
config.setTimeBetweenEvictionRunsMillis(60* 1000);
jedisPool = new JedisPool(config,"192.168.0.201",6384,5000,"yangxin");
}
@Test
public void testString() {
Jedis resource = jedisPool.getResource();
resource.sadd("hobbys","吃","喝","玩","樂");
ScanResult<String> result = resource.sscan("hobbys","0");
List<String> s = result.getResult();
System.out.println(s);
resource.close(); // 回收連線
}
@After
public void after() {
jedisPool.close();
}
}
3、Jedis叢集
package com.digi_zones;
import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import org.junit.rules.Stopwatch;
import redis.clients.jedis.BinaryJedisCluster;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisCluster;
import java.io.IOException;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
/**
* Jedis Cluster 測試
* Created by yangxin on 2016/7/14.
*/
public class JedisClusterTest {
private JedisCluster jc;
@Before
public void before() {
Set<HostAndPort> clusters = new HashSet<HostAndPort>();
clusters.add(new HostAndPort("192.168.0.201",6379));
clusters.add(new HostAndPort("192.168.0.201",6380));
clusters.add(new HostAndPort("192.168.0.201",6381));
clusters.add(new HostAndPort("192.168.0.201",16379));
clusters.add(new HostAndPort("192.168.0.201",16380));
clusters.add(new HostAndPort("192.168.0.201",16381));
jc = new JedisCluster(clusters);
}
@Test
public void testCluster() {
jc.set("name","yangxin");
jc.set("age","27");
String name = jc.get("name");
Assert.assertEquals(name,"yangxin");
String age = jc.get("age");
Assert.assertEquals(age,"27");
}
// 無法操作多個key
@Test
public void testMGet() {
List<String> values = jc.mget("name","age");
System.out.println(values);
}
@Test
public void testBatchCluster() {
// Jedis cluster不支援pipleline
long begin = System.currentTimeMillis();
for (int i = 0; i < 100000; i++) {
jc.set("key" + i, "value" + i);
}
long time = System.currentTimeMillis() - begin;
System.out.println(time);
}
@After
public void after() {
try {
jc.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}