Redis redis自动连接,释放示例

港控/mmm° 2022-03-26 08:07 775阅读 0赞

一.  搭建简单的redis需要的jar包

commons-pool2-2.4.2.jar

spring-data-redis-1.4.0.RELEASE.jar

jedis-2.4.2.jar

此三个版本的jar包能够完全的配合,不会出现jar包冲突,或者版本不符合的情况.redis作为一个数据库,不会影响到正常的业务逻辑.

在java项目中,我们从redis查询是否有我们所需要的缓存,如果没有从数据库中查询出来,然后再存入redis缓存中,redis缓存相当于一个数据库的功能

二.redis配置文件:redis.properties

#最大活动对象数     
    redis.pool.maxTotal=1000
    #最大能够保持idel状态的对象数      
    redis.pool.maxIdle=1000
    #最小能够保持idel状态的对象数   
    redis.pool.minIdle=10
    #当池内没有返回对象时，最大等待时间    
    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.timeout=5000
    #redis服务器的IP
    redis.ip=127.0.0.1
    #redis服务器的Port    
    redis.port=6379
    #redis服务器的密码   
    redis.password=shenzhenair123

三.读取redis配置文件

public class LoadRedisProperties {
    	static Logger log = Logger.getLogger(LoadRedisProperties.class);
    	public static final String REDIS_PROPERTIES_PATH = "redis.properties";
    	
    	public  static Properties  initProper() {	
    		InputStream  is = null;
    		Properties  pro = new Properties();
    		try {
    			 pro = new Properties();
    			 is= Thread.currentThread().getContextClassLoader().getResourceAsStream(REDIS_PROPERTIES_PATH);
    			pro.load(is);
    		} catch (IOException e) {
    			e.printStackTrace();
    		}finally{
    			if(is != null){
    				try {
    					is.close();
    				} catch (IOException e) {
    					e.printStackTrace();
    				}
    			}
    		}
    		return pro;
    	}
    	
    
    	public static void main(String[] args) {
    		Properties initProper = LoadRedisProperties.initProper();
    		System.out.println(initProper);
    	}

一.redis利用连接池自动连接和释放

public class RedisUtil {
    	   static Logger log = Logger.getLogger(RedisUtil.class);
    		
    		private static JedisPool jedisPool = null;
    		private static Integer MAX_TOTAL = null;
    		private static Integer MAX_IDLE = null;
    		private static Integer MIN_IDLE = null;
    		private static Integer MAX_WAIT = null;
    		private static String IP = null;
    		private static Integer PORT = null;
    		private static Integer TIME_OUT = null;
    		private static String PASSWORD = null;
    	
    		
    		//初始化redis连接池
    	    static{
    	    	 Properties pro = LoadRedisProperties.initProper();
    	    	 MAX_TOTAL = Integer.valueOf((String) pro.get("redis.pool.maxTotal"));
    	    	 MAX_IDLE = Integer.valueOf((String) pro.get("redis.pool.maxIdle"));
    	    	 MIN_IDLE = Integer.valueOf((String) pro.get("redis.pool.minIdle"));
    	    	 MAX_WAIT = Integer.valueOf((String) pro.get("redis.pool.maxWaitMillis"));
    	    	 IP =  (String) pro.get("redis.ip");
    	    	 PORT = Integer.valueOf((String) pro.get("redis.port"));
    	    	 TIME_OUT = Integer.valueOf((String) pro.get("redis.timeout"));
    	    	 PASSWORD = (String) pro.get("redis.password");
    	       
    	    	 JedisPoolConfig config = new JedisPoolConfig();
    	        //配置最大jedis实例数
    	        config.setMaxTotal(MAX_TOTAL);
    	        //配置资源池最大闲置数
    	        config.setMaxIdle(MAX_IDLE);
    	        // 配置资源的最小闲置数
    	        config.setMinIdle(MIN_IDLE);
    	        //等待可用连接的最大时间
    	        config.setMaxWaitMillis(MAX_WAIT);
    	        //#使用连接时，检测连接是否成功
    	        config.setTestOnReturn(true);
    	        //则得到的jedis实例均是可用的
    	        config.setTestOnBorrow(true);
    	        if(null == PASSWORD || PASSWORD.length() == 0){
    	        	 jedisPool = new JedisPool(config,IP,PORT,TIME_OUT);
    	        }else{
    	        	jedisPool = new JedisPool(config,IP,PORT,TIME_OUT, PASSWORD);
    	        }
    	    }
    
    	    //获取Jedis实例
    	    public synchronized static Jedis getJedis(){
    	        if(jedisPool != null){
    	            Jedis resource = jedisPool.getResource();
    	            return resource;
    	        }else{
    	            return null;
    	        }
    	    }
    
    		    //释放Jedis资源
    		    public static void closeJedis(final Jedis jedis){
    		        if(jedis != null){
    		            jedisPool.returnResource(jedis);
    		        }
    		    }
    		    
    		    public static void main(String[] args) {
    				Jedis jedis = getJedis();
    			}
    		    
       
    }

三. json转换工具,把List集合转化为json,把json转化为相关对象的集合

public class JsonUtils {
    	
    	    /**
    	     * list对象集合转化为json字符串
    	     * @param <T>
    	     * @param ts
    	     * @return
    	     */
    	    public static <T> String listToJson(List<T> ts) {
    	        String jsons = JSON.toJSONString(ts);
    	        return jsons;
    	    }
    
    	    /**
    	     * json转化为List对象集合
    	     */
    	    public static <T> List<T> jsonToList(String jsonString, Class<T> clazz) {
    	        @SuppressWarnings("unchecked")
    	        List<T> ts = (List<T>) JSONArray.parseArray(jsonString, clazz);
    	        return ts;
    	    }
    	
    }

四.在java中进行调用示例

try {
    				key = fdlBsg.getAirline()+fdlBsg.getOcty()+fdlBsg.getDcty();
    				jedis = RedisUtil.getJedis();
    				String discountListJson = jedis.hget("FDL_REPORT_DATA_RATE_DISCOUNT", fdlBsg.getAirline()+fdlBsg.getOcty()+fdlBsg.getDcty());
    				if(null != discountListJson && discountListJson.length() > 0){
    					 discountList = JsonUtils.jsonToList(discountListJson, DiscountMangent.class);
    				}
    			} catch (Exception e) {
    				e.printStackTrace();
    			}finally{
    				RedisUtil.closeJedis(jedis);
    			}