fix parse ipv6 from address in haproxy

yuz10 · Jun 5, 2024 · 2b580c6 · 2b580c6
1 parent 7558850
commit 2b580c6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/.../java/org/apache/rocketmq/proxy/remoting/protocol/http2proxy/HAProxyMessageForwarder.java b/.../java/org/apache/rocketmq/proxy/remoting/protocol/http2proxy/HAProxyMessageForwarder.java
@@ -118,11 +118,11 @@ protected HAProxyMessage buildHAProxyMessage(Channel inboundChannel) throws Ille
             }
         } else {
             String remoteAddr = RemotingHelper.parseChannelRemoteAddr(inboundChannel);
-            sourceAddress = StringUtils.substringBefore(remoteAddr, CommonConstants.COLON);
+            sourceAddress = StringUtils.substringBeforeLast(remoteAddr, CommonConstants.COLON);
             sourcePort = Integer.parseInt(StringUtils.substringAfterLast(remoteAddr, CommonConstants.COLON));
 
             String localAddr = RemotingHelper.parseChannelLocalAddr(inboundChannel);
-            destinationAddress = StringUtils.substringBefore(localAddr, CommonConstants.COLON);
+            destinationAddress = StringUtils.substringBeforeLast(localAddr, CommonConstants.COLON);
             destinationPort = Integer.parseInt(StringUtils.substringAfterLast(localAddr, CommonConstants.COLON));
         }