zoukankan      html  css  js  c++  java
  • Invalid property 'sentinels' of bean class redis spring 错误修改

    /*
     * Copyright 2014-2015 the original author or authors.
     *
     * Licensed under the Apache License, Version 2.0 (the "License");
     * you may not use this file except in compliance with the License.
     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package org.springframework.data.redis.connection;
    
    import static org.springframework.util.Assert.*;
    import static org.springframework.util.StringUtils.*;
    
    import java.util.Collections;
    import java.util.HashMap;
    import java.util.LinkedHashSet;
    import java.util.Map;
    import java.util.Set;
    
    import org.springframework.core.env.MapPropertySource;
    import org.springframework.core.env.PropertySource;
    import org.springframework.util.StringUtils;
    
    /**
     * Configuration class used for setting up {@link RedisConnection} via {@link RedisConnectionFactory} using connecting
     * to <a href="http://redis.io/topics/sentinel">Redis Sentinel(s)</a>. Useful when setting up a high availability Redis
     * environment.
     * 
     * @author Christoph Strobl
     * @author Thomas Darimont
     * @since 1.4
     */
    public class RedisSentinelConfiguration {
    
        private static final String REDIS_SENTINEL_MASTER_CONFIG_PROPERTY = "spring.redis.sentinel.master";
        private static final String REDIS_SENTINEL_NODES_CONFIG_PROPERTY = "spring.redis.sentinel.nodes";
    
        private NamedNode master;
        private Set<RedisNode> sentinels;
    
        /**
         * Creates new {@link RedisSentinelConfiguration}.
         */
        public RedisSentinelConfiguration() {
            this(new MapPropertySource("RedisSentinelConfiguration", Collections.<String, Object> emptyMap()));
        }
    
        /**
         * Creates {@link RedisSentinelConfiguration} for given hostPort combinations.
         * 
         * <pre>
         * sentinelHostAndPorts[0] = 127.0.0.1:23679
         * sentinelHostAndPorts[1] = 127.0.0.1:23680
         * ...
         * 
         * <pre>
         * 
         * @param sentinelHostAndPorts must not be {@literal null}.
         * @since 1.5
         */
        public RedisSentinelConfiguration(String master, Set<String> sentinelHostAndPorts) {
            this(new MapPropertySource("RedisSentinelConfiguration", asMap(master, sentinelHostAndPorts)));
        }
    
        /**
         * Creates {@link RedisSentinelConfiguration} looking up values in given {@link PropertySource}.
         * 
         * <pre>
         * <code>
         * spring.redis.sentinel.master=myMaster
         * spring.redis.sentinel.nodes=127.0.0.1:23679,127.0.0.1:23680,127.0.0.1:23681
         * </code>
         * </pre>
         * 
         * @param propertySource must not be {@literal null}.
         * @since 1.5
         */
        public RedisSentinelConfiguration(PropertySource<?> propertySource) {
    
            notNull(propertySource, "PropertySource must not be null!");
    
            this.sentinels = new LinkedHashSet<RedisNode>();
    
            if (propertySource.containsProperty(REDIS_SENTINEL_MASTER_CONFIG_PROPERTY)) {
                this.setMaster(propertySource.getProperty(REDIS_SENTINEL_MASTER_CONFIG_PROPERTY).toString());
            }
    
            if (propertySource.containsProperty(REDIS_SENTINEL_NODES_CONFIG_PROPERTY)) {
                appendSentinels(commaDelimitedListToSet(propertySource.getProperty(REDIS_SENTINEL_NODES_CONFIG_PROPERTY)
                        .toString()));
            }
        }
    
        /**
         * Set {@literal Sentinels} to connect to.
         * 
         * @param sentinels must not be {@literal null}.
         */
        public void setSentinels(Iterable<RedisNode> sentinels) {
    
            notNull(sentinels, "Cannot set sentinels to 'null'.");
    
            this.sentinels.clear();
    
            for (RedisNode sentinel : sentinels) {
                addSentinel(sentinel);
            }
        }
        public void setSentinels(Set<RedisNode> sentinels) {
    
            notNull(sentinels, "Cannot set sentinels to 'null'.");
    
            this.sentinels.clear();
    
            for (RedisNode sentinel : sentinels) {
                addSentinel(sentinel);
            }
        }
    
        /**
         * Returns an {@link Collections#unmodifiableSet(Set)} of {@literal Sentinels}.
         * 
         * @return {@link Set} of sentinels. Never {@literal null}.
         */
        public Set<RedisNode> getSentinels() {
            return Collections.unmodifiableSet(sentinels);
        }
    
        /**
         * Add sentinel.
         * 
         * @param sentinel must not be {@literal null}.
         */
        public void addSentinel(RedisNode sentinel) {
    
            notNull(sentinel, "Sentinel must not be 'null'.");
            this.sentinels.add(sentinel);
        }
    
        /**
         * Set the master node via its name.
         * 
         * @param name must not be {@literal null}.
         */
        public void setMaster(final String name) {
    
            notNull(name, "Name of sentinel master must not be null.");
            setMaster(new NamedNode() {
    
                @Override
                public String getName() {
                    return name;
                }
            });
        }
    
        /**
         * Set the master.
         * 
         * @param master must not be {@literal null}.
         */
        public void setMaster(NamedNode master) {
    
            notNull("Sentinel master node must not be 'null'.");
            this.master = master;
        }
    
        /**
         * Get the {@literal Sentinel} master node.
         * 
         * @return
         */
        public NamedNode getMaster() {
            return master;
        }
    
        /**
         * @see #setMaster(String)
         * @param master
         * @return
         */
        public RedisSentinelConfiguration master(String master) {
            this.setMaster(master);
            return this;
        }
    
        /**
         * @see #setMaster(NamedNode)
         * @param master
         * @return
         */
        public RedisSentinelConfiguration master(NamedNode master) {
            this.setMaster(master);
            return this;
        }
    
        /**
         * @see #addSentinel(RedisNode)
         * @param sentinel
         * @return
         */
        public RedisSentinelConfiguration sentinel(RedisNode sentinel) {
            this.addSentinel(sentinel);
            return this;
        }
    
        /**
         * @see #sentinel(RedisNode)
         * @param host
         * @param port
         * @return
         */
        public RedisSentinelConfiguration sentinel(String host, Integer port) {
            return sentinel(new RedisNode(host, port));
        }
    
        private void appendSentinels(Set<String> hostAndPorts) {
    
            for (String hostAndPort : hostAndPorts) {
                addSentinel(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());
        }
    
        /**
         * @param master must not be {@literal null} or empty.
         * @param sentinelHostAndPorts must not be {@literal null}.
         * @return
         */
        private static Map<String, Object> asMap(String master, Set<String> sentinelHostAndPorts) {
    
            hasText(master, "Master address must not be null or empty!");
            notNull(sentinelHostAndPorts, "SentinelHostAndPorts must not be null!");
    
            Map<String, Object> map = new HashMap<String, Object>();
            map.put(REDIS_SENTINEL_MASTER_CONFIG_PROPERTY, master);
            map.put(REDIS_SENTINEL_NODES_CONFIG_PROPERTY, StringUtils.collectionToCommaDelimitedString(sentinelHostAndPorts));
    
            return map;
        }
    }

    Invalid property 'sentinels' of bean class redis  ,spring 集成redis时报的错,集成配置如下,

    <!-- redis配置 -->
        <bean id="redisSentinelConfiguration"
            class="org.springframework.data.redis.connection.RedisSentinelConfiguration">
            <property name="master">
                <bean class="org.springframework.data.redis.connection.RedisNode">
                    <property name="name" value="${redis.sentinels.name}">
                    </property>
                </bean>
            </property>
            <property name="sentinels">
                <set>
                    <bean class="org.springframework.data.redis.connection.RedisNode">
                        <constructor-arg name="host" value="${redis.sentinels.ip1}" />
                        <constructor-arg name="port" value="${redis.sentinels.port1}" />
                    </bean>
                    <bean class="org.springframework.data.redis.connection.RedisNode">
                        <constructor-arg name="host" value="${redis.sentinels.ip2}" />
                        <constructor-arg name="port" value="${redis.sentinels.port2}" />
                    </bean>
                </set>
            </property>
        </bean>
        <!-- <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory" >
            <property name="hostName" value="${redis.hostName}"></property>
            <property name="port" value="${redis.port}"></property>
            <property name="password" value="${redis.password}"></property>
            <property name="timeout" value="${redis.timeout}" />  
            <property name="usePool" value="true" />  
            <property name="poolConfig" ref="jedisPoolConfig" /> 
        </bean> -->
        <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory" >
            <constructor-arg name="sentinelConfig" ref="redisSentinelConfiguration"></constructor-arg>
            <property name="password" value="${redis.sentinels.password}"></property>
            <constructor-arg name="poolConfig" ref="jedisPoolConfig"></constructor-arg>
        </bean>
        
        <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">  
            <property name="maxTotal" value="${redis.maxTotal}"></property>  
            <property name="maxIdle" value="${redis.maxIdle}"></property>  
            <property name="maxWaitMillis" value="${redis.maxWaitMillis}"></property>
            <property name="testOnBorrow" value="${redis.testOnBorrow}"></property>  
        </bean>
        
        <bean id="stringRedisSerializer" class="org.springframework.data.redis.serializer.StringRedisSerializer" />
        
        <!-- <bean id="jacksonJsonRedisSerializer" class="org.springframework.data.redis.serializer.JacksonJsonRedisSerializer" >
            <constructor-arg type="java.lang.Class" value="java.lang.Object"/>
        </bean> -->
        
        <bean id="jacksonJsonRedisSerializer" class="org.springframework.data.redis.serializer.JacksonJsonRedisSerializer" >
            <constructor-arg type="java.lang.Class" value="java.lang.Object"/>
        </bean>
        
        
        <bean id="jdkSerializationRedisSerializer" class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>
              
        <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
            <property name="connectionFactory" ref="jedisConnectionFactory"></property>
            <property name="keySerializer" ref="stringRedisSerializer"/>  
            <property name="valueSerializer" ref="stringRedisSerializer" />  
            <property name="hashKeySerializer" ref="stringRedisSerializer" />  
            <property name="hashValueSerializer" ref="stringRedisSerializer"/>  
        </bean>
    <bean id="propertyConfigurer"
      class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
      <property name="locations">
       <list>
        <value>classpath:jdbc.properties</value>
        <value>classpath:redis.properties</value>
       </list>
      </property>
     </bean>

    redis 配置文件

    #redis连接池配置
    redis.maxTotal=300
    redis.maxIdle=20
    #读取超时
    redis.maxWaitMillis=5000
    redis.testOnBorrow=true
    
    #redis连接配置
    redis.hostName=192.168.100.75
    redis.port=6379
    redis.password=desc@1997
    #连接超时
    redis.timeout=5000
    
    #哨兵的配置
    redis.sentinels.ip1=192.168.100.67
    redis.sentinels.port1=26378
    
    redis.sentinels.ip2=192.168.100.67
    redis.sentinels.port2=26379
    
    redis.sentinels.name=mymaster
    redis.sentinels.password=lolaage_cache
    <dependency>
                <groupId>org.springframework.data</groupId>
                <artifactId>spring-data-redis</artifactId>
                <version>1.5.0.RELEASE</version>
            </dependency>
            <dependency>
                <groupId>redis.clients</groupId>
                <artifactId>jedis</artifactId>
                <version>2.6.2</version>
            </dependency>

    出现错误的原因是 spring用的3.1的版本,需要spring4的版本才不会报错,懒得升级版本,研究了一下,发现加个方法可以解决,

    加个如下的类,RedisSentinelConfiguration ,如下的方法即可解决

    public void setSentinels(Set<RedisNode> sentinels) {

            notNull(sentinels, "Cannot set sentinels to 'null'.");

            this.sentinels.clear();

            for (RedisNode sentinel : sentinels) {
                addSentinel(sentinel);
            }
        }

  • 相关阅读:
    二叉树解题思想
    SpringBoot + Mybatis 和ssm 使用数据库的区别
    Spring Cache 抽象(缓存抽象) Redis 缓存
    VirtualBox 虚拟机 从入门到入坑
    小知识点的记录
    SpringBoot 的不同
    请你激起学习的激情
    java 适配器模式
    UML类图的情话诉说
    Java 工厂模式
  • 原文地址:https://www.cnblogs.com/xiongjinpeng/p/7307694.html
Copyright © 2011-2022 走看看