redis客戶端--jedis

一、jedis

jedis 是 redis推薦的java客戶端。通過Jedis我們可以很方便地使用java代碼的方式，對redis進行操作。jedis使用起來比較簡單，它的操作方法與redis命令相類似。對於初次使用redis的人來說，上手更快，更能適應。jedis在github上的下載地址為https://github.com/xetorthio/jedis 。本例子使用maven，需要添加如下依賴：

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>2.6.0</version> 
</dependency>

二、相關實例
　　以下只是對數據的一些基本操作。
　　獲取Jedis操作對象

Jedis jedis;

@Before
public void connectionTest() {
jedis = new Jedis("127.0.0.1", 6379);//redis的地址以及連接端口
6 //jedis.auth("helloworld");  //開啟密碼驗證（配置文件中為 requirepass helloworld）的時候需要執行該方法
7 }

　　Jedis對key的操作

@Test
public void keyTest() throws UnsupportedEncodingException {
System.out.println(jedis.flushDB());// 清空數據
System.out.println(jedis.echo("hello"));

// 判斷key否存在
System.out.println(jedis.exists("foo"));

jedis.set("key", "values");
jedis.set("key2", "values");
System.out.println(jedis.exists("key"));// 判斷是否存在

// 如果數據庫沒有任何key，返回nil，否則返回數據庫中一個隨機的key。
String randomKey = jedis.randomKey();
System.out.println("randomKey: " + randomKey);

// 設置60秒后該key過期
jedis.expire("key", 60);

// key有效毫秒數
System.out.println(jedis.pttl("key"));

// 移除key的過期時間
jedis.persist("key");

// 獲取key的類型, "string", "list", "set". "none" none表示key不存在
System.out.println("type: " + jedis.type("key"));

// 導出key的值
byte[] bytes = jedis.dump("key");
System.out.println(new String(bytes));

// 將key重命名
jedis.renamenx("key", "keytest");
System.out.println("key是否存在: " + jedis.exists("key"));// 判斷是否存在
System.out.println("keytest是否存在: " + jedis.exists("keytest"));// 判斷是否存在

// 查詢匹配的key
// KEYS * 匹配數據庫中所有 key 。
// KEYS h?llo 匹配 hello ， hallo 和 hxllo 等。
// KEYS h*llo 匹配 hllo 和 heeeeello 等。
// KEYS h[ae]llo 匹配 hello 和 hallo ，但不匹配 hillo 。
// 特殊符號用 \ 隔開。
Set<String> set = jedis.keys("k*");
System.out.println(set);

// 刪除key
jedis.del("key");
System.out.println(jedis.exists("key"));
}

　　Jedis對字符串(String)的相關操作

@Test
public void stringTest() {
jedis.set("hello", "hello");
System.out.println(jedis.get("hello"));

// 使用append 向字符串后面添加
jedis.append("hello", " world");
System.out.println(jedis.get("hello"));

// set覆蓋字符串
jedis.set("hello", "123");
System.out.println(jedis.get("hello"));

// 設置過期時間
jedis.setex("hello2", 2, "world2");
System.out.println(jedis.get("hello2"));
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
}
System.out.println(jedis.get("hello2"));

// 一次添加多個key-value對
jedis.mset("a", "1", "b", "2");
// 獲取a和b的value
List<String> valus = jedis.mget("a", "b");
System.out.println(valus);

// 批量刪除
jedis.del("a", "b");
System.out.println(jedis.exists("a"));
System.out.println(jedis.exists("b"));
}

　　Jedis對鏈表(Lists)的操作

