(rocketmq) branch develop updated: [ISSUE #9007] Fix client connection local ip is null in RemotingClient (#9008)

[lizhimin]

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

lizhimin 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 78501c7461 [ISSUE #9007] Fix client connection local ip is null in 
RemotingClient (#9008)
78501c7461 is described below

commit 78501c746123ce21622e18a3b6490220ace535d5
Author: weihubeats <we...@apache.org>
AuthorDate: Mon Dec 2 15:13:05 2024 +0800

    [ISSUE #9007] Fix client connection local ip is null in RemotingClient 
(#9008)
---
 .../java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
index b3042c9f8d..6ac54aed6d 100644
--- 
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
+++ 
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
@@ -74,6 +74,7 @@ import org.apache.rocketmq.common.Pair;
 import org.apache.rocketmq.common.ThreadFactoryImpl;
 import org.apache.rocketmq.common.constant.LoggerName;
 import org.apache.rocketmq.common.utils.FutureUtils;
+import org.apache.rocketmq.common.utils.NetworkUtil;
 import org.apache.rocketmq.common.utils.ThreadUtils;
 import org.apache.rocketmq.logging.org.slf4j.Logger;
 import org.apache.rocketmq.logging.org.slf4j.LoggerFactory;
@@ -1130,7 +1131,7 @@ public class NettyRemotingClient extends 
NettyRemotingAbstract implements Remoti
         @Override
         public void connect(ChannelHandlerContext ctx, SocketAddress 
remoteAddress, SocketAddress localAddress,
             ChannelPromise promise) throws Exception {
-            final String local = localAddress == null ? "UNKNOWN" : 
RemotingHelper.parseSocketAddressAddr(localAddress);
+            final String local = localAddress == null ? 
NetworkUtil.getLocalAddress() : 
RemotingHelper.parseSocketAddressAddr(localAddress);
             final String remote = remoteAddress == null ? "UNKNOWN" : 
RemotingHelper.parseSocketAddressAddr(remoteAddress);
             LOGGER.info("NETTY CLIENT PIPELINE: CONNECT  {} => {}", local, 
remote);