修改failover，支持hostname

jd-opensource · Jun 8, 2020 · 3a4007b · 3a4007b
1 parent e697ec7
commit 3a4007b
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...c/main/java/io/journalkeeper/rpc/remoting/transport/support/FailoverChannelTransport.java b/...c/main/java/io/journalkeeper/rpc/remoting/transport/support/FailoverChannelTransport.java
@@ -30,6 +30,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.net.InetSocketAddress;
 import java.net.SocketAddress;
 import java.util.concurrent.Future;
 
@@ -218,6 +219,9 @@ protected boolean isNeedReconnect() {
 
     protected boolean reconnect() {
         try {
+            if (address instanceof InetSocketAddress) {
+                address = new InetSocketAddress(((InetSocketAddress) address).getHostString(), ((InetSocketAddress) address).getPort());
+            }
             ChannelTransport newTransport = (ChannelTransport) transportClient.createTransport(address, connectionTimeout);
             ChannelTransport delegate = this.delegate;
             this.delegate = newTransport;