This is an automated email from the ASF dual-hosted git repository. huangli pushed a commit to branch 4.9.2_dev_community in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 38e00c41fc752e614c5638a6ee50ac4985dc3a50 Author: huangli <[email protected]> AuthorDate: Tue May 25 14:41:47 2021 +0800 消除反向DNS解析 --- .../src/main/java/org/apache/rocketmq/common/message/MessageExt.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java b/common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java index 577c4f4..133cb93 100644 --- a/common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java +++ b/common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java @@ -153,6 +153,10 @@ public class MessageExt extends Message { public String getBornHostNameString() { if (null != this.bornHost) { + if (bornHost instanceof InetSocketAddress) { + // without reverse dns lookup + return ((InetSocketAddress) bornHost).getHostString(); + } InetAddress inetAddress = ((InetSocketAddress) this.bornHost).getAddress(); return null != inetAddress ? inetAddress.getHostName() : null;
