快捷導(dǎo)航

SpringBoot連接Redis集群教程

更新時間：2025年06月20日 14:32:08 作者：°Fuhb

這篇文章主要介紹了SpringBoot連接Redis集群教程,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教

1. 依賴

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

2. 修改配置文件

server.port=100

#redis集群節(jié)點(diǎn)信息
spring.redis.cluster.nodes=192.168.25.132:6379,192.168.25.132:6380,192.168.25.133:6379,192.168.25.133:6380,192.168.25.134:6379,192.168.25.134:6380
#redis連接密碼（默認(rèn)空）
spring.redis.password=
#redis連接池最大連接數(shù)（使用負(fù)值表示沒有限制）
spring.redis.jedis.pool.max-active=20
#redis連接池最大阻塞等待時間（使用負(fù)值表示沒有限制）
spring.redis.jedis.pool.max-wait=-1
#redis連接池最大空閑連接
spring.redis.jedis.pool.max-idle=200
#redis連接池最小空閑連接
spring.redis.jedis.pool.min-idle=20
#redis連接超時時間（毫秒）
spring.redis.timeout=10000

3. 創(chuàng)建RedisClusterConfig

@Configuration
public class RedisClusterConfig {

    @Value("${spring.redis.cluster.nodes}")
    private String clusterNodes;

    @Value("${spring.redis.database}")
    private int database;

    @Value("${spring.redis.timeout}")
    private int timeout;

    @Value("${spring.redis.jedis.pool.max-idle}")
    private int maxIdle;

    @Value("${spring.redis.jedis.pool.min-idle}")
    private int minIdle;

    @Value("${spring.redis.jedis.pool.max-active}")
    private int maxActive;

    @Value("${spring.redis.jedis.pool.max-wait}")
    private long maxWait;

    @Bean
    public JedisCluster getJedisCluster() {
        return new JedisCluster(getNodes(), timeout, poolConfig());
    }

    private JedisPoolConfig poolConfig() {
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxIdle(maxIdle);
        config.setMinIdle(minIdle);
        config.setMaxTotal(maxActive);
        config.setMaxWaitMillis(maxWait);
        return config;
    }

    private Set<HostAndPort> getNodes() {
        String[] cNodes = clusterNodes.split(",");
        Set<HostAndPort> nodes = new HashSet<HostAndPort>();
        // 分割出集群節(jié)點(diǎn)
        String[] hp;
        for (String node : cNodes) {
            hp = node.split(":");
            nodes.add(new HostAndPort(hp[0], Integer.parseInt(hp[1])));
        }
        return nodes;
    }
}

4. 測試

@RestController
@RequestMapping("/redis/cluster")
public class RedisClusterController {
    @Autowired
    private JedisCluster jedisCluster;

    @GetMapping("/set")
    public void set(@RequestParam("key") String key, @RequestParam("value") String value){
        jedisCluster.set(key, value);
    }
}

這邊就不演示了，分別訪問以下2個地址，能得到結(jié)果說明正常：