Fix host-port splitter in SentinelConnectionManager for ipv6 addresses

6 years ago · 0e74a8f1b0
parent a71460624e
commit 0e74a8f1b0
1 changed files with 5 additions and 2 deletions
--- a/redisson/src/main/java/org/redisson/connection/SentinelConnectionManager.java
+++ b/redisson/src/main/java/org/redisson/connection/SentinelConnectionManager.java
@ -371,8 +371,11 @@ public class SentinelConnectionManager extends MasterSlaveConnectionManager {
                            Set<String> removedSlaves = new HashSet<String>(slaves);
                            removedSlaves.removeAll(currentSlaves);
                            for (String slave : removedSlaves) {
-                                String[] parts = slave.replace("redis://", "").split(":");
-                                slaveDown(parts[0], parts[1]);
+                                String hostPort = slave.replace("redis://", "");
+                                int lastColonIdx = hostPort.lastIndexOf(":");
+                                String host = hostPort.substring(0, lastColonIdx);
+                                String port = hostPort.substring(lastColonIdx + 1);
+                                slaveDown(host, port);
                            }
                        };
                    };