redistemplate 使用redis集群
时间: 2023-09-02 12:12:07 浏览: 48
使用 RedisTemplate 连接 Redis 集群需要以下步骤:
1. 在 Spring Boot 项目中添加 Redis 集群的依赖,例如 jedis 和 lettuce。
2. 创建 Redis 集群的配置类,配置 Redis 集群的节点信息和连接池信息,例如:
```
@Configuration
public class RedisClusterConfig {
@Bean
public RedisClusterConfiguration redisClusterConfiguration() {
RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration();
redisClusterConfiguration.setMaxRedirects(3);
redisClusterConfiguration.setClusterNodes(
Set.of(new RedisNode("127.0.0.1", 7000),
new RedisNode("127.0.0.1", 7001),
new RedisNode("127.0.0.1", 7002),
new RedisNode("127.0.0.1", 7003),
new RedisNode("127.0.0.1", 7004),
new RedisNode("127.0.0.1", 7005)));
return redisClusterConfiguration;
}
@Bean
public LettuceConnectionFactory lettuceConnectionFactory(RedisClusterConfiguration redisClusterConfiguration) {
return new LettuceConnectionFactory(redisClusterConfiguration,
LettuceClientConfiguration.builder().build());
}
@Bean
public RedisTemplate<String, Object> redisTemplate(LettuceConnectionFactory lettuceConnectionFactory) {
RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(lettuceConnectionFactory);
return redisTemplate;
}
}
```
3. 使用 RedisTemplate 连接 Redis 集群,例如:
```
@Autowired
private RedisTemplate<String, Object> redisTemplate;
public void setValue(String key, Object value) {
redisTemplate.opsForValue().set(key, value);
}
public Object getValue(String key) {
return redisTemplate.opsForValue().get(key);
}
```
这样就可以使用 RedisTemplate 连接 Redis 集群了。