• 一、Redis 八種數據類型
• 二、Rdeis Jedis
• 三、Redis Lettuce
• 四、Redis 集群

一、Jedis 概述

Jedis 是 Redis 官方推薦的 Java 連接開發工具。使 Java 可以操作 Redis 中間件。

二、Jedis 示例

1. Ping

public class TestPing {    public static void main(String[] args) {        // 創建連接        Jedis jedis = new Jedis("127.0.0.1", 6379);        System.out.printf("測試連接: %s", jedis.ping()).println();        // 關閉連接        jedis.close();    }}

2. Password

public class TestPassword {    public static void main(String[] args) {        // 創建連接        Jedis jedis = new Jedis("127.0.0.1", 6379);        // 未設置密碼，跳過//        System.out.printf("驗證密碼: %s", jedis.auth("123456")).println();        // 連接        jedis.connect();        // 斷開連接        jedis.disconnect();        // 清除所有key        jedis.flushAll();        // 關閉連接        jedis.close();    }}

3. Key

public class TestKey {    public static void main(String[] args) {        // 創建連接        Jedis jedis = new Jedis("127.0.0.1", 6379);        System.out.println("清空數據: " + jedis.flushDB());        System.out.println("判斷username鍵是否存在: " + jedis.exists("username"));        System.out.println("新增<"username","qs">的鍵值對: " + jedis.set("username", "qs"));        System.out.println("新增<"password","123">的鍵值對: " + jedis.set("password", "123"));        System.out.print("系統中所有的鍵如下: ");        Set<String> keys = jedis.keys("*");        System.out.println(keys);        System.out.println("刪除鍵password: " + jedis.del("password"));        System.out.println("判斷鍵password是否存在: " + jedis.exists("password"));        System.out.println("查看鍵username所存儲的值的類型: " + jedis.type("username"));        System.out.println("隨機返回key空間中一個key: " + jedis.randomKey());        System.out.println("重命名key: " + jedis.rename("username", "name"));        System.out.println("取出修改后的name: " + jedis.get("name"));        System.out.println("按索引查詢: " + jedis.select(0));        System.out.println("刪除當前選擇數據庫中的所有key: " + jedis.flushDB());        System.out.println("返回當前數據庫中key的數目: " + jedis.dbSize());        System.out.println("刪除所有數據庫中的所有key: " + jedis.flushAll());        // 關閉連接        jedis.close();    }}

4. String

public class TestString {    public static void main(String[] args) {        // 創建連接        Jedis jedis = new Jedis("127.0.0.1", 6379);        jedis.flushDB();        System.out.println("===========增加數據===========");        System.out.println(jedis.set("key1", "value1"));        System.out.println(jedis.set("key2", "value2"));        System.out.println(jedis.set("key3", "value3"));        System.out.println("修改key1: " + jedis.set("key1", "value1Changed"));        System.out.println("獲取key1的值: " + jedis.get("key1"));        System.out.println("刪除鍵key2: " + jedis.del("key2"));        System.out.println("獲取鍵key2: " + jedis.get("key2"));        System.out.println("在key3后面加入值: " + jedis.append("key3", "End"));        System.out.println("獲取key3的值: " + jedis.get("key3"));        System.out.println("增加多個鍵值對：" + jedis.mset("key01", "value01", "key02", "value02", "key03", "value03"));        System.out.println("獲取多個鍵值對：" + jedis.mget("key01", "key02", "key03"));        System.out.println("獲取多個鍵值對：" + jedis.mget("key01", "key02", "key03", "key04"));        System.out.println("刪除多個鍵值對：" + jedis.del("key01", "key02"));        System.out.println("獲取多個鍵值對：" + jedis.mget("key01", "key02", "key03"));        jedis.flushDB();        System.out.println("===========新增鍵值對防止覆蓋原先值==============");        System.out.println(jedis.setnx("key1", "value1"));        System.out.println(jedis.setnx("key2", "value2"));        System.out.println(jedis.setnx("key2", "value2-new"));        System.out.println(jedis.get("key1"));        System.out.println(jedis.get("key2"));        System.out.println("===========新增鍵值對并設置有效時間=============");        System.out.println(jedis.setex("key3", 2, "value3"));        System.out.println(jedis.get("key3"));        try {            TimeUnit.SECONDS.sleep(3);        } catch (InterruptedException e) {            e.printStackTrace();        }        System.out.println(jedis.get("key3"));        System.out.println("===========獲取原值，更新為新值==========");        System.out.println(jedis.getSet("key2", "key2GetSet"));        System.out.println(jedis.get("key2"));        System.out.println("獲得key2的值的字串: " + jedis.getrange("key2", 2, 4));        // 關閉連接        jedis.close();    }}

5. List

public class TestList {    public static void main(String[] args) {        // 創建連接        Jedis jedis = new Jedis("127.0.0.1", 6379);        jedis.flushDB();        System.out.println("===========添加一個list===========");        jedis.lpush("collections", "ArrayList", "Vector", "Stack", "HashMap", "WeakHashMap", "LinkedHashMap");        jedis.lpush("collections", "HashSet");        jedis.lpush("collections", "TreeSet");        jedis.lpush("collections", "TreeMap");        // -1代表倒數第一個元素，-2代表倒數第二個元素，end為-1表示查詢全部        System.out.println("collections的內容: " + jedis.lrange("collections", 0, -1));        System.out.println("collections區間0-3的元素: " + jedis.lrange("collections", 0, 3));        System.out.println("===============================");        // 刪除列表指定的值，第二個參數為刪除的個數（有重復時），后add進去的值先被刪，類似于出棧        System.out.println("刪除指定元素個數: " + jedis.lrem("collections", 2, "HashMap"));        System.out.println("collections的內容: " + jedis.lrange("collections", 0, -1));        System.out.println("刪除下標0-3區間之外的元素: " + jedis.ltrim("collections", 0, 3));        System.out.println("collections的內容: " + jedis.lrange("collections", 0, -1));        System.out.println("collections列表出棧（左端）: " + jedis.lpop("collections"));        System.out.println("collections的內容: " + jedis.lrange("collections", 0, -1));        System.out.println("collections添加元素，從列表右端，與lpush相對應: " + jedis.rpush("collections", "EnumMap"));        System.out.println("collections的內容: " + jedis.lrange("collections", 0, -1));        System.out.println("collections列表出棧（右端）: " + jedis.rpop("collections"));        System.out.println("collections的內容: " + jedis.lrange("collections", 0, -1));        System.out.println("修改collections指定下標1的內容: " + jedis.lset("collections", 1, "LinkedArrayList"));        System.out.println("collections的內容: " + jedis.lrange("collections", 0, -1));        System.out.println("===============================");        System.out.println("collections的長度: " + jedis.llen("collections"));        System.out.println("獲取collections下標為2的元素: " + jedis.lindex("collections", 2));        System.out.println("===============================");        jedis.lpush("sortedList", "3", "6", "2", "0", "7", "4");        System.out.println("sortedList排序前: " + jedis.lrange("sortedList", 0, -1));        System.out.println(jedis.sort("sortedList"));        System.out.println("sortedList排序后: " + jedis.lrange("sortedList", 0, -1));        // 關閉連接        jedis.close();    }}

6. Set

public class TestSet {    public static void main(String[] args) {        // 創建連接        Jedis jedis = new Jedis("127.0.0.1", 6379);        jedis.flushDB();        System.out.println("============向集合中添加元素（不重復）============");        System.out.println(jedis.sadd("eleSet", "e1", "e2", "e4", "e3", "e0", "e8", "e7", "e5"));        System.out.println(jedis.sadd("eleSet", "e6"));        System.out.println(jedis.sadd("eleSet", "e6"));        System.out.println("eleSet的所有元素為: " + jedis.smembers("eleSet"));        System.out.println(&