redis单节点和集群配置及工具类

太过爱你忘了你带给我的痛 2022-05-29 08:42 214阅读 0赞

<dependency>
    			<groupId>redis.clients</groupId>
    			<artifactId>jedis</artifactId>
    			<version>2.8.1</version>
    		</dependency>

可视包：
    
    jedis-2.8.1.jar
         commons-pool2-2.4.2.jar

配置文件:

##############Redis singleton configuration
    redis.singleton.host=dev-redis.com
    redis.singleton.port=6379
    redis.singleton.password=
    redis.singleton.db=6
    redis.singleton.timeout=300000
    
    ##############Redis claster configuration
    
    redis.claster.claster1=xx.xx.xx.xx:7001
    redis.claster.claster2=xx.xx.xx.xx:7002
    redis.claster.claster3=xx.xx.xx.xx:7003
    redis.claster.claster4=xx.xx.xx.xx:7001
    redis.claster.claster5=xx.xx.xx.xx:7002
    redis.claster.claster6=xx.xx.xx.xx:7003
    
    #############Common Redis configuration
    redis.minIdle=5
    #最大空闲连接数, 默认8个
    redis.maxIdle=10
    #最大连接数, 默认8个
    redis.maxTotal=20
    #获取连接时的最大等待毫秒数(如果设置为阻塞时BlockWhenExhausted),如果超时就抛异常, 小于零:阻塞不确定的时间,  默认-1
    redis.maxWaitMillis=-1
    #在获取连接的时候检查有效性, 默认false
    redis.testOnBorrow=true
    
    
    addressKeyPrefix=redis.claster.claster
    redis.timeout=300000
    redis.maxRedirections=6
    
    
    #设置redis key过期时间为30天(seconds)
    redis.expired=2592000

工具类：

package com.cn;
    
    import java.util.HashSet;
    import java.util.List;
    import java.util.Set;
    import java.util.regex.Pattern;
    
    import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    
    import redis.clients.jedis.HostAndPort;
    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisCluster;
    import redis.clients.jedis.JedisPool;
    import redis.clients.jedis.JedisPoolConfig;
    /**
     *  redis 工具类
     */
    public class RedisUtil{
    
    		private volatile static JedisCluster jedisCluster;  
    		private volatile static Jedis jedis;
    		
    		private static Logger logger=LoggerFactory.getLogger(RedisUtil.class);
    
    		public RedisUtil(){}
    
    		// 线程安全  集群
            public static JedisCluster getInstance(){
        	     
        	   if (jedisCluster == null) {  
        	        synchronized (RedisUtil.class) {  
    	    	        if (jedisCluster == null) {  
    	    	        	   GenericObjectPoolConfig g=new GenericObjectPoolConfig();
    	    	    	       g.setMaxWaitMillis(Integer.parseInt(ResourcesUtil.getValue("redis", "redis.maxWaitMillis")));
    	    	    	       g.setMaxTotal(Integer.parseInt(ResourcesUtil.getValue("redis", "redis.maxTotal")));
    	    	    	       g.setMinIdle(Integer.parseInt(ResourcesUtil.getValue("redis", "redis.minIdle")));
    	    	    	       g.setMaxIdle(Integer.parseInt(ResourcesUtil.getValue("redis", "redis.maxIdle")));
    	    	    	       g.setTestOnBorrow(Boolean.valueOf(ResourcesUtil.getValue("redis", "redis.testOnBorrow")));
    	    	    	   	Set<HostAndPort> haps;
    						try {
    							haps = parseHostAndPort();
    							 jedisCluster = new JedisCluster(haps,Integer.parseInt(ResourcesUtil.getValue("redis", "redis.timeout")),Integer.parseInt(ResourcesUtil.getValue("redis", "redis.maxRedirections")), g);
    							 logger.info("获取jedis对象成功...");
    		    				 return jedisCluster;
    						} catch (Exception e) {
    							e.printStackTrace();
    							logger.error("获取jedis对象失败: \n"+e.getMessage());
    						}
    	    	        }  
        	        }  
        	    }
    	     	return jedisCluster;  
           }
          // 线程安全  单节点
            public static Jedis init(){
       	     
         	   if (jedis == null) {  
         	        synchronized (RedisUtil.class) {  
     	    	        if (jedis == null) {  
     	    	        	  JedisPoolConfig g = new JedisPoolConfig();
     	    	    	       g.setMaxWaitMillis(Integer.parseInt(ResourcesUtil.getValue("redis", "redis.maxWaitMillis")));
     	    	    	       g.setMaxTotal(Integer.parseInt(ResourcesUtil.getValue("redis", "redis.maxTotal")));
     	    	    	       g.setMinIdle(Integer.parseInt(ResourcesUtil.getValue("redis", "redis.minIdle")));
     	    	    	       g.setMaxIdle(Integer.parseInt(ResourcesUtil.getValue("redis", "redis.maxIdle")));
     	    	    	       g.setTestOnBorrow(Boolean.valueOf(ResourcesUtil.getValue("redis", "redis.testOnBorrow")));
     						try {
     							  JedisPool pool=new JedisPool(ResourcesUtil.getValue("redis", "redis.singleton.host"),Integer.parseInt(ResourcesUtil.getValue("redis", "redis.singleton.port")));
     							  jedis=pool.getResource();
     							 logger.info("获取jedis对象成功...");
     		    				 return jedis;
     						} catch (Exception e) {
     							e.printStackTrace();
     							logger.error("获取jedis对象失败: \n"+e.getMessage());
     						}
     	    	        }  
         	        }  
         	    }
     	     	return jedis;  
            }
    
    		private static Set<HostAndPort> parseHostAndPort() throws Exception {  
    			try {  
    
    				Set<HostAndPort> haps = new HashSet<HostAndPort>();  
    				List<String> list=ResourcesUtil.gekeyList("redis");
    				for(String key:list){
    					if (!key.startsWith(ResourcesUtil.getValue("redis", "addressKeyPrefix"))) {  
    						continue;  
    					}  
    					String val = ResourcesUtil.getValue("redis", key);
    					
    					Pattern p = Pattern.compile("^.+[:]\\d{1,5}\\s*$");
    					
    					boolean isIpPort = p.matcher(val).matches();  
    					
    					if (!isIpPort) {  
    						throw new IllegalArgumentException("ip 或 port 不合法");  
    					}  
    					String[] ipAndPort = val.split(":");  
    
    					HostAndPort hap = new HostAndPort(ipAndPort[0], Integer.parseInt(ipAndPort[1]));  
    					haps.add(hap);  
    				}
    				return haps;  
    			} catch (IllegalArgumentException ex) {  
    				throw ex;  
    			} catch (Exception ex) {  
    				throw new Exception("解析 jedis 配置文件失败", ex);  
    			}  
    		}  
    
    	   public static void main(String[] args) {
    //		   Map<String, Object> map=new HashMap<>();
    //		   map.put("2017-11-15", "3");
    //		   JedisCluster jedisCluster=RedisUtil.getInstance();
    		   jedisCluster.set("good",JSON.toJSONString(map));
    //		   jedisCluster.setex("good",10,JSON.toJSONString(map));
    //		  System.out.println(jedisCluster.get("good"));
    	  }
    	
    }