脚本宝典收集整理的这篇文章主要介绍了Jedis支持哨兵模式下认证，脚本宝典觉得挺不错的，现在分享给大家，也给大家做个参考。
redis高可用哨兵模式，为了安全，也会添加认证
所以，我们在Java中连接Redis时，就需要配置两种密码；
1. 连接哨兵的认证密码： sentinelPassword
2. 哨兵返回的master节点密码：redisPassword
针对以上问题，我们选择连接Redis的库为Jedis： redis/jedis: A blazingly small and sane redis java client (gIThub.COM)
代码如下：
PRivate static void createJedisPool() { JedisPoolconfig config = new JedisPoolConfig(); config.setMaxtotal(MAX_TOTAL); config.setMaxidle(MAX_IDLE); config.setMaxWaitMillis(MAX_WAIT_MILLIS); config.settestOnBorrow(TEST_ON_BORROW); config.setTestWhileidle(TEST_WHILE_IDLE); config.setTestOnReturn(TEST_ON_RETURN); String masterName = "mymaster"; Set<String> sentinels = new HashSet<String>(); sentinels.add(new HostAndPort("10.0.0.13", 26379).toString()); sentinels.add(new HostAndPort("10.0.0.14", 26379).toString()); sentinels.add(new HostAndPort("10.0.0.15", 26379).toString()); String password = "redisPassword"; // 连接redis时master节点认证密码 String sentinelPassword = "sentinelPassword"; // 连接sentinel时的认证密码 // sentinel no auth // pool = new JedisSentinelPool(masterName, sentinels, config, TIMEOUT, password, 0); // sentinel need auth pool = new JedisSentinelPool(masterName, sentinels, password, sentinelPassword); }
但是怎么调试都不行，看了代码实现
public JedisSentinelPool(String masterName, Set<String> sentinels, GenericObjectPoolConfig<Jedis> poolConfig, int connectionTimeout, int soTimeout, int infiniteSoTimeout, String user, String password, int database, String clientName, int sentinelConnectionTimeout, int sentinelSoTimeout, String sentinelUser, String sentinelPassword, String sentinelClientName) {
this(masterName, sentinels, poolConfig, new JedisFactory(connectionTimeout, soTimeout, infiniteSoTimeout, user, password, database, clientName));
this.connectionTimeout = connectionTimeout;
this.soTimeout = soTimeout;
this.infiniteSoTimeout = infiniteSoTimeout;
this.user = user;
this.password = password;
this.database = database;
this.clientName = clientName;
this.sentinelConnectionTimeout = sentinelConnectionTimeout;
this.sentinelSoTimeout = sentinelSoTimeout;
this.sentinelUser = sentinelUser;
this.sentinelPassword = sentinelPassword;
this.sentinelClientName = sentinelClientName;
}
public JedisSentinelPool(String masterName, Set<String> sentinels, GenericObjectPoolConfig<Jedis> poolConfig, JedisFactory factory) {
this(masterName, parseHostAndPorts(sentinels), poolConfig, (JedisFactory)factory, DefaultJedisClientConfig.builder().build());
}
public JedisSentinelPool(String masterName, Set<HostAndPort> sentinels, GenericObjectPoolConfig<Jedis> poolConfig, JedisClientConfig masteClientConfig, JedisClientConfig sentinelClientConfig) {
this(masterName, sentinels, poolConfig, new JedisFactory(masteClientConfig), sentinelClientConfig);
}
public JedisSentinelPool(String masterName, Set<HostAndPort> sentinels, GenericObjectPoolConfig<Jedis> poolConfig, JedisFactory factory, JedisClientConfig sentinelClientConfig) {
suPEr(poolConfig, factory);
this.masterListeners = new HashSet();
this.initPoolLock = new Object();
this.poolConfig = poolConfig;
this.factory = factory;
this.sentinelClientConfig = sentinelClientConfig;
HostAndPort master = this.initSentinels(sentinels, masterName);
this.initMaster(master);
}
发现在 this.initSentinels(sentinels, masterName); 时，确实没有将哨兵的密码传入；所以我们就到官方仓库去查看；发现官方的里面是有传入哨兵密码信息的；
所以，我们就更新了jedis的依赖版本；【jedis 3.6.0 是没有解决的，只有3.6.*是否解决没有测试，3.7.0是解决了】
<!-- jedis -->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.7.0</version>
</dependency>
解决之后的代码如下：
public JedisSentinelPool(String masterName, Set<String> sentinels, GenericObjectPoolConfig<Jedis> poolConfig, int connectionTimeout, int soTimeout, int infiniteSoTimeout, String user, String password, int database, String clientName, int sentinelConnectionTimeout, int sentinelSoTimeout, String sentinelUser, String sentinelPassword, String sentinelClientName) {
this(masterName, parseHostAndPorts(sentinels), poolConfig, (JedisClientConfig)DefaultJedisClientConfig.builder().connectionTimeoutMillis(connectionTimeout).socketTimeoutMillis(soTimeout).blockingSocketTimeoutMillis(infiniteSoTimeout).user(user).password(password).database(database).clientName(clientName).build(), DefaultJedisClientConfig.builder().connectionTimeoutMillis(sentinelConnectionTimeout).socketTimeoutMillis(sentinelSoTimeout).user(sentinelUser).password(sentinelPassword).clientName(sentinelClientName).build());
this.connectionTimeout = connectionTimeout;
this.soTimeout = soTimeout;
this.infiniteSoTimeout = infiniteSoTimeout;
this.user = user;
this.password = password;
this.database = database;
this.clientName = clientName;
this.sentinelConnectionTimeout = sentinelConnectionTimeout;
this.sentinelSoTimeout = sentinelSoTimeout;
this.sentinelUser = sentinelUser;
this.sentinelPassword = sentinelPassword;
this.sentinelClientName = sentinelClientName;
}
public JedisSentinelPool(String masterName, Set<String> sentinels, GenericObjectPoolConfig<Jedis> poolConfig, JedisFactory factory) {
this(masterName, parseHostAndPorts(sentinels), poolConfig, (JedisFactory)factory, DefaultJedisClientConfig.builder().build());
}
public JedisSentinelPool(String masterName, Set<HostAndPort> sentinels, JedisClientConfig masteClientConfig, JedisClientConfig sentinelClientConfig) {
this(masterName, sentinels, new GenericObjectPoolConfig(), masteClientConfig, sentinelClientConfig);
}
public JedisSentinelPool(String masterName, Set<HostAndPort> sentinels, GenericObjectPoolConfig<Jedis> poolConfig, JedisClientConfig masteClientConfig, JedisClientConfig sentinelClientConfig) {
this(masterName, sentinels, poolConfig, new JedisFactory(masteClientConfig), sentinelClientConfig);
}
public JedisSentinelPool(String masterName, Set<HostAndPort> sentinels, GenericObjectPoolConfig<Jedis> poolConfig, JedisFactory factory, JedisClientConfig sentinelClientConfig) {
super(poolConfig, factory);
this.masterListeners = new HashSet();
this.initPoolLock = new Object();
this.poolConfig = poolConfig;
this.factory = factory;
this.sentinelClientConfig = sentinelClientConfig;
HostAndPort master = this.initSentinels(sentinels, masterName);
this.initMaster(master);
}
发现其实只要更新依赖包到最新就可以解决，囧
以上是脚本宝典为你收集整理的Jedis支持哨兵模式下认证全部内容，希望文章能够帮你解决Jedis支持哨兵模式下认证所遇到的问题。
本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。