Java中Jedis基本使用

更新時(shí)間：2021年05月21日 10:48:42 作者：三分惡

Redis的Java實(shí)現(xiàn)的客戶端，本文主要介紹了Java中Jedis基本使用，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

在前面我們已經(jīng)學(xué)習(xí)了Redis命令行客戶端redis-cli的使用，接下來(lái)我們了解一下Redis基于Java編程語(yǔ)言的客戶端。

在Java語(yǔ)言體系下，有三個(gè)常用的Redis客戶端Jedis、Redisson、Lettuce。三者各有特點(diǎn)，各有適用的場(chǎng)景。

Java Redis客戶端

Jedis：Redis的Java實(shí)現(xiàn)的客戶端，其API提供了比較全面的Redis命令的支持；
Jedis中的方法調(diào)用是比較底層的暴露的Redis的API，也即Jedis中的Java方法基本和Redis的API保持著一致，了解Redis的API，也就能熟練的使用Jedis。
Redisson:實(shí)現(xiàn)了分布式和可擴(kuò)展的Java數(shù)據(jù)結(jié)構(gòu)，提供很多分布式相關(guān)操作服務(wù)，例如，分布式鎖，分布式集合，可通過(guò)Redis支持延遲隊(duì)列。和Jedis相比，功能較為簡(jiǎn)單，不支持字符串操作，不支持排序、事務(wù)、管道、分區(qū)等Redis特性。Redisson的宗旨是促進(jìn)使用者對(duì)Redis的關(guān)注分離，從而讓使用者能夠?qū)⒕Ω械胤旁谔幚順I(yè)務(wù)邏輯上。
Redisson中的方法則是進(jìn)行比較高的抽象，每個(gè)方法調(diào)用可能進(jìn)行了一個(gè)或多個(gè)Redis方法調(diào)用。
Lettuce:高級(jí)Redis客戶端，用于線程安全同步，異步和響應(yīng)使用，支持集群，Sentinel，管道和編碼器。是SpringBoot2.x版本默認(rèn)的客戶端。

好了，我們開(kāi)始學(xué)習(xí)Jedis的使用吧。

1、Jedis的基本使用

創(chuàng)建Maven工程，在項(xiàng)目中添加Jedis依賴。

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

Jedis的使用方法非常簡(jiǎn)單，只要三行代碼就可以實(shí)現(xiàn)基本的set/get功能：

        //1.生成一個(gè)Jedis對(duì)象，這個(gè)對(duì)象負(fù)責(zé)和指定Redis實(shí)例進(jìn)行通信
        Jedis jedis = new Jedis("127.0.0.1", 6379);
        // 2.jedis執(zhí)行set操作
        jedis.set("hello", "world");
        //3.jedis執(zhí)行g(shù)et操作,value="world"
        String value = jedis.get("hello");

初始化Jedis需要兩個(gè)參數(shù)：Redis實(shí)例的IP和端口，除了這兩個(gè)參數(shù)外，還有一個(gè)包含了四個(gè)參數(shù)的構(gòu)造函數(shù)是比較常用的：

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

參數(shù)說(shuō)明：

host：Redis實(shí)例的所在機(jī)器的IP
port：Redis實(shí)例的端口
connectionTimeout：客戶端連接超時(shí)
soTimeout：客戶端讀寫(xiě)超時(shí)

可以打印輸出一下上面程序的結(jié)果：

運(yùn)行結(jié)果

和JDBC類似，一般涉及到這種網(wǎng)絡(luò)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();
            }
        }

接下來(lái)我們看一下Jedis對(duì)各種基本數(shù)據(jù)類型的操作：

字符串

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

hash

        jedis.hset("myhash", "f1", "v1");
        jedis.hset("myhash", "f2", "v2");
        //運(yùn)行結(jié)果 {f2=v2, f1=v1}
        System.out.println(jedis.hgetAll("myhash"));

list

        jedis.rpush("mylist", "1");
        jedis.rpush("mylist", "2");
        jedis.rpush("mylist", "3");
        //運(yùn)行結(jié)果 [1, 2, 3]
        System.out.println(jedis.lrange("mylist",0,-1));

set

        jedis.sadd("myset", "a");
        jedis.sadd("myset", "b");
        jedis.sadd("myset", "a");
        //運(yùn)行結(jié)果 [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");
        //運(yùn)行結(jié)果 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中，存儲(chǔ)對(duì)象一般會(huì)進(jìn)行序列化和反序列化，Jedis本身并不支持序列化?？梢砸胗螒蝾~第三方的序列化工具，例如XML、Json、谷歌的Protobuf、Facebook的Thrift等等。

我們以protostuff（Protobuf的Java客戶端）為例來(lái)進(jìn)行學(xué)習(xí)：

引入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>

定義實(shí)體類

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

測(cè)試序列化和反序列化

        // 1.生成序列化工具類
        ProtostuffSerializer protostuffSerializer = new ProtostuffSerializer();
        // 2.生成Jedis對(duì)象
        Jedis jedis = new Jedis("127.0.0.1", 6379);
        // 3.序列化
        String key = "club:1";
        // 定義實(shí)體對(duì)象
        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);
        //結(jié)果 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的直連方式，每次都會(huì)新建TCP 連接，使用后再斷開(kāi)連接。

這種頻繁的連接/斷開(kāi)連接的過(guò)程顯然是對(duì)資源的一種浪費(fèi)。

Jedis直連Redis

和數(shù)據(jù)庫(kù)連接池一樣，同樣可以引入池化技術(shù)，將Jedis連接存在池子（JedisPool）里，每次去池子里取，而不用重新創(chuàng)建。

Jedis連接池使用

連接池的方式是可以預(yù)先初始化好Jedis連接，所以每次只需要從 Jedis連接池借用即可，而借用和歸還操作是在本地進(jìn)行的，只有少量的并發(fā)同步開(kāi)銷，遠(yuǎn)遠(yuǎn)小于新建TCP連接的開(kāi)銷。

Jedis提供了JedisPool這個(gè)類作為對(duì)Jedis的連接池，同時(shí)使用了Apache的通用對(duì)象池工具common-pool作為資源的管理工具。

使用JedisPool操作Redis示例如下：

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

        // common-pool連接池配置，這里使用默認(rèn)配置
        GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
        // 初始化Jedis連接池
        JedisPool jedisPool = new JedisPool(poolConfig, "127.0.0.1", 6379);

2）獲取Jedis對(duì)象不再是直接生成一個(gè)Jedis對(duì)象進(jìn)行直連，而是從連接池直接獲?。?/p>

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

面GenericObjectPoolConfig使用的是默認(rèn)配置，實(shí)際它提供有很多參數(shù)，例如池子中最大連接數(shù)、最大空閑連接數(shù)、最小空閑連接數(shù)、連接活性檢測(cè)，等等。