spring boot配置同时支持单机和集群redis

系统管理员 2022-05-08 12:34 736阅读 0赞

正式环境都是用集群版redis，开发用的单机版，领导要求通过配置文件来确定是单机还是集群，由于单机版已经实现了，那么准备就在单机版基础上进行开发，然后发现spring boot1.2版本已经比较老，就升级版本，由于升级了spring boot版本，对应其他配置也进行了修改。最终修改的配置如下：

pom.xml

<properties>
    	<java.version>1.8</java.version>
    	<spring.version>4.3.9.RELEASE</spring.version>
    	<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>
    <parent>
    	<groupId>org.springframework.boot</groupId>
    	<artifactId>spring-boot-starter-parent</artifactId>
    	<version>1.5.8.RELEASE</version>
    </parent>
    <dependency>
    	<groupId>org.springframework.boot</groupId>
    	<artifactId>spring-boot-starter-data-redis</artifactId>
           
    </dependency>
    <dependency>
    	<groupId>redis.clients</groupId>
    	<artifactId>jedis</artifactId>
    	<version>2.9.0</version>
    </dependency>

redis.properties文件基本没有变:

# REDIS (RedisProperties) 
    # Redis服务器地址(集群用逗号分隔)
    #spring.redis.host=xxx.xxx.xxx.xxx:xxxxx
    spring.redis.host=xxx.xxx.xxx.xxx:xxxxx,xxx.xxx.xxx.xxx:xxxxx
    # Redis服务器连接密码（默认为空）
    spring.redis.password=123456
    # 连接超时时间（毫秒）
    spring.redis.timeout=2000
    spring.redis.max-redirects=8

注意：host变成ip:port,集群多个ip和端口用“,”分割，为什么这样写spring框架中RedisClusterConfiguration类中就是这样分割。看一下源代码：

//RedisClusterConfiguration类：
    private static final String REDIS_CLUSTER_NODES_CONFIG_PROPERTY = "spring.redis.cluster.nodes";  //默认是配置这样的
    ……
    public RedisClusterConfiguration(PropertySource<?> propertySource) {
    
    	notNull(propertySource, "PropertySource must not be null!");
    
    	this.clusterNodes = new LinkedHashSet<RedisNode>();
            //有spring.redis.cluster.nodes配置，分割这个属性，添加node
    	if (propertySource.containsProperty(REDIS_CLUSTER_NODES_CONFIG_PROPERTY)) {
    		appendClusterNodes(commaDelimitedListToSet(propertySource.getProperty(REDIS_CLUSTER_NODES_CONFIG_PROPERTY)
    				.toString()));
    	 }
             ……
    	}
    //函数会调用，用"，"分割：
    public static String[] commaDelimitedListToStringArray(String str) {
    	return delimitedListToStringArray(str, ",");
    }
    //然后用":"分割组装成RedisNode
    private void appendClusterNodes(Set<String> hostAndPorts) {
    
    	for (String hostAndPort : hostAndPorts) {
    		addClusterNode(readHostAndPortFromString(hostAndPort));
    	}
    }
    
    private RedisNode readHostAndPortFromString(String hostAndPort) {
    	String[] args = split(hostAndPort, ":");
    
    	notNull(args, "HostAndPort need to be seperated by  ':'.");
    	isTrue(args.length == 2, "Host and Port String needs to specified as host:port");
    	return new RedisNode(args[0], Integer.valueOf(args[1]).intValue());
    }

在cacheconfig类中变成这样的：

@Bean
    	public RedisClusterConfiguration getClusterConfiguration() {
    		if (host.split(",").length > 1) {
                            //如果是host是集群模式的才进行以下操作
    			Map<String, Object> source = new HashMap<String, Object>();
    
    			source.put("spring.redis.cluster.nodes", host);
    
    			source.put("spring.redis.cluster.timeout", timeout);
    
    			source.put("spring.redis.cluster.max-redirects", redirects);
                  //在源码的注释中可以看到是这样配置，以为这样写就不用在Connection中不用在认证，后来确定太天真了
                
                source.put("spring.redis.cluster.password", password);
    
    			return new RedisClusterConfiguration(new                 
                    MapPropertySource("RedisClusterConfiguration", source));
    		}  else {
    			return null;
    		}
    	}
    
    	@Bean
    	public JedisConnectionFactory jedisConnectionFactory() {
    		if (host.split(",").length == 1) {
    			JedisConnectionFactory factory = new JedisConnectionFactory();
    			factory.setHostName(host.split(":")[0]);
    			factory.setPort(Integer.valueOf(host.split(":")[1]));
    			factory.setPassword(password);
    			factory.setTimeout(timeout);
    			return factory;
    		} else {
    			JedisConnectionFactory jcf = new JedisConnectionFactory(getClusterConfiguration());
    			jcf.setPassword(password); //集群的密码认证
    			return jcf;
    		}
    
    	}
    //这样改造之后，redisTemplate模板就不用改了，之前写的redisUtil类也不用变了