我从单个节点Redis切换到基于Sentinel的多节点Redis实例,并且由于新实例的VCAP结构不同而且Spring默认不处理,我知道我们需要自己解析VCAP并配置Redis bean .
在Spring文档here之后,这就是我调整Redis bean的方法:
public RedisConnectionFactory jedisConnectionFactory(JsonArray sentinelNodes) {
RedisSentinelConfiguration sentinelConfig = new RedisSentinelConfiguration().master("mymaster");
String hostname;
String port;
for (int i = 0; i < sentinelNodes.size(); i++) {
JsonObject sentinelNode = sentinelNodes.getJsonObject(i);
hostname = sentinelNode.getString("hostname");
port = sentinelNode.getString("port");
sentinelConfig.sentinel(hostname, Integer.parseInt(port));
}
return new JedisConnectionFactory(sentinelConfig);
}
@Bean
public RedisTemplate<String, String> redisTemplate(RedisConnectionFactory cf) {
JsonArray sentinelNodes = environmentHandler.getSentinelNodesForRedis();
if (sentinelNodes != null) {
cf = jedisConnectionFactory(sentinelNodes);
}
RedisTemplate<String, String> redisTemplate = new RedisTemplate<>();
redisTemplate.setConnectionFactory(cf);
redisTemplate.setKeySerializer(new StringRedisSerializer());
redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer<>(Object.class));
return redisTemplate;
}
@SuppressWarnings("rawtypes")
@Bean
public CacheManager cacheManager(RedisTemplate redisTemplate) {
return new RedisCacheManager(redisTemplate);
}
我从VCAP获取sentinel节点的信息并传递它以创建我的JedisConnectionFactory . 我能够像这样配置bean,但在运行时收到一个Exception,声明'org.springframework.data.redis.RedisConnectionFailureException:无法获得Jedis连接;嵌套异常是java.lang.NullPointerException:在尝试调用从局部变量'shardInfo'加载的null对象的方法redis.clients.jedis.JedisShardInfo.getHost()时在org.springframework.data.redis.connection.jedis.JedisConnectionFactory.fetchJedisConnector(JedisConnectionFactory.java:204)......' . 根据我的理解,我使用RedisSentinelConfiguration而不是JedisShardInfo配置了JedisConnectionFactory,我不应该使用shardInfo .
在检查此库的较新版本时,我注意到此特定代码已修改为this . 所以我适应了这个更新的版本,但现在应用程序在启动期间崩溃,但有以下异常 .
java.lang.NoSuchMethodError:org.springframework.util.Assert.isTrue(ZLjava / util / function / Supplier;)V |在org.springframework.data.redis.connection.RedisStandaloneConfiguration . (RedisStandaloneConfiguration.java:61)|在org.springframework.data.redis.connection.jedis.JedisConnectionFactory . (JedisConnectionFactory.java:99)|在org.springframework.data.redis.connection.jedis.JedisConnectionFactory . (JedisConnectionFactory.java:111)...
在异常之后我拿了here,但我不明白为什么会引起这种异常 .
有人能够指出我出错的地方或者指出如何通过Spring Boot bean配置这些多节点Redis哨兵的例子吗?
1 回答
在返回RedisConnectionFactory之前调用afterPropertiesSet()方法似乎已经完成了这个技巧 .
(另外,设置了Factory的密码 . )