1. 程式人生 > >spring boot下JedisCluster客戶端的配置,連線Redis叢集

spring boot下JedisCluster客戶端的配置,連線Redis叢集

1,pom依賴新增:

    <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <type>jar</type>
            <scope>compile</scope>
            <version>2.8.0</version>
        </dependency>

2,application.properties中配置:

   #redis cluster
redis.cache.clusterNodes=120.125.122.103:5000,120.125.122.103:5001,120.125.122.103:5002,120.125.122.103:5003,120.125.122.103:5004,120.125.122.103:5005
redis.cache.commandTimeout=5000
#unit:second
redis.cache.expireSeconds=120

3,新增類RedisProperties  JedisClusterConfig,核心程式碼如下:

@Component
@ConfigurationProperties(prefix = "redis.cache")
public class RedisProperties {

    private int    expireSeconds;
    private String clusterNodes;
    private int    commandTimeout;

}

@Configuration
public class JedisClusterConfig {

    @Autowired
    private RedisProperties redisProperties;
    
    /**
    * 注意:
    * 這裡返回的JedisCluster是單例的,並且可以直接注入到其他類中去使用
    * @return
    */
    @Bean
    public JedisCluster getJedisCluster() {
        
        String[] serverArray = redisProperties.getClusterNodes().split(",");//獲取

伺服器陣列(這裡要相信自己的輸入,所以沒有考慮空指標問題)
        Set<HostAndPort> nodes = new HashSet<>();
    
         for (String ipPort : serverArray) {
             String[] ipPortPair = ipPort.split(":");
             nodes.add(new HostAndPort(ipPortPair[0].trim(), Integer.valueOf(ipPortPair[1].trim())));
         }
         
        return new JedisCluster(nodes, redisProperties.getCommandTimeout());
    }
    
}

特別注意:@ConfigurationProperties(prefix = "redis.cache") 中redis.cache要和application.properties中的字首對應。

4,使用:

    @Autowired
    private JedisCluster   jc ;