Redis第五节——Jedis连接池

2023-09-06  本文已影响0人  杜艳_66c4

1、jedis连接池: jedisPool

使用:
1、创建JedisPool连接池对象
2、调用方法getResource()方法获取Jedis链接

Jedis的配置


详细配置项 jedispool的使用

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

2、Jedis连接池工具类

测试类
package cn.dayJedis;

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 JedisPoolUtil {

    private static JedisPool jedisPool;

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

        JedisPool jedisPool1 = new JedisPool(config, pro.getProperty("host"), Integer.parseInt(pro.getProperty("port")));

    }


    /*
   获取连接的方法
    */
    public static Jedis getJedis(){

        return jedisPool.getResource();
    }

}

测试类

package cn.dayJedis;

import redis.clients.jedis.Jedis;

public class JedisTest {
    public static void main(String[] args) {
        new JedisTest().test();
    }

    public void test(){
        //通过连接池工具类获取
        Jedis jedis = JedisPoolUtil.getJedis();

        //使用
        jedis.set("hh","ee");

    }

}
上一篇下一篇

猜你喜欢

热点阅读