Jedis-连接池、连接池工具类

Jedis-连接池

jedis连接池：JedisPool

JedisTest测试类

　　 /**
     * jedis连接池使用
     */
    @Test
    public void test7() {
        // 0.创建一个配置值对象
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(50);;
        config.setMaxIdle(10);

        // 1.创建Jedis连接池对象
        JedisPool jedisPool = new JedisPool(config, "localhost", 6379);

        // 2.获取连接
        Jedis jedis = jedisPool.getResource();
        // 3.使用
        jedis.set("hehe","haha");

        // 4.关闭 归还到连接池中
        jedis.close();
    }

Jedis-连接池工具类

jedis.properties配置文件

 创建util工具包，创建JedisPoolUtils工具类

package com.example.day23_redis.jedis.util;

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;

/*
   JedisPool工具类
    加载配合文件,配置连接池的参数
    提供获取连接的方法
 */
public class JedisPoolUtils {

    private static JedisPool jedisPool;

    static {
        // 读取配置文件
        InputStream is = JedisPoolUtils.class.getClassLoader().getResourceAsStream("jedis.properties");
        // 创建Properties对象
        Properties pro = new Properties();
        // 关联文件
        try {
            pro.load(is);
        } catch (IOException e) {
            e.printStackTrace();
        }
        // 获取数据,设置到JedisPoolConfig中
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(Integer.parseInt(pro.getProperty("maxTotal")));
        config.setMaxIdle(Integer.parseInt(pro.getProperty("maxIdle")));

        // 初始化JedisPool
        jedisPool = new JedisPool(config,pro.getProperty("host"),Integer.parseInt(pro.getProperty("port")));
    }

    /**
     * 获取连接方法
     */
    public static Jedis getJedis() {
        return jedisPool.getResource();
    }
}

JedisTest测试类

    /**
     * jedis连接池工具类使用
     */
    @Test
    public void test8() {
        // 通过连接池工具类获取
        Jedis jedis = JedisPoolUtils.getJedis();

        // 3.使用
        jedis.set("hello","world");

        // 4.关闭 归还到连接池中
        jedis.close();
    }