opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-31 02:20:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #5512] Skip the unnecessary network interfaces. (#5513)

Browse Source
This commit is contained in:
echooymxq
2022-11-13 18:02:32 +08:00
committed by GitHub
parent 48ed898071
commit 407d2738f2
2 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/src/main/java/org/apache/rocketmq/common/utils/NetworkUtil.java
+3 -3
View File
@@ -95,12 +95,12 @@ public class NetworkUtil {
ArrayList<String> ipv4Result = new ArrayList<>();
ArrayList<String> ipv6Result = new ArrayList<>();
while (enumeration.hasMoreElements()) {
final NetworkInterface networkInterface = enumeration.nextElement();
if (isBridge(networkInterface)) {
final NetworkInterface nif = enumeration.nextElement();
if (isBridge(nif) || nif.isVirtual() || nif.isPointToPoint() || !nif.isUp()) {
continue;
}
final Enumeration<InetAddress> en = networkInterface.getInetAddresses();
final Enumeration<InetAddress> en = nif.getInetAddresses();
while (en.hasMoreElements()) {
final InetAddress address = en.nextElement();
if (!address.isLoopbackAddress()) {
common/src/test/java/org/apache/rocketmq/common/NetworkUtilTest.java
+3 -1
View File
@@ -16,6 +16,7 @@
*/
package org.apache.rocketmq.common;
import java.net.InetAddress;
import org.apache.rocketmq.common.utils.NetworkUtil;
import org.junit.Test;
@@ -23,10 +24,11 @@ import static org.assertj.core.api.Assertions.assertThat;
public class NetworkUtilTest {
@Test
public void testGetLocalAddress() throws Exception {
public void testGetLocalAddress() {
String localAddress = NetworkUtil.getLocalAddress();
assertThat(localAddress).isNotNull();
assertThat(localAddress.length()).isGreaterThan(0);
assertThat(localAddress).isNotEqualTo(InetAddress.getLoopbackAddress().getHostAddress());
}
@Test