From efdb99f8cecc4afb592afad79c761081d5d5cf22 Mon Sep 17 00:00:00 2001
From: lee <4766465@qq.com>
Date: Wed, 18 Dec 2024 13:27:00 +0800
Subject: [PATCH] init
---
xxl-job/xxl-job-core/src/main/java/com/xxl/job/core/util/IpUtil.java | 203 ++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 203 insertions(+), 0 deletions(-)
diff --git a/xxl-job/xxl-job-core/src/main/java/com/xxl/job/core/util/IpUtil.java b/xxl-job/xxl-job-core/src/main/java/com/xxl/job/core/util/IpUtil.java
new file mode 100644
index 0000000..c97c4fe
--- /dev/null
+++ b/xxl-job/xxl-job-core/src/main/java/com/xxl/job/core/util/IpUtil.java
@@ -0,0 +1,203 @@
+package com.xxl.job.core.util;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.IOException;
+import java.net.Inet6Address;
+import java.net.InetAddress;
+import java.net.NetworkInterface;
+import java.net.UnknownHostException;
+import java.util.Enumeration;
+import java.util.regex.Pattern;
+
+/**
+ * ip tool
+ *
+ * @author xuxueli 2016-5-22 11:38:05
+ */
+public class IpUtil {
+ private static final Logger logger = LoggerFactory.getLogger(IpUtil.class);
+
+ private static final String ANYHOST_VALUE = "0.0.0.0";
+ private static final String LOCALHOST_VALUE = "127.0.0.1";
+ private static final Pattern IP_PATTERN = Pattern.compile("\\d{1,3}(\\.\\d{1,3}){3,5}$");
+
+
+
+ private static volatile InetAddress LOCAL_ADDRESS = null;
+
+ // ---------------------- valid ----------------------
+
+ private static InetAddress toValidAddress(InetAddress address) {
+ if (address instanceof Inet6Address) {
+ Inet6Address v6Address = (Inet6Address) address;
+ if (isPreferIPV6Address()) {
+ return normalizeV6Address(v6Address);
+ }
+ }
+ if (isValidV4Address(address)) {
+ return address;
+ }
+ return null;
+ }
+
+ private static boolean isPreferIPV6Address() {
+ return Boolean.getBoolean("java.net.preferIPv6Addresses");
+ }
+
+ /**
+ * valid Inet4Address
+ *
+ * @param address
+ * @return
+ */
+ private static boolean isValidV4Address(InetAddress address) {
+ if (address == null || address.isLoopbackAddress()) {
+ return false;
+ }
+ String name = address.getHostAddress();
+ boolean result = (name != null
+ && IP_PATTERN.matcher(name).matches()
+ && !ANYHOST_VALUE.equals(name)
+ && !LOCALHOST_VALUE.equals(name));
+ return result;
+ }
+
+
+ /**
+ * normalize the ipv6 Address, convert scope name to scope id.
+ * e.g.
+ * convert
+ * fe80:0:0:0:894:aeec:f37d:23e1%en0
+ * to
+ * fe80:0:0:0:894:aeec:f37d:23e1%5
+ * <p>
+ * The %5 after ipv6 address is called scope id.
+ * see java doc of {@link Inet6Address} for more details.
+ *
+ * @param address the input address
+ * @return the normalized address, with scope id converted to int
+ */
+ private static InetAddress normalizeV6Address(Inet6Address address) {
+ String addr = address.getHostAddress();
+ int i = addr.lastIndexOf('%');
+ if (i > 0) {
+ try {
+ return InetAddress.getByName(addr.substring(0, i) + '%' + address.getScopeId());
+ } catch (UnknownHostException e) {
+ // ignore
+ logger.debug("Unknown IPV6 address: ", e);
+ }
+ }
+ return address;
+ }
+
+ // ---------------------- find ip ----------------------
+
+
+ private static InetAddress getLocalAddress0() {
+ InetAddress localAddress = null;
+ try {
+ localAddress = InetAddress.getLocalHost();
+ InetAddress addressItem = toValidAddress(localAddress);
+ if (addressItem != null) {
+ return addressItem;
+ }
+ } catch (Throwable e) {
+ logger.error(e.getMessage(), e);
+ }
+
+ try {
+ Enumeration<NetworkInterface> interfaces = NetworkInterface.getNetworkInterfaces();
+ if (null == interfaces) {
+ return localAddress;
+ }
+ while (interfaces.hasMoreElements()) {
+ try {
+ NetworkInterface network = interfaces.nextElement();
+ if (network.isLoopback() || network.isVirtual() || !network.isUp()) {
+ continue;
+ }
+ Enumeration<InetAddress> addresses = network.getInetAddresses();
+ while (addresses.hasMoreElements()) {
+ try {
+ InetAddress addressItem = toValidAddress(addresses.nextElement());
+ if (addressItem != null) {
+ try {
+ if(addressItem.isReachable(100)){
+ return addressItem;
+ }
+ } catch (IOException e) {
+ // ignore
+ }
+ }
+ } catch (Throwable e) {
+ logger.error(e.getMessage(), e);
+ }
+ }
+ } catch (Throwable e) {
+ logger.error(e.getMessage(), e);
+ }
+ }
+ } catch (Throwable e) {
+ logger.error(e.getMessage(), e);
+ }
+ return localAddress;
+ }
+
+
+ // ---------------------- tool ----------------------
+
+ /**
+ * Find first valid IP from local network card
+ *
+ * @return first valid local IP
+ */
+ public static InetAddress getLocalAddress() {
+ if (LOCAL_ADDRESS != null) {
+ return LOCAL_ADDRESS;
+ }
+ InetAddress localAddress = getLocalAddress0();
+ LOCAL_ADDRESS = localAddress;
+ return localAddress;
+ }
+
+ /**
+ * get ip address
+ *
+ * @return String
+ */
+ public static String getIp(){
+ return getLocalAddress().getHostAddress();
+ }
+
+ /**
+ * get ip:port
+ *
+ * @param port
+ * @return String
+ */
+ public static String getIpPort(int port){
+ String ip = getIp();
+ return getIpPort(ip, port);
+ }
+
+ public static String getIpPort(String ip, int port){
+ if (ip==null) {
+ return null;
+ }
+ return ip.concat(":").concat(String.valueOf(port));
+ }
+
+ public static Object[] parseIpPort(String address){
+ String[] array = address.split(":");
+
+ String host = array[0];
+ int port = Integer.parseInt(array[1]);
+
+ return new Object[]{host, port};
+ }
+
+
+}
--
Gitblit v1.9.3