@Test
public void listTest() {
String key = "mylist";
jedis.del(key);

// 隊列添加元素
jedis.rpush(key, "aaaa");
jedis.rpush(key, "aaaa");
jedis.rpush(key, "bbbb");
jedis.rpush(key, "cccc");
jedis.rpush(key, "cccc");

// 隊列長度
System.out.println("lenth: " + jedis.llen(key));

// 打印隊列，從索引0開始，到倒數第1個（全部元素）
System.out.println("all elements: " + jedis.lrange(key, 0, -1));

// 索引為1的元素
System.out.println("index of 1: " + jedis.lindex(key, 1));

// 設置隊列里面一個元素的值，當index超出范圍時會返回一個error。
jedis.lset(key, 1, "aa22");
System.out.println("index of 1: " + jedis.lindex(key, 1));

// 從隊列的右邊入隊一個元素
jedis.rpush(key, "-2", "-1");// 先-2，后-1入隊列
System.out.println("all elements: " + jedis.lrange(key, 0, -1));

// 從隊列的左邊入隊一個或多個元素
jedis.lpush(key, "second element", "first element");// 先second
// element，后first
// elementF入隊列
System.out.println("all elements: " + jedis.lrange(key, 0, -1));

// 從隊列的右邊出隊一個元素
System.out.println(jedis.rpop(key));
// 從隊列的左邊出隊一個元素
System.out.println(jedis.lpop(key));
System.out.println("all elements: " + jedis.lrange(key, 0, -1));

// count > 0: 從頭往尾移除值為 value 的元素，count為移除的個數。
// count < 0: 從尾往頭移除值為 value 的元素，count為移除的個數。
// count = 0: 移除所有值為 value 的元素。
jedis.lrem(key, 1, "cccc");
System.out.println("all elements: " + jedis.lrange(key, 0, -1));

// 即最右邊的那個元素也會被包含在內。 如果start比list的尾部下標大的時候，會返回一個空列表。
// 如果stop比list的實際尾部大的時候，Redis會當它是最后一個元素的下標。
System.out.println(jedis.lrange(key, 0, 2));
System.out.println("all elements: " + jedis.lrange(key, 0, -1));

// 刪除區間以外的元素
System.out.println(jedis.ltrim(key, 0, 2));
System.out.println("all elements: " + jedis.lrange(key, 0, -1));
}

　　Jedis對集合(Sets)的操作

@Test
public void testSet() {
// 清空數據
System.out.println(jedis.flushDB());
String key = "myset";
String key2 = "myset2";

// 集合添加元素
jedis.sadd(key, "aaa", "bbb", "ccc");
jedis.sadd(key2, "bbb", "ccc", "ddd");

// 獲取集合里面的元素數量
System.out.println(jedis.scard(key));

// 獲得兩個集合的交集，並存儲在一個關鍵的結果集
jedis.sinterstore("destination", key, key2);
System.out.println(jedis.smembers("destination"));

// 獲得兩個集合的並集，並存儲在一個關鍵的結果集
jedis.sunionstore("destination", key, key2);
System.out.println(jedis.smembers("destination"));

// key集合中，key2集合沒有的元素，並存儲在一個關鍵的結果集
jedis.sdiffstore("destination", key, key2);
System.out.println(jedis.smembers("destination"));

// 確定某個元素是一個集合的成員
System.out.println(jedis.sismember(key, "aaa"));

// 從key集合里面隨機獲取一個元素
System.out.println(jedis.srandmember(key));

// aaa從key移動到key2集合
jedis.smove(key, key2, "aaa");
System.out.println(jedis.smembers(key));
System.out.println(jedis.smembers(key2));

// 刪除並獲取一個集合里面的元素
System.out.println(jedis.spop(key));

// 從集合里刪除一個或多個元素
jedis.srem(key2, "ccc", "ddd");
System.out.println(jedis.smembers(key2));
}

　　Jedis對有序集合(Sorted Sets)的操作

