Fixed - Redis node random selection doesn't work properly

pull/5937/head
Nikita Koksharov 9 months ago
parent 3058fc879c
commit 90201424b6

@ -65,8 +65,6 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
private ClusterServersConfig cfg;
private final long seed = ThreadLocalRandom.current().nextLong();
public ClusterConnectionManager(ClusterServersConfig cfg, Config configCopy) {
super(cfg, configCopy);
this.serviceManager.setNatMapper(cfg.getNatMapper());
@ -890,8 +888,6 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
int index = 0;
if (addresses.size() > 1) {
addresses.sort(Comparator.comparing(RedisURI::getHost));
SplittableRandom r = new SplittableRandom(seed);
index = r.nextInt(addresses.size());
}
RedisURI address = addresses.get(index);

@ -56,8 +56,6 @@ public class DNSMonitor {
private boolean printed;
private final long seed = ThreadLocalRandom.current().nextLong();
public DNSMonitor(ConnectionManager connectionManager, RedisClient masterHost, Collection<RedisURI> slaveHosts, long dnsMonitoringInterval, AddressResolverGroup<InetSocketAddress> resolverGroup) {
this.resolver = resolverGroup.getResolver(connectionManager.getServiceManager().getGroup().next());
@ -129,8 +127,6 @@ public class DNSMonitor {
int index = 0;
if (addresses.size() > 1) {
addresses.sort(Comparator.comparing(RedisURI::getHost));
SplittableRandom r = new SplittableRandom(seed);
index = r.nextInt(addresses.size());
}
RedisURI address = addresses.get(index);

Loading…
Cancel
Save