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 >
</dependency>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.8.0</version>
</dependency>
</dependencies>
1、Jedis客戶端介面
package com.digi_zones;
import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import redis.clients.jedis.*;
import java.util.*;
/**
* Jedis Api測試
* 字串、Set、List、Hash、publish/subscribe
* Created by yangxin on 2016/7/14.
*/
public class JedisTest {
private Jedis jedis;
@Before
public void before() {
jedis = new Jedis("192.168.0.201",6384);
jedis.auth("yangxin");
}
/**
* 字串
* 文件:127.0.0.1:6384> help @string
*/
@Test
public void testString() {
jedis.flushDB(); // 清空當前資料的所有資料
// 儲存一個字串
jedis.set("language","java");
// 在原來key對應的值追加一個字串,如果key不存在,則建立一個新的key
jedis.append("language","c++");
// 獲取一個字串
String s = jedis.get("language");
Assert.assertEquals("javac++",s);
// 自增1,redis會轉換成整型,再進行加操作。等價於count++。預設為0
jedis.incr("count");
// 在原有值的基礎增加指定的值,等價於count+=10;
jedis.incrBy("count",10);
// 浮點數自增
Double price = jedis.incrByFloat("price",1.2);
Assert.assertTrue(price == 1.2);
// 自減1,等價於count--
jedis.decr("count");
// 減指定數量的值,等價於count-=5
jedis.decrBy("count",5);
Assert.assertEquals(jedis.get("count"),"5");
// 獲取key舊的值,並設定一個新的值
s = jedis.getSet("count","100");
Assert.assertEquals(s,"5");
// 獲取指定範圍的字串,0:起始偏移 3:結束位置
s = jedis.getrange("language",0,3);
Assert.assertEquals(s, "java");
// 替換,0:替換起始位置,php:從0開始替換的字串
jedis.setrange("language",0,"php");
Assert.assertEquals(jedis.get("language"),"phpac++");
// 只有key不存在才儲存,key不存在返回1,存在返回0
long r = jedis.setnx("count","200");
Assert.assertTrue(r == 0);
// 獲取字串的長度
long len = jedis.strlen("language");
Assert.assertTrue("phpac++".length() == len);
// 同時設定多個key的值
jedis.mset("language","java", "count","2000");
// 獲取多個key的值
List<String> list = jedis.mget("language","count");
System.out.println(list);
Assert.assertTrue(list.size() == 2 && list.get(0).equals("java") && list.get(1).equals("2000"));
// 同時設定多個key,且key不存在
r = jedis.msetnx("auth","yangxin","age","18");
Assert.assertTrue(r == 1);
// 儲存帶有效期的key,單位為毫秒
jedis.psetex("expir_key",2000,"abcde");
try {
Thread.sleep(2100);
} catch (InterruptedException e) {
e.printStackTrace();
}
boolean b = jedis.exists("expir_key");
Assert.assertTrue(!b);
// 儲存帶有效期的key,單位為秒
jedis.setex("expir_key2",3,"test");
}
/**
* 集合
* 1> 元素沒有順序
* 2> 元素不可重複
* 文件:127.0.0.1:6384> help @set
*/
@Test
public void testSet() {
jedis.flushDB();
// 新增元素,返回新增的元素個數
long r = jedis.sadd("hobbys","吃","喝","玩","樂","看書","旅遊");
Assert.assertTrue(r == 6);
// 查詢集合元數數量
r = jedis.scard("hobbys");
Assert.assertTrue(r == 6);
// 取多個集合的差集
r = jedis.sadd("hobbys2","吃","旅遊");
Assert.assertTrue(r == 2);
Set<String> s = jedis.sdiff("hobbys","hobbys2");
System.out.println(s);
Assert.assertTrue(s.size() == 4);
// 取hoobys和hobbys2的差集,將結果存在hobbys3集合中
r = jedis.sdiffstore("hobbys3","hobbys","hobbys2");
Assert.assertTrue(jedis.scard("hobbys3") == r);
// 取多個集合的交集
s = jedis.sinter("hobbys","hobbys2");
System.out.println(s);
Assert.assertTrue(s.size() == 2);
// 取多個集合的交集,並將結果儲存到一個新的key中
r = jedis.sinterstore("hobbys4","hobbys","hobbys2");
Assert.assertTrue(jedis.scard("hobbys4") == r);
// 判斷某個元素是否在集合當中
boolean b = jedis.sismember("hobbys","吃");
Assert.assertTrue(b);
// 獲取集合中的的元素
s = jedis.smembers("hobbys");
System.out.println(s);
Assert.assertTrue(s.size() == 6);
// 從一個集合中移動指定的元素到另外一個集合當中
r = jedis.smove("hobbys","hobbys2","樂");
Assert.assertTrue(r == 1);
Assert.assertTrue(jedis.sismember("hobbys2","樂"));
// 從集合中隨機獲取2個元素
List<String> list = jedis.srandmember("hobbys",2);
System.out.println("隨機獲取2個元素:" + list);
Assert.assertTrue(list.size() == 2);
// 從集合中隨機移除一個或多個元素,返回移除的元素。因為集合中的元素是沒有順序的
s = jedis.spop("hobbys",2);
System.out.println(s);
Assert.assertTrue(s.size() == 2);
// 從集合中刪除一個或多個元素,返回刪除的個數
r = jedis.srem("hobbys","吃","旅遊");
System.out.println(r);
Assert.assertTrue(!jedis.sismember("hobbys","吃") && !jedis.sismember("hobbys","旅遊"));
// 根據查詢關鍵搜尋集合中的元素,0:搜尋開始位置,scanParams:搜尋規則
ScanParams scanParams = new ScanParams();
jedis.sadd("hobbys","java","javascript","php","c++","c","objective-c","node.js","python");
scanParams.match("java*");
ScanResult<String> sr = jedis.sscan("hobbys",0,scanParams);
list = sr.getResult();
System.out.println(list);
Assert.assertTrue(list.size() == 2);
// 取多個集合的並集,如果元素相同,則會覆蓋
Set<String> us = jedis.sunion("hobbys2","hobbys3");
System.out.println(us);
// 將多個集合的並集儲存到一個新的集合中
r = jedis.sunionstore("hobbys5","hobbys2","hobbys3");
Assert.assertTrue(r == jedis.scard("hobbys5"));
System.out.println(jedis.smembers("hobbys5"));
}
/**
* 自動排序的集合
* 1> 元素不可重複
* 2> 元素有序(根據score排序)
* score值越大,排名越靠後
*/
@Test
public void testSortedSet() {
jedis.flushDB();
// 新增元素(不需要設定同樣的型別)
jedis.zadd("price",1,"1");
jedis.zadd("price",5,"10");
jedis.zadd("price",2,"5.2");
jedis.zadd("price",6,"6");
jedis.zadd("price",7,"3");
jedis.zadd("price",10,"五百");
// 獲取元素列表
Set<String> set = jedis.zrange("price",0,-1);
System.out.println(set);
// 獲取指定分值範圍的元素數量
long r = jedis.zcount("price",1,8);
System.out.println(r);
Assert.assertTrue(r == 5);
// 給指定元素的增加分值,返回新的分值
double s = jedis.zincrby("price",5.5,"3");
System.out.println(s);
Assert.assertTrue(s == 12.5);
// 指定鍵在集合的分值排名,從0開始算
r = jedis.zrank("price","3");
System.out.println(r);
Assert.assertTrue(r == 5); // 最高分,預設按升序排列,第最後一名
// 刪除元素,刪除成功返回刪除的元素數量,失敗返回0
r = jedis.zrem("price","五百","3");
Assert.assertTrue(r == 2);
// 獲取元素的排名分值
s = jedis.zscore("price","6");
Assert.assertTrue(s == 6);
// 獲取元素在集合中的逆序名次(倒數第幾名),從0開始計算
s = jedis.zrevrank("price","6");
Assert.assertTrue(s == 0);
// 獲取指定範圍的後幾個元素(這裡是後3個元素)
set = jedis.zrevrange("price", 0, 2);
System.out.println(set); // [6, 10, 5.2]
// 獲取指定分值範圍的後幾個元素,依移1個元素,取後2個
set = jedis.zrevrangeByScore("price",5,1,1,2);
System.out.println(set); // [5.2, 1]
/**
* 模擬搜尋
* 區間必須包含(、[符號:(代表不包含,[代表包含
* -、+ : 代表最少和最大範圍
* @see http://redisdoc.com/sorted_set/zrangebylex.html
*/
jedis.zadd("alpha",0,"a");
jedis.zadd("alpha",0,"b");
jedis.zadd("alpha",0,"c");
jedis.zadd("alpha",0,"d");
jedis.zadd("alpha",0,"e");
jedis.zadd("alpha",0,"f");
jedis.zadd("alpha",0,"k");
jedis.zadd("alpha",0,"z");
// 取a~k範圍的元素,包含a,不包含k。從第2個開始取3個
set = jedis.zrangeByLex("alpha","[a","(k",1,3);
System.out.println(set); // [b, c, d]
// 獲取指定範圍的元素個數
r = jedis.zlexcount("alpha","[a","[f");
System.out.println(r);
Assert.assertTrue(r == 6);
// 倒著取指定範圍的元素
set = jedis.zrevrangeByLex("alpha","[z","[d",0,3);
System.out.println(set); // [z, k, f]
}
/**
* 佇列
* 文件:127.0.0.1:6384> help @list
*/
@Test
public void testList() {
jedis.flushDB();
// 向頭新增元素,返回連結串列的長度
long r = jedis.lpush("users","yangxin","yangli","yangfang","huge","guodegang");
System.out.println(r);
Assert.assertTrue(r == 5);
// 向尾新增元素,返回連結串列的長度
r = jedis.rpush("users","likaifu","mayun","mahuateng");
System.out.println(r);
Assert.assertTrue(r == 8);
// 返回連結串列長度
r = jedis.llen("users");
System.out.println(r);
Assert.assertTrue(r == 8);
// 獲取連結串列元素,0:開始索引,-1:結束索引,-1表示取連結串列長度
List<String> list = jedis.lrange("users",0,-1);
System.out.println(list);
Assert.assertTrue(list.size() == 8);
// 刪除指定的相同元素數量,返回刪除元素個數
jedis.rpush("users","mahuateng","mahuateng");
r = jedis.lrem("users",2,"mahuateng");
System.out.println(r);
Assert.assertTrue(r == 2);
// 彈出列表中第一個元素(刪除並返回第一個元素)
String s = jedis.lpop("users");
System.out.println(s);
Assert.assertEquals(s,"guodegang");
// 彈出列表中最後一個元素
s = jedis.rpop("users");
System.out.println(s);
Assert.assertEquals(s,"mahuateng");
// 往佇列頭部插入元素,列表必須存在
r = jedis.lpushx("users2","laoyang");
System.out.println(r == 0);
// 修改佇列中指定索引的值
s = jedis.lset("users",0,"yangxin");
System.out.println(s);
Assert.assertEquals(s,"OK");
// 擷取並儲存連結串列中指定範圍的元素
s = jedis.ltrim("users",0,5);
System.out.println(s);
// 返回指定索引的元素
s = jedis.lindex("users",0);
System.out.println(s);
Assert.assertEquals(s,"yangxin");
System.out.println("users: " + jedis.lrange("users",0,-1));
// 彈出users最後一個元素,儲存到user2連結串列中,並返回
s = jedis.rpoplpush("users","users2");
System.out.println(jedis.lrange("users2",0,-1));
// 同上,只是有阻塞超時時長,單位:毫秒
s = jedis.brpoplpush("users","users2",1);
System.out.println(jedis.lrange("users2",0,-1));
}
/**
* hash表
* 文件:127.0.0.1:6384> help @hash
*/
@Test
public void testHash() {
jedis.flushDB();
// 新增元素,如果key存在則修改,且返回0.如果key不存在,則新增,返回1
long r = jedis.hset("user", "name","yangxin");
jedis.hset("user","age","18"); // 18顯得我年輕~
Assert.assertEquals(r,1);
// 如果key不存在則新增,否則操作失敗。key存在返回0,否則返回1
r = jedis.hsetnx("user","name","郭德綱");
Assert.assertTrue(r == 0);
// 獲取某一key的值
String s = jedis.hget("user","name");
System.out.println(s);
Assert.assertEquals(s,"yangxin");
// 獲取所有值
Map<String, String> map = jedis.hgetAll("user");
for (Map.Entry<String,String> entry : map.entrySet()) {
System.out.println(entry.getKey() + "=" + entry.getValue());
}
Assert.assertTrue(map.size() == 2);
// 判斷某個key的欄位是否存在
boolean b = jedis.hexists("user","sex");
Assert.assertTrue(!b);
// 對某個field累加指定的整數值,返回累加後的值
r = jedis.hincrBy("user","age",10); // 還是迴歸現實吧~^^
System.out.println(r);
Assert.assertTrue(r == 28);
// 對某個field累加指定的浮點數值,返回累加後的值
double f = jedis.hincrByFloat("user","height",1.75);
System.out.println(f);
Assert.assertTrue(f == 1.75);
// 獲取hash的欄位數量
r = jedis.hlen("user");
Assert.assertEquals(r,3);
// 獲取多個欄位的值
List<String> list = jedis.hmget("user","name","age");
System.out.println(list);
Assert.assertTrue(list.size() == 2);
// 獲取所有欄位的值
list = jedis.hvals("user");
System.out.println(list);
Assert.assertTrue(list.size() == 3);
// 刪除欄位
r = jedis.hdel("user","name","age");
System.out.println(r);
Assert.assertTrue(r == 2);
// 查詢欄位
jedis.hset("user","js1","value1");
jedis.hset("user","xxxjs2","value2");
jedis.hset("user","abcjs3","value3");
jedis.hset("user","1abcjs","value4");
jedis.hset("user","2abc2js3","value5");
jedis.hset("user","name","yangxin");
ScanParams scanParams = new ScanParams();
scanParams.match("*js*"); // 查詢包含js的欄位
ScanResult<Map.Entry<String, String>> sr = jedis.hscan("user","0",scanParams);
System.out.println(sr.getResult().size());
Assert.assertTrue(sr.getResult().size() == 5);
for (Iterator<Map.Entry<String, String>> iterator = sr.getResult().iterator(); iterator.hasNext();) {
Map.Entry<String, String> entry = iterator.next();
System.out.println(entry.getKey() + "=" + entry.getValue());
}
}
/**
* 訊息釋出
* 文件:127.0.0.1:6384> help @pubsub
*/
@Test
public void testPublish() {
// 釋出一個事件
long r = jedis.publish("event_msg","message_" + System.currentTimeMillis());
System.out.println(r);
}
/**
* 訊息訂閱
* 文件:127.0.0.1:6384> help @pubsub
*/
@Test
public void testSubscribe() {
// 訂閱一個事件
JedisPubSub sub = new JedisPubSub() {
private int count;
/**
* 收到訂閱訊息回撥
* @param channel 訂閱的訊息通道
* @param message 訊息內容
*/
@Override
public void onMessage(String channel, String message) {
count++;
if (count > 3) {
unsubscribe(channel);
count = 0;
return;
}
System.out.println("onMessage--->channel: " + channel + ", message: " + message);
}
// 訊息訂閱成功回撥
@Override
public void onSubscribe(String channel, int subscribedChannels) {
System.out.println("onSubscribe---->channel:" + channel + ", subscribedChannels: " + subscribedChannels);
}
/**
* 訊息取訊息訂閱回撥
*/
@Override
public void onUnsubscribe(String channel, int subscribedChannels) {
System.out.println("onUnsubscribe--->channel: " + channel + ", subscribedChannels: " + subscribedChannels);
}
/**
* 收到模式匹配主題訊息回撥(可以用*萬用字元匹配)
* @param pattern 模式匹配主題
* @param channel 傳送訊息的具體主題
* @param message 訊息內容
*/
@Override
public void onPMessage(String pattern, String channel, String message) {
count++;
if (count > 3) {
punsubscribe();
count = 0;
return;
}
System.out.println("onPMessage---->pattern: " + pattern+ ", channel:" + channel + ", message: " + message);
}
/**
* 模式主題訂閱成功回撥
* @param pattern 模式匹配主題
* @param subscribedChannels
*/
@Override
public void onPSubscribe(String pattern, int subscribedChannels) {
System.out.println("onPSubscribe---->pattern:" + pattern + ", subscribedChannels: " + subscribedChannels);
}
/**
* 模式主題取消訂閱回撥
* @param pattern 模式匹配主題
* @param subscribedChannels
*/
@Override
public void onPUnsubscribe(String pattern, int subscribedChannels) {
System.out.println("onUnsubscribe--->pattern: " + pattern + ", subscribedChannels: " + subscribedChannels);
}
};
// 訂閱event_msg,event_msg2,event_msg3 三個訊息
//jedis.subscribe(sub,"event_msg","event_msg2","event_msg3");
// 訂閱模式匹配訊息
jedis.psubscribe(sub,"event.msg.*", "event.doc.*");
}
/**
* 事務
*/
@Test
public void testTransaction() {
jedis.flushDB();
Transaction transaction = jedis.multi(); // 開始執行事務
transaction.hset("user","name","yangxin");
transaction.hset("user","age","28");
transaction.hset("user","sex","man");
transaction.hset("user","height","1.75");
transaction.hset("user","weight","65");
List<Object> objects = transaction.exec(); // 執行事務
System.out.println(objects.toString());
}
/**
* 批處理
* 10萬個key是單個key儲存速度的10倍以上
*/
@Test
public void testPipleLine() {
Pipeline pipeline = jedis.pipelined();
long start = System.currentTimeMillis();
for (int i = 0; i < 100000; i++) {
pipeline.set("key" + i, "value" + i);
pipeline.hset("user", "key" + i, "vlaue" + i);
if (i % 1000 == 0) {
pipeline.sync();
}
}
pipeline.sync();
long end = System.currentTimeMillis() - start;
System.out.println(end);
}
/**
* key
*/
@Test
public void testKey() {
jedis.flushDB();
jedis.hset("user","username","yangxin");
jedis.set("name","yangxin");
// 刪除key,返回刪除key的數量
long ret = jedis.del("user","name","language");
System.out.println(ret);
Assert.assertTrue(ret == 2); // language這個key不存在
jedis.set("name","yangxin");
jedis.set("age","28");
jedis.set("sex","man");
jedis.set("height","175");
jedis.set("weight", "65kg");
jedis.sadd("hobbys","吃","喝","玩","樂");
// 隨機返回一個key
String key = jedis.randomKey();
System.out.println(key);
// 序列化指定key的值
byte[] value = jedis.dump("name");
System.out.println(new String(value));
// 查詢指定的key是否存在
boolean b = jedis.exists("name");
Assert.assertTrue(b);
// 設定指定key的有效期,單位:秒。返回1設定成功,0設定失敗(超時或key不存在)
ret = jedis.expire("name",60 * 10);
System.out.println(ret);
Assert.assertTrue(ret == 1);
// 指定key有效期(1970.1.1 0:0:0以來的秒數)
Calendar expire = Calendar.getInstance();
expire.add(Calendar.SECOND, 5);
ret = jedis.expireAt("age",expire.getTimeInMillis()/1000);
Assert.assertTrue(ret == 1);
/**
* 移動一個key到指定主機指定的資料庫
* 注意:如果目標主機資料庫中的key已經存在,則報錯
* arg1: 目標主機IP
* arg2: 目標主機埠
* arg3:當前例項的key
* arg4: 目標主機的資料庫序號
* arg5: 移動超時時長
*/
String s = jedis.migrate("192.168.0.201",6385,"age",0,5000);
Assert.assertEquals(s,"OK");
/**
* 在當前redis例項移動指定的key到指定序號資料庫中
* 移動成功返回1,否則返回0
*/
long r = jedis.move("weight",1);
//Assert.assertTrue(r == 1);
System.out.println(r);
//------------------debug 排錯------------------
r = jedis.objectRefcount("height"); // 檢視一個物件被引用的次數
System.out.println(r);
s = jedis.objectEncoding("height"); // 檢視key在redis內部儲存的資料型別
System.out.println(s);
r = jedis.objectIdletime("height"); // 檢視自儲存後的空閒時間
System.out.println(r);
// 獲取一個key的剩餘生命週期,以秒為單位,-1:表示沒有有效期限制
r = jedis.ttl("age");
System.out.println(r);
// 獲取一個key的剩餘生命週期,以毫秒為單位, -1:表示沒有有效期限制
r = jedis.pttl("age");
System.out.println(r);
// key重新命名,如果兩個key相同重新命名失敗,如果新key已經存在,則覆蓋
s = jedis.rename("age","newAge");
System.out.println(s);
// 如果新key已經存在,重新命名失敗
r = jedis.renamenx("newAge","age");
System.out.println(r);
// 搜尋key
ScanParams sp = new ScanParams();
sp.match("age");
ScanResult<String> result = jedis.scan(0,sp);
System.out.println(result.getResult());
Assert.assertTrue(result.getResult().size() == 1);
// 對set、list進行排序(只能是數值)
jedis.sadd("num","1","0","3","10","10.2","8","5","2.2","2");
System.out.println(jedis.smembers("num"));
System.out.println(jedis.sort("num")); // 預設升序
SortingParams params = new SortingParams();
params.desc(); // 降序
System.out.println(jedis.sort("num",params));
// 將排序結果儲存到一個新的列表中(list)
params.asc();
System.out.println(jedis.sort("num",params,"sorted_num"));
}
@After
public void after() {
jedis.close();
}
}
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();
}
}
}