Jedis介紹

jedis是封裝了redis的java客戶端，提供了更簡單的redis操作API，同時SpringBoot也將redis做了封裝，但是用來直接操作redis步驟繁瑣。

redis配置檔案

1 . 引入redis

<dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

2 . 配置redis連線屬性

說明：SpringBoot會根據application.properties中的配置檔案，對SpringBoot整合的redis進行自動的配置，將屬性檔案自動注入到org.springframework.boot.autoconfigure.data.redis.RedisProperties類中，

        #redis配置
        ################################################

        #redis資料庫索引(預設為0)
        spring.redis.database=0
        #redis伺服器IP地址
 

        spring.redis.host=
        #redis埠號
        spring.redis.port=6379
        #redis密碼，預設為空
        spring.redis.password=
        #連線redis超時時間（毫秒）
        spring.redis.time-out=0ms

        #jedis連線池
        ###############################
        #最大等待時間
        spring.redis.jedis.pool.max-wait=1000
 
ms
        #最小空閒數量
        spring.redis.jedis.pool.min-idle=1
        #最大空閒數量
        spring.redis.jedis.pool.max-idle=10
        #最大連線數量
        spring.redis.jedis.pool.max-active=1000

3 . 關於RedisProperties類的原始碼分析：

package org.springframework.boot.autoconfigure.data.redis;

import java.time.Duration;
import java.util.List;

import org.springframework.boot.context.properties.ConfigurationProperties;

/**
 * Configuration properties for Redis.（redis的屬性配置類）
 */
@ConfigurationProperties(prefix = "spring.redis")
public class RedisProperties {

    /**
     * Database index used by the connection factory.
     */
    private int database = 0;

    /**
     * Connection URL. Overrides host, port, and password. User is ignored. Example:
     * redis://user:[email protected]:6379
     */
    private String url;

    /**
     * Redis server host.
     */
    private String host = "localhost";

    /**
     * Login password of the redis server.
     */
    private String password;

    /**
     * Redis server port.
     */
    private int port = 6379;

    /**
     * Whether to enable SSL support.
     */
    private boolean ssl;

    /**
     * Connection timeout.
     */
    private Duration timeout;

    private Sentinel sentinel;

    private Cluster cluster;

    private final Jedis jedis = new Jedis();

    private final Lettuce lettuce = new Lettuce();

    /**
    *此處省略了所有的get set方法
    */

    /**
     * Pool properties.（連線池的配置資訊）
     */
    public static class Pool {

        /**
         * Maximum number of "idle" connections in the pool. Use a negative value to
         * indicate an unlimited number of idle connections.
         */
        private int maxIdle = 8;

        /**
         * Target for the minimum number of idle connections to maintain in the pool. This
         * setting only has an effect if it is positive.
         */
        private int minIdle = 0;

        /**
         * Maximum number of connections that can be allocated by the pool at a given
         * time. Use a negative value for no limit.
         */
        private int maxActive = 8;

        /**
         * Maximum amount of time a connection allocation should block before throwing an
         * exception when the pool is exhausted. Use a negative value to block
         * indefinitely.
         */
        private Duration maxWait = Duration.ofMillis(-1);
        /**
        *省略了關於連線池屬性資訊的get set方法
        */
    }

    /**
     * Cluster properties.（叢集配置資訊）
     */
    public static class Cluster {

        /**
         * Comma-separated list of "host:port" pairs to bootstrap from. This represents an
         * "initial" list of cluster nodes and is required to have at least one entry.
         */
        private List<String> nodes;

        /**
         * Maximum number of redirects to follow when executing commands across the
         * cluster.
         */
        private Integer maxRedirects;
        /**
        *省略了關於叢集配置資訊的get set方法
        */

    }

    /**
     * Redis sentinel properties.（哨兵屬性資訊）
     */
    public static class Sentinel {

        /**
         * Name of the Redis server.
         */
        private String master;

        /**
         * Comma-separated list of "host:port" pairs.
         */
        private List<String> nodes;
        /**
        *省略了關於哨兵屬性資訊的get set方法
        */

    }

    /**
     * Jedis client properties.（redis的客戶端jedis）
     */
    public static class Jedis {

        /**
         * Jedis pool configuration.
         */
        private Pool pool;
        /**
        *省略了關於jedis屬性資訊的get set方法
        */

    }

    /**
     * Lettuce client properties.
     */
    public static class Lettuce {

        /**
         * Shutdown timeout.
         */
        private Duration shutdownTimeout = Duration.ofMillis(100);

        /**
         * Lettuce pool configuration.
         */
        private Pool pool;
    }

}

Jedis配置

1 . 引入jedis客戶端依賴

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

2 . 建立JedisPoolFactory類，用來配置JedisPool屬性資訊，以及建立RedisPool

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.data.redis.RedisProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

@Configuration
public class JedisPoolFactory {

    //自動注入redis配置屬性檔案
    @Autowired
    private RedisProperties properties;

    @Bean
    public JedisPool getJedisPool(){
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxIdle(properties.getJedis().getPool().getMaxIdle());
        config.setMaxTotal(properties.getJedis().getPool().getMaxActive());
        config.setMaxWaitMillis(properties.getJedis().getPool().getMaxWait().toMillis());
        JedisPool pool = new JedisPool(config,properties.getHost(),properties.getPort(),100);
        return pool;
    }
}

通過SpringBoot容器來自動建立以及注入JedisPool

    @Autowired
    private JedisPool jedisPool;

至此，便可以使用jedisPool.getResource();方法來獲取Jedis來操作redis資料庫了