Redis连接池的配置与使用

63 阅读 0 评论 42 点赞

我是靠谱客的博主精明向日葵，最近开发中收集的这篇文章主要介绍Redis连接池的配置与使用，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

Redis连接池

jedis连接资源的创建与销毁是很消耗程序性能，所以jedis为我们提供了jedis的池化技术，jedisPool在创建时初始化一些连接资源存储到连接池中，使用jedis连接资源时不需要创建，而是从连接池中获取一个资源进行redis的操作，使用完毕后，不需要销毁该jedis连接资源，而是将该资源归还给连接池，供其他请求使用。

下面给出 jedis详细配置的一些项

#最大总连接数     
redis.pool.maxTotal=1000 
   
#最大能够保持idel状态的对象数（最大活动树）   
redis.pool.maxIdle=100  
#最小能够保持idel状态的对象数（最小活动树）  
redis.pool.minIdle=50    

#当池内没有返回对象时，最大等待时间    
redis.pool.maxWaitMillis=10000    

#当调用borrow Object方法时，是否进行有效性检查    
redis.pool.testOnBorrow=true    
#当调用return Object方法时，是否进行有效性检查    
redis.pool.testOnReturn=true  

#“空闲链接”检测线程，检测的周期，毫秒数。如果为负值，表示不运行“检测线程”。默认为-1.  
redis.pool.timeBetweenEvictionRunsMillis=30000 
 
#向调用者输出“链接”对象时，是否检测它的空闲超时；  
redis.pool.testWhileIdle=true  

# 对于“空闲链接”检测线程而言，每次检测的链接资源的个数。默认为3.  
redis.pool.numTestsPerEvictionRun=50  

#redis服务器的IP    
redis.ip=xxxxxx  
#redis服务器的Port    
redis.port=6379

下面就是JedisPool配置初始化过程

jedis.propertis 这里就只配置了两个，就是最大连接数和最大活动数

host:127.0.0.1
port:6397
maxTotal=50
maxIdle=10

JedisPoolUtil.java

package com.yjj.util;

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

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

/**
 * 加载配置文件，配置连接池参数
 * 提供链接的方法
 * @author Administrator
 *
 */
public class JedisPoolUtil {

	private static JedisPool jedisPool;
	
	//当类加载就读取配置文件
	static{
		//类加载加载配置文件
		InputStream is=JedisPoolUtil.class.getClassLoader().getResourceAsStream("jedis.properties");
		
		//创建Properties对象
		Properties pr=new Properties();
		try {
			//关联文件
			pr.load(is);
		} catch (IOException e) {
			e.printStackTrace();
		}
		
		//获取数据，设置数据
		JedisPoolConfig config=new JedisPoolConfig();
		//最大连接数
		config.setMaxTotal(Integer.parseInt(pr.getProperty("maxTotal")));
		//设置最大的空闲连接
		config.setMaxIdle(Integer.parseInt(pr.getProperty("maxIdle")));
		
		//初始化JedisPool
		jedisPool=new JedisPool(pr.getProperty("host"),Integer.parseInt(pr.getProperty("port")));
	}
	
	//获取Jedis
	public static Jedis getJedis(){
		return jedisPool.getResource();
	}
	
	//释放资源
	public static void closeJedis(Jedis jedis){
		if(jedis!=null){
			jedis.close();
		}
	}
}

JedisPoolTest.java

package com.yjj.test;

import org.junit.Test;

import com.yjj.util.JedisPoolUtil;

import redis.clients.jedis.Jedis;

public class JedisPoolTest {

	@Test
	public void Test(){
		Jedis jedis=JedisPoolUtil.getJedis();
		jedis.set("hello", "hi");
		
		JedisPoolUtil.closeJedis(jedis);
	}
}