@Test
public void testSortSet() {
// 清空數據
System.out.println(jedis.flushDB());
String key = "mysortset";

Map<String, Double> scoreMembers = new HashMap<String, Double>();
scoreMembers.put("aaa", 1001.0);
scoreMembers.put("bbb", 1002.0);
scoreMembers.put("ccc", 1003.0);

// 添加數據
jedis.zadd(key, 1004.0, "ddd");
jedis.zadd(key, scoreMembers);

// 獲取一個排序的集合中的成員數量
System.out.println(jedis.zcard(key));

// 返回的成員在指定范圍內的有序集合，以0表示有序集第一個成員，以1表示有序集第二個成員，以此類推。
// 負數下標，以-1表示最后一個成員，-2表示倒數第二個成員
Set<String> coll = jedis.zrange(key, 0, -1);
System.out.println(coll);

// 返回的成員在指定范圍內的逆序集合
coll = jedis.zrevrange(key, 0, -1);
System.out.println(coll);

// 元素下標
System.out.println(jedis.zscore(key, "bbb"));

// 刪除元素
System.out.println(jedis.zrem(key, "aaa"));
System.out.println(jedis.zrange(key, 0, -1));

// 給定值范圍內的成員數
System.out.println(jedis.zcount(key, 1002.0, 1003.0));
}

Jedis對哈希(Hashs)的操作

@Test
public void testHash() {
// 清空數據
System.out.println(jedis.flushDB());
String key = "myhash";
Map<String, String> hash = new HashMap<String, String>();
hash.put("aaa", "11");
hash.put("bbb", "22");
hash.put("ccc", "33");

// 添加數據
jedis.hmset(key, hash);
jedis.hset(key, "ddd", "44");

// 獲取hash的所有元素(key值)
System.out.println(jedis.hkeys(key));

// 獲取hash中所有的key對應的value值
System.out.println(jedis.hvals(key));

// 獲取hash里所有元素的數量
System.out.println(jedis.hlen(key));

// 獲取hash中全部的域和值,以Map<String, String> 的形式返回
Map<String, String> elements = jedis.hgetAll(key);
System.out.println(elements);

// 判斷給定key值是否存在於哈希集中
System.out.println(jedis.hexists(key, "bbb"));

// 獲取hash里面指定字段對應的值
System.out.println(jedis.hmget(key, "aaa", "bbb"));

// 獲取指定的值
System.out.println(jedis.hget(key, "aaa"));

// 刪除指定的值
System.out.println(jedis.hdel(key, "aaa"));
System.out.println(jedis.hgetAll(key));

// 為key中的域 field 的值加上增量 increment
System.out.println(jedis.hincrBy(key, "bbb", 100));
System.out.println(jedis.hgetAll(key));
}

　　Jedis操作事務

@Test
public void testTransaction() {
Transaction t = jedis.multi();
t.set("hello", "world");
Response<String> response = t.get("hello");

t.zadd("foo", 1, "barowitch");
t.zadd("foo", 0, "barinsky");
t.zadd("foo", 0, "barikoviev");
Response<Set<String>> sose = t.zrange("foo", 0, -1); //  返回全部相應並以有序集合的方式返回
System.out.println(response);
System.out.println(sose);
t.exec(); // 此行注意，不能缺少

String foolbar = response.get(); // Response.get() 可以從響應中獲取數據

int soseSize = sose.get().size(); // sose.get() 會立即調用set方法
System.out.println(foolbar);
System.out.println(sose.get());
}

　　Jedis操作管道

 

    @Test
    public void testTransactionPipeling() {
        Pipeline p = jedis.pipelined();//開一個管道

        p.set("fool", "bar");
        p.zadd("foo", 1, "barowitch");
        p.zadd("foo", 0, "barinsky");
        p.zadd("foo", 0, "barikoviev");
        Response<String> pipeString = p.get("fool");
        Response<Set<String>> sose = p.zrange("foo", 0, -1);
        System.out.println(pipeString);
        System.out.println(sose);

        p.sync();//提交

        System.out.println("==========");
        System.out.println(p.get("fool"));
        System.out.println(p.zrange("foo", 0, -1));

        int soseSize = sose.get().size();
        Set<String> setBack = sose.get();

        System.out.println(soseSize);
        System.out.println(setBack);
    }