【Redis破障之路】四：Jedis基本使用

在前面我們已經學習了Redis指令行用戶端redis-cli的使用，接下來我們了解一下Redis基于Java程式設計語言的用戶端。

在Java語言體系下，有三個常用的Redis用戶端

Jedis

、

Redisson

Lettuce

。三者各有特點，各有适用的場景。

• Jedis

  ：Redis的Java實作的用戶端，其API提供了比較全面的Redis指令的支援；

  Jedis中的方法調用是比較底層的暴露的Redis的API，也即Jedis中的Java方法基本和Redis的API保持着一緻，了解Redis的API，也就能熟練的使用Jedis。

• Redisson

  :實作了分布式和可擴充的Java資料結構，提供很多分布式相關操作服務，例如，分布式鎖，分布式集合，可通過Redis支援延遲隊列。和Jedis相比，功能較為簡單，不支援字元串操作，不支援排序、事務、管道、分區等Redis特性。Redisson的宗旨是促進使用者對Redis的關注分離，進而讓使用者能夠将精力更集中地放在處理業務邏輯上。

  Redisson中的方法則是進行比較高的抽象，每個方法調用可能進行了一個或多個Redis方法調用。

• Lettuce

  :進階Redis用戶端，用于線程安全同步，異步和響應使用，支援叢集，Sentinel，管道和編碼器。是SpringBoot2.x版本預設的用戶端。

好了，我們開始學習Jedis的使用吧。

1、Jedis的基本使用

建立Maven工程，在項目中添加Jedis依賴。

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

Jedis的使用方法非常簡單，隻要三行代碼就可以實作基本的set/get功能：

//1.生成一個Jedis對象，這個對象負責和指定Redis執行個體進行通信
        Jedis jedis = new Jedis("127.0.0.1", 6379);
        // 2.jedis執行set操作
        jedis.set("hello", "world");
        //3.jedis執行get操作,value="world"
        String value = jedis.get("hello");      

初始化Jedis需要兩個參數：Redis執行個體的IP和端口，除了這兩個參數外，還有一個包含了四個參數的構造函數是比較常用的：

Jedis(final String host, final int port, final int connectionTimeout, final int soTimeout)      

參數說明：

• host：Redis執行個體的所在機器的IP
• port：Redis執行個體的端口
• connectionTimeout：用戶端連接配接逾時
• soTimeout：用戶端讀寫逾時

可以列印輸出一下上面程式的結果：

和JDBC類似，一般涉及到這種網絡I/O的操作，最好使用try catch finally的形式，稍微修改一下上面的例子：

Jedis jedis = null;
        try {
            jedis = new Jedis("127.0.0.1", 6379);
            jedis.get("hello");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (jedis != null) {
                jedis.close();
            }
        }      

接下來我們看一下Jedis對各種基本資料類型的操作：

• 字元串

jedis.set("hello", "world");
        //結果 world
        System.out.println(jedis.get("hello"));
       //結果 1
        System.out.println(jedis.incr("counter"));      

• hash

jedis.hset("myhash", "f1", "v1");
        jedis.hset("myhash", "f2", "v2");
        //運作結果 {f2=v2, f1=v1}
        System.out.println(jedis.hgetAll("myhash"));      

• list

jedis.rpush("mylist", "1");
        jedis.rpush("mylist", "2");
        jedis.rpush("mylist", "3");
        //運作結果 [1, 2, 3]
        System.out.println(jedis.lrange("mylist",0,-1));      

• set

jedis.sadd("myset", "a");
        jedis.sadd("myset", "b");
        jedis.sadd("myset", "a");
        //運作結果 [b, a]
        System.out.println(jedis.smembers("myset"));      

• zset

Jedis jedis = new Jedis("127.0.0.1", 6379);
        jedis.zadd("thezset", 99, "tom");
        jedis.zadd("thezset", 66, "peter");
        jedis.zadd("thezset", 33, "james");
        //運作結果 james 33.0 peter 66.0 tom 99.0
        jedis.zrangeWithScores("thezset",0,-1).stream().forEach(s->{
            System.out.print(s.getElement()+" "+s.getScore()+" ");
        });      

