redisson 基于spring boot 2.0的集群配置

redisson客户端 pom配置

        <dependency>
            <groupId>org.redisson</groupId>
            <artifactId>redisson</artifactId>
            <version>3.16.1</version>
        </dependency>

代码示例

@Configuration
@EnableConfigurationProperties(RedisProperties.class)
public class RedissonConfig {

    /**
     * redisson 配置
     * @param properties
     * @return
     */
    @Bean
    public RedissonClient getRedisson(RedisProperties properties) {
        Config config = new Config();
        if (properties.getCluster() != null && properties.getCluster().getNodes() != null ) {
            String[] nodes = properties.getCluster().getNodes().toArray(new String[0]);
            String[] result = new String[nodes.length];
            for (int i = 0; i < nodes.length; i++) {
                String nodePart = "redis://"+nodes[i];
                result[i] = nodePart;
            }
            //集群配置
            config.useClusterServers()
                    .setScanInterval(10000)
                    .addNodeAddress(result)
                    .setPassword(properties.getPassword());
        } else {
            //单机配置
          config.useSingleServer().setAddress(properties.getHost() + ":" + properties.getPort()).setPassword(properties.getPassword());

 } return Redisson.create(config); } }