Java代码封装redis工具类

maven依赖关系：

        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>2.9.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-pool2</artifactId>
            <version>2.6.0</version>
        </dependency>

源码：

package StudyPro.service;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

/**
 * 使用连接池封装Redis连接工具类
 */
public class RedisUtils {
    private static JedisPool jedisPool;
    private static Properties properties;
    private static String proPath = "redisConfig.properties";
    private static boolean authFlag;
    private static String password;

    static {
        //读取配置文件
        try {
            readConfigFile();
        } catch (IOException e) {
            e.printStackTrace();
        }

        // 配置连接池
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        poolConfig.setMaxIdle(20);
        poolConfig.setMinIdle(10);
        poolConfig.setMaxTotal(30);
        poolConfig.setMaxWaitMillis(3000);
        poolConfig.setTestOnBorrow(true);
        poolConfig.setTestOnReturn(true);
        jedisPool = new JedisPool(properties.getProperty("redis.host"), Integer.valueOf(properties.getProperty("redis.port")));

        //判断是否需要密码验证
        if ("1".equals(properties.getProperty("redis.authFlag"))) {
            authFlag = true;
            password = properties.getProperty("redis.password");
            if (password == null) {
                try {
                    throw new Exception("redis密码没有读取到！");
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        }
    }

    private static Properties readConfigFile() throws IOException {
        InputStream in = RedisUtils.class.getClass().getResourceAsStream("/" + proPath);
        if (in == null) {
            throw new IOException("读取不到配置文件：" + proPath);
        }
        properties = new Properties();
        properties.load(in);
        in.close();
        return properties;
    }

    public static Jedis getResource() {
        Jedis jedis = jedisPool.getResource();
        if (authFlag) {
            jedis.auth(password);
        }
        return jedis;
    }

    public static void close() {
        jedisPool.close();
    }
}

配置文件redisConfig.properties：

redis.host=10.15.1.19
redis.port=16379
# auth:0不需要密码；1需要密码
redis.authFlag=1
redis.password=wC3Xo8E5mlmgMb

测试代码：

package StudyPro.service;

import org.junit.Test;
import redis.clients.jedis.Jedis;

public class TestRedisUtils {
    @Test
    public void test() {
        Jedis jedis = RedisUtils.getResource();
//        jedis.auth("wC3Xo8E5mlmgMb");
        System.out.println(jedis.get("a"));
        jedis.close();
        RedisUtils.close();

    }
}