2、序列化

在Java中，存儲對象一般會進行序列化和反序列化，Jedis本身并不支援序列化。可以引入遊戲額第三方的序列化工具，例如XML、Json、谷歌的Protobuf、Facebook的Thrift等等。

我們以protostuff（Protobuf的Java用戶端）為例來進行學習：

• 引入protostuff依賴

<properties>
        <protostuff.version>1.0.11</protostuff.version>
    </properties>
    
        <dependency>
            <groupId>com.dyuproject.protostuff</groupId>
            <artifactId>protostuff-runtime</artifactId>
            <version>${protostuff.version}</version>
        </dependency>
        <dependency>
            <groupId>com.dyuproject.protostuff</groupId>
            <artifactId>protostuff-core</artifactId>
            <version>${protostuff.version}</version>
        </dependency>          

• 定義實體類

public class Club implements Serializable {
    private int id; // id
    private String name; // 名稱
    private String info; // 描述
    private Date createDate; // 建立日期
    private int rank; // 排名
    //省略getter/setter等
}          

• 測試序列化和反序列化

// 1.生成序列化工具類
        ProtostuffSerializer protostuffSerializer = new ProtostuffSerializer();
        // 2.生成Jedis對象
        Jedis jedis = new Jedis("127.0.0.1", 6379);
        // 3.序列化
        String key = "club:1";
        // 定義實體對象
        Club club = new Club(1, "AC", "米蘭", new Date(), 1);
        // 序列化
        byte[] clubBtyes = protostuffSerializer.serialize(club);
        jedis.set(key.getBytes(), clubBtyes);
        // 4.反序列化
        byte[] resultBtyes = jedis.get(key.getBytes());
        Club resultClub = protostuffSerializer.deserialize(resultBtyes);
        //結果 Club{id=1, name='AC', info='米蘭', createDate=Sat May 15 22:21:42 CST 2021, rank=1}
        System.out.println(resultClub.toString());      

3、Jedis連接配接池

在上面我們使用的是Jedis的直連方式，每次都會建立TCP 連接配接，使用後再斷開連接配接。

這種頻繁的連接配接/斷開連接配接的過程顯然是對資源的一種浪費。

和資料庫連接配接池一樣，同樣可以引入池化技術，将Jedis連接配接存在池子（JedisPool）裡，每次去池子裡取，而不用重新建立。

連接配接池的方式是可以預先初始化好Jedis連接配接，是以每次隻需要從 Jedis連接配接池借用即可，而借用和歸還操作是在本地進行的，隻有少量的并發同步開銷，遠遠小于建立TCP連接配接的開銷。

Jedis提供了JedisPool這個類作為對Jedis的連接配接池，同時使用了Apache的通用對象池工具common-pool作為資源的管理工具。

使用JedisPool操 作Redis示例如下：

1）Jedis連接配接池（通常JedisPool是單例的）：

// common-pool連接配接池配置，這裡使用預設配置
        GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
        // 初始化Jedis連接配接池
        JedisPool jedisPool = new JedisPool(poolConfig, "127.0.0.1", 6379);      

2）擷取Jedis對象不再是直接生成一個Jedis對象進行直連，而是從連接配接池直接擷取：

Jedis jedis = null;
        try {
            // 1. 從連接配接池擷取jedis對象 
            jedis = jedisPool.getResource();
            // 2. 執行操作 
            jedis.get("hello");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (jedis != null) {
                // 如果使用JedisPool，close操作不是關閉連接配接，代表歸還連接配接池 
                jedis.close();
            }
        }      

面GenericObjectPoolConfig使用的是預設配置，實際它提供有很多參數，例如池子中最大連接配接數、最大空閑連接配接數、最小空閑連接配接數、連接配接活性檢測，等等。