redistemplate连接redis集群
时间: 2023-06-28 12:06:02 浏览: 100
要连接Redis集群,你需要使用RedisTemplate的ClusterConnection来创建连接。下面是一个示例代码:
```
@Configuration
public class RedisConfig {
@Bean
public RedisConnectionFactory redisConnectionFactory() {
RedisClusterConfiguration clusterConfiguration = new RedisClusterConfiguration(Arrays.asList("host1:port1", "host2:port2", "host3:port3"));
return new JedisConnectionFactory(clusterConfiguration);
}
@Bean
public RedisTemplate<String, Object> redisTemplate() {
RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(redisConnectionFactory());
redisTemplate.setDefaultSerializer(new StringRedisSerializer());
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
redisTemplate.setHashKeySerializer(new StringRedisSerializer());
redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
redisTemplate.afterPropertiesSet();
return redisTemplate;
}
}
```
在此示例中,我们使用RedisClusterConfiguration来设置Redis集群节点的位置,并使用JedisConnectionFactory来创建连接工厂。然后,我们使用RedisTemplate来配置Redis连接,并设置序列化器,以便在与Redis交互时正确地序列化和反序列化数据。最后,我们返回RedisTemplate对象以供使用。
请注意,此示例假定您已经将Redis集群正确配置并在运行中。
阅读全文