[rocketmq] branch develop updated: [ISSUE #1750] Fix display of SocketAddress is 'ocalhost/127.0.0.1:9876'

[yu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

yuzhou pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 75557b8  [ISSUE #1750] Fix display of SocketAddress is 'ocalhost/127.0.0.1:9876'
75557b8 is described below

commit 75557b8700bef395002a6b5b7c2bb083c120b632
Author: rushsky518 <ru...@163.com>
AuthorDate: Sat Dec 25 17:15:37 2021 +0800

    [ISSUE #1750] Fix display of SocketAddress is 'ocalhost/127.0.0.1:9876'
    
    * #1750 lastIndex of /
    
    * optimize code
---
 .../java/org/apache/rocketmq/remoting/common/RemotingHelper.java    | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

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 74dfacc..34efc4e 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
@@ -192,10 +192,8 @@ public class RemotingHelper {
     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 "";
     }