diff --git a/remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java b/remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java index f244bf4c853..e7aad18cb9d 100644 --- a/remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java +++ b/remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java @@ -173,10 +173,8 @@ public static String parseChannelRemoteAddr(final Channel channel) { public static String parseSocketAddressAddr(SocketAddress socketAddress) { if (socketAddress != null) { final String addr = socketAddress.toString(); - - if (addr.length() > 0) { - return addr.substring(1); - } + int index = addr.lastIndexOf("/"); + return (index != -1) ? addr.substring(index + 1) : addr; } return ""; }