From 96df029f43c57c46dcd3d2cfa15e02257ed1cb64 Mon Sep 17 00:00:00 2001 From: duandongmei Date: Sat, 26 Jan 2019 19:41:58 +0600 Subject: [PATCH] =?UTF-8?q?ASN=E5=AE=9A=E6=97=B6=E8=AE=A1=E7=AE=97v4?= =?UTF-8?q?=E5=92=8Cv6=E7=9A=84IP=E4=B8=AA=E6=95=B0=EF=BC=9B=20=E7=95=8C?= =?UTF-8?q?=E9=9D=A2=E5=B1=95=E7=A4=BAASNIPv4=E5=92=8Cv6=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/nis/domain/Nets.java | 31 + .../java/com/nis/util/ConfigDictUtils.java | 35 + src/main/java/com/nis/util/IPUtil.java | 759 ++++++++++++++++++ .../nis/web/dao/basics/AsnGroupInfoDao.java | 2 + .../nis/web/dao/basics/AsnGroupInfoDao.xml | 6 + .../com/nis/web/dao/basics/AsnIpCfgDao.java | 1 + .../com/nis/web/dao/basics/AsnIpCfgDao.xml | 6 + .../com/nis/web/task/StatisticASNIpNumer.java | 134 ++++ .../resources/messages/message_en.properties | 4 +- .../resources/messages/message_ru.properties | 4 +- .../messages/message_zh_CN.properties | 4 +- src/main/resources/spring-mvc.xml | 14 +- src/main/webapp/WEB-INF/tlds/fns.tld | 8 + .../WEB-INF/views/basics/asnGroupList.jsp | 7 + .../WEB-INF/views/basics/asnIpCfgList.jsp | 7 + 15 files changed, 1017 insertions(+), 5 deletions(-) create mode 100644 src/main/java/com/nis/domain/Nets.java create mode 100644 src/main/java/com/nis/util/IPUtil.java create mode 100644 src/main/java/com/nis/web/task/StatisticASNIpNumer.java diff --git a/src/main/java/com/nis/domain/Nets.java b/src/main/java/com/nis/domain/Nets.java new file mode 100644 index 000000000..7c9d2690b --- /dev/null +++ b/src/main/java/com/nis/domain/Nets.java @@ -0,0 +1,31 @@ +package com.nis.domain; + +/** + * Created by dell on 2018-8-30. + */ +public class Nets { + + private String StartIP; + private String EndIP; + private String NetMask; + public String getStartIP() { + return StartIP; + } + public void setStartIP(String startIP) { + StartIP = startIP; + } + public String getEndIP() { + return EndIP; + } + public void setEndIP(String endIP) { + EndIP = endIP; + } + public String getNetMask() { + return NetMask; + } + public void setNetMask(String netMask) { + NetMask = netMask; + } + + +} diff --git a/src/main/java/com/nis/util/ConfigDictUtils.java b/src/main/java/com/nis/util/ConfigDictUtils.java index dffc42ed2..2c2c656cf 100644 --- a/src/main/java/com/nis/util/ConfigDictUtils.java +++ b/src/main/java/com/nis/util/ConfigDictUtils.java @@ -2,6 +2,7 @@ package com.nis.util; import java.util.ArrayList; import java.util.Arrays; +import java.util.Iterator; import java.util.List; import java.util.Map; @@ -11,6 +12,7 @@ import com.google.common.collect.Lists; import com.google.common.collect.Maps; import com.nis.domain.SysDataDictionaryItem; import com.nis.domain.SysDataDictionaryName; +import com.nis.domain.basics.AsnGroupInfo; import com.nis.domain.basics.ServiceDictInfo; import com.nis.domain.basics.SysDictInfo; import com.nis.domain.configuration.BaseStringCfg; @@ -18,6 +20,7 @@ import com.nis.domain.configuration.CfgIndexInfo; import com.nis.domain.configuration.PxyObjTrustedCaCrl; import com.nis.domain.specific.SpecificServiceCfg; import com.nis.web.dao.SysDictDao; +import com.nis.web.dao.basics.AsnGroupInfoDao; import com.nis.web.dao.basics.ServiceDictInfoDao; import com.nis.web.dao.basics.SysDictInfoDao; import com.nis.web.dao.configuration.PxyObjKeyringDao; @@ -41,6 +44,7 @@ public class ConfigDictUtils { private final static SpecificServiceCfgDao specificServiceCfgDao = SpringContextHolder.getBean(SpecificServiceCfgDao.class); private final static WebsiteCfgDao websiteCfgDao = SpringContextHolder.getBean(WebsiteCfgDao.class); private final static PxyObjKeyringDao pxyObjKeyringDao = SpringContextHolder.getBean(PxyObjKeyringDao.class); + private final static AsnGroupInfoDao asnGroupInfoDao = SpringContextHolder.getBean(AsnGroupInfoDao.class); /** * 根据主键查询配置详情 @@ -203,4 +207,35 @@ public class ConfigDictUtils { } return crlFIle; } + /** + * 根据compileId获取配置内容 + * @param compileId + * @return + */ + public static List getASNIPNum(Integer groupId ) { + List ipNum=new ArrayList<>(); + ipNum.add(0, 0); + ipNum.add(1, 0); + try { + if(!StringUtil.isEmpty(groupId)){ + List list=asnGroupInfoDao.getASNIPNum(groupId); + if(!StringUtil.isEmpty(list)){ + int index=0; + for (Iterator iterator = list.iterator(); iterator.hasNext();) { + if(index==0){ + Map map=(Map) iterator.next(); + if(map != null){ + ipNum.add(0, (Integer) map.get("v4_num")); + ipNum.add(1, (Integer) map.get("v6_num")); + } + } + } + } + } + + } catch (Exception e) { + e.printStackTrace(); + } + return ipNum; + } } diff --git a/src/main/java/com/nis/util/IPUtil.java b/src/main/java/com/nis/util/IPUtil.java new file mode 100644 index 000000000..f6dee0eec --- /dev/null +++ b/src/main/java/com/nis/util/IPUtil.java @@ -0,0 +1,759 @@ +package com.nis.util; + + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import com.nis.domain.Nets; + +import javax.servlet.http.HttpServletRequest; +import java.io.StringWriter; +import java.util.ArrayList; +import java.util.List; +import java.util.regex.Matcher; +import java.util.regex.Pattern; + +/** + * + *

对IPV4进行处理工具类.

+ * @author 中电积至有限公司 darnell + * @version 1.0 创建时间：2018-08-30 + * + */ +public class IPUtil { + + + private static Logger logger = LoggerFactory.getLogger(IPUtil.class); + private static byte pos []= new byte []{(byte)128,64,32,16,8,4,2,1}; + private static final Pattern IPV4Pattern = Pattern. + compile("\\b((?!\\d\\d\\d)\\d+|1\\d\\d|2[0-4]\\d|25[0-5])\\.((?!\\d\\d\\d)\\d+|1\\d\\d|2[0-4]\\d|25[0-5])\\.((?!\\d\\d\\d)\\d+|1\\d\\d|2[0-4]\\d|25[0-5])\\.((?!\\d\\d\\d)\\d+|1\\d\\d|2[0-4]\\d|25[0-5])\\b"); + private static final Pattern IPV6_STD_PATTERN = + Pattern.compile( + "^(?:[0-9a-fA-F]{1,4}:){7}[0-9a-fA-F]{1,4}$"); + + private static final Pattern IPV6_HEX_COMPRESSED_PATTERN = + Pattern.compile( + "^((?:[0-9A-Fa-f]{1,4}(?::[0-9A-Fa-f]{1,4})*)?)::((?:[0-9A-Fa-f]{1,4}(?::[0-9A-Fa-f]{1,4})*)?)$"); + + + /** + * + *

将10进制IP转为字符串，网络序。IP((0-255).(0-255).(0-255).(0-255))格式. + * ip10为字符串形式能给处理带来方便. + *

+ * 
+     * IpUtil.getIpString("3232235777") = "192.168.1.1"
+     *
+ * @see #getIpDesimal(String) + * @param ip10 10进制IP + * @return 返回如0.0.0.0格式IP + */ + public static String getIpString(String ip10) { + StringBuffer sb = new StringBuffer(""); + if (ip10.indexOf("-") > -1) { + + Integer intIP = Integer.parseInt(setStrEmpty(ip10)); + + sb.append(String.valueOf(intIP&0x000000FF)); + sb.append("."); + sb.append(String.valueOf((intIP&0x0000FFFF)>>>8)); + sb.append(".");//将高8位置0，然后右移16位 + sb.append(String.valueOf((intIP&0x00FFFFFF)>>>16)); + sb.append("."); + sb.append(String.valueOf(intIP>>>24&0xFF));//直接右移24位 + return sb.toString(); + } else { + + Long longIP = Long.parseLong(setStrEmpty(ip10)); + sb.append(String.valueOf(longIP&0x000000FF)); + sb.append("."); + sb.append(String.valueOf((longIP&0x0000FFFF)>>>8)); + sb.append(".");//将高8位置0，然后右移16位 + sb.append(String.valueOf((longIP&0x00FFFFFF)>>>16)); + sb.append("."); + sb.append(String.valueOf(longIP>>>24&0xFF));//直接右移24位 + return sb.toString(); + } + } + + /** + * + *

将10进制IP转为字符串，主机序。IP((0-255).(0-255).(0-255).(0-255))格式. + * ip10为字符串形式能给处理带来方便. + *

+ * 
+     * IpUtil.getIpHostString("3232235777") = "192.168.1.1"
+     *
+ * @see #getIpDesimal(String) + * @param ip10 10进制IP + * @return 返回如0.0.0.0格式IP + */ + //将10进制整数形式转换成127.0.0.1形式的IP地址，按网络序 + public static String getIpHostString(String ip10) { + StringBuffer sb = new StringBuffer(32); + if (ip10.indexOf("-") > -1) { + + Integer intIP = Integer.parseInt(setStrEmpty(ip10)); + + sb.append(String.valueOf(intIP >>> 24));// 直接右移24位 + sb.append("."); + sb.append(String.valueOf((intIP & 0x00FFFFFF) >>> 16)); // 将高8位置0，然后右移16位 + sb.append("."); + sb.append(String.valueOf((intIP & 0x0000FFFF) >>> 8)); + sb.append("."); + sb.append(String.valueOf(intIP & 0x000000FF)); + return sb.toString(); + } else { + Long longIP = Long.parseLong(setStrEmpty(ip10)); + + sb.append(String.valueOf(longIP >>> 24));// 直接右移24位 + sb.append("."); + sb.append(String.valueOf((longIP & 0x00FFFFFF) >>> 16)); // 将高8位置0，然后右移16位 + sb.append("."); + sb.append(String.valueOf((longIP & 0x0000FFFF) >>> 8)); + sb.append("."); + sb.append(String.valueOf(longIP & 0x000000FF)); + + return sb.toString(); + } + } + + + /** + * 判断一个IP地址是否属于某一个子网 + * + * @param ip IP地址 + * @param prefix 子网地址 + * @param prefixLen 掩码长度 + * @return true or false + */ + public static boolean inPrefix(String ip, String prefix, int prefixLen) { + String binPrefix = toBinaryString(prefix); + if (binPrefix.length() > prefixLen) { + binPrefix = binPrefix.substring(0,prefixLen); + } + + String binIP = toBinaryString(ip); + binIP = binIP.substring(0,prefixLen); + if (binIP.equals(binPrefix)) { + return true; + } else { + return false; + } + } + + + /** + * 获得两个IP间的范围，如192.168.0.128-192.168.2.256。 + * 注意：本方法不做合法性检查！ + * + * @param startIp 起始IP + * @param endIp 中止IP + * @return 范围内的IP地址数组 + */ + public static List getIPRange(String startIp, String endIp) { + + List list = new ArrayList(); + + try{ + + long start = getIpHostDesimal(startIp); + long end = getIpHostDesimal(endIp); + + for (long i = start; i <= end; i++) { + list.add(getIpHostString(String.valueOf(i))); + } + + } catch (Exception e) { + e.printStackTrace(); + } + + return list; + } + + + + /** + * 验证IP为保留三个IP区域私有地址 + * @param ip IPV4 + * @return boolean true 私有地址 false 公有地址 + */ + public static boolean internalIp(String ip) { + byte[] addr = getAddress(ip); + return internalIp(addr); + } + + private static boolean internalIp(byte[] addr) { + final byte b0 = addr[0]; + final byte b1 = addr[1]; + //10.x.x.x/8 + final byte SECTION_1 = 0x0A; + //172.16.x.x/12 + final byte SECTION_2 = (byte) 0xAC; + final byte SECTION_3 = (byte) 0x10; + final byte SECTION_4 = (byte) 0x1F; + //192.168.x.x/16 + final byte SECTION_5 = (byte) 0xC0; + final byte SECTION_6 = (byte) 0xA8; + switch (b0) { + case SECTION_1: + return true; + case SECTION_2: + if (b1 >= SECTION_3 && b1 <= SECTION_4) { + return true; + } + case SECTION_5: + switch (b1) { + case SECTION_6: + return true; + } + default: + return false; + } + } + + /** + * 获得子网的所有IP地址；如：192.168.0.1/24。 + * 注意：本方法不做合法性检查！ + * @param prefix 子网所属IP地址 + * @param prefixLen 子网掩码 + * @return List + */ + public static List getIPRange(String prefix, int prefixLen) { + String binPrefix = toBinaryString(prefix); + if (binPrefix.length() > prefixLen) { + binPrefix = binPrefix.substring(0,prefixLen); + } + StringBuffer ip1 = new StringBuffer(binPrefix); + StringBuffer ip2 = new StringBuffer(binPrefix); + for (int i = ip1.length(); i < 32; i++) { + ip1.append('0'); + } + for (int i = ip2.length(); i < 32; i++) { + ip2.append('1'); + } + + return getIPRange(toIPString(ip1.toString()),toIPString(ip2.toString())); + } + + + /** + * + *

根据标准ip段获取，该段子网掩码 + *

+ * @param startIP 起始ip，endIP 结束ip + * @return 返回如子网掩码格式IP + */ + public static String getMask(String startIP,String endIP) { + byte start [] = getAddress(startIP); + byte end [] = getAddress(endIP); + byte mask [] = new byte [start.length]; + boolean flag=false; + for(int i=0; i>1); + } + p=(byte)(p<<1); + return (byte)(b&p); + } + + + private static byte[] getAddress(String address) { + String subStr [] = address.split("\\."); + if(subStr.length!=4) { + throw new IllegalArgumentException("所传入的IP地址不符合IPv4的规范"); + } + byte b [] = new byte [4]; + for (int i=0;i=32) + { + return 0; + } + int bits=32-netmask; + return (int) Math.pow(2,bits) -2; + } + + private static StringBuffer toBin(int x) + { + StringBuffer result=new StringBuffer(); + result.append(x%2); + x/=2; + while(x>0){ + result.append(x%2); + x/=2; + } + return result; + } + + + + + + /** + * 根据起始IP地址和子网掩码计算终止IP + * @return String 子网的结束IP + */ + public static String getEndIP(String StartIP,int netmask) + { + return getEndIP(StartIP,convertMask(netmask)); + } + /** + * 根据起始IP地址和子网掩码计算终止IP + * @return String 子网的结束IP + */ + public static String getEndIP(String StartIP, String netmask) + { + Nets nets = new Nets(); + String[] start=Negation(StartIP,netmask).split("\\."); + nets.setStartIP(start[0]+"."+start[1]+"."+start[2]+"."+(Integer.valueOf(start[3])+1)); + nets.setEndIP(TaskOR(Negation(StartIP,netmask),netmask)); + nets.setNetMask(netmask); + return nets.getEndIP(); + } + + /** + * temp1根据temp2取反 + */ + private static String Negation(String StartIP,String netmask) + { + String[] temp1=StartIP.trim().split("\\."); + String[] temp2=netmask.trim().split("\\."); + int[] rets=new int[4]; + for (int i =0;i<4;i++) { + rets[i]=Integer.parseInt(temp1[i])&Integer.parseInt(temp2[i]); + } + return rets[0]+"."+rets[1]+"."+rets[2]+"."+rets[3]; + } + /** + * temp1根据temp2取或 + */ + private static String TaskOR(String StartIP,String netmask) + { + String[] temp1=StartIP.trim().split("\\."); + String[] temp2=netmask.trim().split("\\."); + int[] rets=new int[4]; + for (int i =0;i<4;i++) { + rets[i]=255-(Integer.parseInt(temp1[i])^Integer.parseInt(temp2[i])); + } + //return rets[0]+"."+rets[1]+"."+rets[2]+"."+(rets[3]-1); + return rets[0]+"."+rets[1]+"."+rets[2]+"."+(rets[3]); + } + + + + /** + *

将整型的掩码转换成IPv4型(30 -> 255.255.255.252).

+ * + * @param mask 整型掩码. + * @return IPv4型掩码. + * @exception RuntimeException 掩码错误. + */ + public static String convertMask(int mask) { + if (mask > 32 || mask < 8) { + throw(new RuntimeException("掩码错误！应为8-32的整数。")); + } + return toIPString(maskToBinaryString(mask)); + } + + + /** + *

将整型的掩码转换成反向IPv4型(30 -> 255.255.255.252).

+ * + * @param mask 整型掩码. + * @return IPv4型反向掩码. + * @exception Exception 掩码错误. + */ + public static String convertReverseMask(int mask) throws Exception { + if (mask > 32 || mask < 8) { + throw(new Exception("掩码错误！应为8-32的整数。")); + } + return toIPString(reverseMaskToBinaryString(mask)); + } + + + + /** + * 将整型掩码转换成二进制字符串 + * @param mask 整型掩码 + * @return 二进制型掩码. + */ + private static String maskToBinaryString(int mask) { + StringBuffer str = new StringBuffer(); + + for(int i=1;i<=32;i++) { + if (i <= mask) { + str.append('1'); + } else { + str.append('0'); + } + } + return str.toString(); + } + + + /** + * 将整型掩码转换成二进制字符串 + * @param mask 整型掩码 + * @return 反向二进制型掩码. + */ + private static String reverseMaskToBinaryString(int mask) { + StringBuffer str = new StringBuffer(); + + for(int i=1;i<=32;i++) { + if (i <= mask) { + str.append('0'); + } else { + str.append('1'); + } + } + return str.toString(); + } + + + /** + * 将二进制字符串转换成IPv4型字符串 + * @param binary 二进制字符串 + * @return IPv4型IP. + */ + private static String toIPString(String binary) { + if (binary.length() < 32) { + for (int i=binary.length();i<32;i++) { + binary = "0" + binary; + } + } + + String part1 = binary.substring(0,8); + String part2 = binary.substring(8,16); + String part3 = binary.substring(16,24); + String part4 = binary.substring(24); + return Integer.parseInt(part1,2) + "." + + Integer.parseInt(part2,2) + "." + + Integer.parseInt(part3,2) + "." + + Integer.parseInt(part4,2); + } + /** + * 获取子网的网络地址. + * + * @param ip IP地址. + * @param mask 掩码. + * @return 网络地址. + * @exception Exception IP地址错误或掩码错误. + */ + public static String getSubNetIP(String ip, int mask) throws Exception { + if (!isIP(ip)) { + throw(new Exception("IP地址不合法！")); + } + String s1 = toBinaryString(ip); + String s2 = maskToBinaryString(mask); + return toIPString(Long.toBinaryString(Long.parseLong(s1,2)&Long.parseLong(s2,2))); + } + + /** + *

将整型掩码转换成IPv4型的反码(30 -> 0.0.0.3).

+ * + * @param mask 整型掩码. + * @return IPv4型反码. + * @exception Exception 掩码错误. + */ + public static String reverseMask(int mask) throws Exception { + if (mask > 32 || mask < 8) { + throw(new Exception("掩码错误！应为8-32的整数。")); + } + String str = maskToBinaryString(mask); + str = str.replace('0','2'); + str = str.replace('1','0'); + str = str.replace('2','1'); + return toIPString(str); + } + + /** + * 将IPv4型字符串转换成长度为32的二进制字符串 + * 需要加验证是否为IP + */ + public static String toBinaryString(String ip) { + String[] array = ip.split("[.]"); + String str = ""; + for (int i=0; i验证Ip是否符合规则.给定字符串,判断是否符合正则验证的ip格式.

+ * 
例子说明:
+ * @param ip ip字符 + * @return true ip符合验证规则, false ip不符合验证规则. + */ + public static boolean isIP(String ip) { + if (ip == null) { + return false; + } + Matcher mat = IPV4Pattern.matcher(ip); + return mat.matches(); + } + + + public static boolean isIPv6StdAddress(final String input) { + return IPV6_STD_PATTERN.matcher(input).matches(); + } + + public static boolean isIPv6HexCompressedAddress(final String input) { + return IPV6_HEX_COMPRESSED_PATTERN.matcher(input).matches(); + } + + public static boolean isIPv6Address(final String input) { + return isIPv6StdAddress(input) || isIPv6HexCompressedAddress(input); + } + + /** + * + *

在web方式下获取客户端IP地址.

+ *

+ * 使用该方法,需要在有javaee.jar扩展包前提下. + *

+ * @param request HttpServletRequest请求对象 + * @return 返回字符串IP地址 + */ + public static String getIpAddr(HttpServletRequest request) { + String ip = request.getHeader("X-Forwarded-For"); + if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) { + ip = request.getHeader("Proxy-Client-IP"); + } + if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) { + ip = request.getHeader("WL-Proxy-Client-IP"); + } + if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) { + ip = request.getHeader("HTTP_CLIENT_IP"); + } + if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) { + ip = request.getHeader("HTTP_X_FORWARDED_FOR"); + } + if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) { + ip = request.getRemoteAddr(); + } + return ip; + } + + + /** + * + *

验证mask是否符合规则.给定字符串,判断是否符合正则验证的mask格式.

+ * 
例子说明:
+ * @param mask mask字符 + * @return true mask符合验证规则, false mask不符合验证规则. + */ + public static boolean isMask(String mask) { + if (mask == null) { + return false; + } + if(!isIP(mask)){ + return false; + } + String[] ips = mask.split("\\."); + String binaryVal = ""; + for (int i = 0; i < ips.length; i++) + { + String binaryStr = Integer.toBinaryString(Integer.parseInt(ips[i])); + Integer times = 8 - binaryStr.length(); + + for(int j = 0; j < times; j++) + { + binaryStr = "0" + binaryStr; + } + binaryVal += binaryStr; + } + if(binaryVal.indexOf("01")!=-1){ + return false; + } + return true; + } + + + /** + * + *

将IP进制转换成十进制网络字节序

+ *

+ * IP是一个字符串，符合IP的规则(0-255).(0-255).(0-255).(0-255). + * 将ip转换成长整型的原因是：处理时间类型简单；入库节省空间,查询提高效率. + *

+ * 
+     * IpUtil.getIpDesimal("192.168.1.1") = 3232235777
+     * IpUtil.getIpDesimal("192.168.1.256") = -1 //不符合Ip规则
+     *
+ * @see #getIpString(String) + * @param ip 符合IP规则的字符串 + * @return -1 验证ip不合法,ip 计算ip返回长整型. + */ + public static long getIpDesimal(String ip) { + long ip10 = 0; + if (!isIP(ip)) { + return -1; // ip 不合法 + } + String[] ss = ip.trim().split("\\."); + for (int i = 0; i < 4; i++) { + ip10 += Math.pow(256, i) * Long.parseLong(ss[i]); + } + + return ip10; + } + + + /** + * + *

将IP进制转换成十进制主机字节序

+ *

+ * IP是一个字符串，符合IP的规则(0-255).(0-255).(0-255).(0-255). + * 将ip转换成长整型的原因是：处理时间类型简单；入库节省空间,查询提高效率. + *

+ * 
+     * IpUtil.getIpHostDesimal("192.168.1.1") = 3232235777
+     * IpUtil.getIpHostDesimal("192.168.1.256") = -1 //不符合Ip规则
+     *
+ * @see #getIpString(String) + * @param ip 符合IP规则的字符串 + * @return -1 验证ip不合法,ip 计算ip返回长整型. + */ + + public static long getIpHostDesimal(String ip) { + long ip10 = 0; + if (!isIP(ip)) { + return -1; // ip 不合法 + } + String[] ss = ip.trim().split("\\."); + for (int i = 0; i < 4; i++) { + ip10 += Math.pow(256, 3 - i) * Long.parseLong(ss[i]); + } + + return ip10; + } + + + + /** + * + *

获取IP/mask 包含IP数量，适合完整IPw网段

+ *

+ * + * + *

+ * 
+     *
+     *
+     *
+ * @param ip 符合IP规则的字符串 + * @param mask 掩码格式 + * @return -1 验证ip不合法,ip 计算ip返回长整型. + */ + public static long getIpNum(String ip, int mask) { + long num = 0; + + if (isIP(ip)) { + String endIp = getEndIP(ip, mask); + num = getIpHostDesimal(endIp) - getIpHostDesimal(ip) +1; + + } else { + throw new IllegalArgumentException("所传入的IP地址不符合IPV4规范"); + } + + return num; + } + + + + + // 此方法用于判断数据为空就置为0 + private static String setStrEmpty(String str) { + if ("".equals(str) || str == null) { + str = "0"; + } + return str; + } + + + private static String toString(byte[] address) { + StringWriter sw = new StringWriter(16); + sw.write(Integer.toString(address[0]&0xFF)); + for(int i=1;i { void deleteAll(); void insertWithId(AsnGroupInfo asnGroupInfo); void insertWithoutId(AsnGroupInfo asnGroupInfo); + void updateIpNum(@Param("v4Num")long v4Num,@Param("v6Num")long v6Num,@Param("groupId")Integer groupId); + List getASNIPNum(@Param("asnNo")Integer asnNo); } \ No newline at end of file diff --git a/src/main/java/com/nis/web/dao/basics/AsnGroupInfoDao.xml b/src/main/java/com/nis/web/dao/basics/AsnGroupInfoDao.xml index da4379863..cd7460b3c 100644 --- a/src/main/java/com/nis/web/dao/basics/AsnGroupInfoDao.xml +++ b/src/main/java/com/nis/web/dao/basics/AsnGroupInfoDao.xml @@ -457,4 +457,10 @@ delete from asn_group_info + + update asn_group_info set v4_num=#{v4Num},v6_num=#{v6Num} where group_id=#{groupId} + + \ No newline at end of file diff --git a/src/main/java/com/nis/web/dao/basics/AsnIpCfgDao.java b/src/main/java/com/nis/web/dao/basics/AsnIpCfgDao.java index cc2a2448e..7cd66e2ff 100644 --- a/src/main/java/com/nis/web/dao/basics/AsnIpCfgDao.java +++ b/src/main/java/com/nis/web/dao/basics/AsnIpCfgDao.java @@ -36,4 +36,5 @@ public interface AsnIpCfgDao extends CrudDao{ public void updateAsn(@Param("asnId")String asnNo,@Param("organization")String organization,@Param("country")String country,@Param("detail")String detail,@Param("groupId")String groupId); public void updateAsnIpByAsnGroups(@Param("entity")AsnIpCfg entity,@Param("asnGroups")List asnGroups,@Param("asnIds")String asnIds); public void deleteAll(); + public List findAllAsnIpCfgList(); } diff --git a/src/main/java/com/nis/web/dao/basics/AsnIpCfgDao.xml b/src/main/java/com/nis/web/dao/basics/AsnIpCfgDao.xml index 25528adee..6eef95262 100644 --- a/src/main/java/com/nis/web/dao/basics/AsnIpCfgDao.xml +++ b/src/main/java/com/nis/web/dao/basics/AsnIpCfgDao.xml @@ -671,4 +671,10 @@ delete from asn_ip_cfg + \ No newline at end of file diff --git a/src/main/java/com/nis/web/task/StatisticASNIpNumer.java b/src/main/java/com/nis/web/task/StatisticASNIpNumer.java new file mode 100644 index 000000000..d9a7ae111 --- /dev/null +++ b/src/main/java/com/nis/web/task/StatisticASNIpNumer.java @@ -0,0 +1,134 @@ +package com.nis.web.task; + +import java.util.ArrayList; +import java.util.HashMap; +import java.util.Iterator; +import java.util.List; +import java.util.Map; +import java.util.Map.Entry; + +import org.apache.ibatis.session.ExecutorType; +import org.apache.ibatis.session.SqlSession; +import org.apache.ibatis.session.SqlSessionFactory; +import org.apache.log4j.Logger; +import org.springframework.beans.factory.annotation.Autowired; + +import com.nis.domain.basics.AsnGroupInfo; +import com.nis.domain.basics.AsnIpCfg; +import com.nis.util.IPUtil; +import com.nis.util.StringUtil; +import com.nis.web.dao.basics.AsnGroupInfoDao; +import com.nis.web.dao.basics.AsnIpCfgDao; +import com.nis.web.service.SpringContextHolder; + +import net.sf.json.JSONObject; +/** + * 定时统计ASN 下IPv4和IPV6的个数 + * @author intraUser + * + */ +public class StatisticASNIpNumer { + + private Logger logger = Logger.getLogger(this.getClass()); + + @Autowired + protected AsnIpCfgDao asnIpCfgDao; + public void calculateASNIp() { + logger.info("定时统计ASN IP个数开始。。。。。。。。。。。。。。"); + long start=System.currentTimeMillis(); + Map> asnNumerMap=new HashMap<>(); + List asnIpList=new ArrayList<>(); + asnIpList=asnIpCfgDao.findAllAsnIpCfgList(); + + getAllASNIPNumber(asnIpList, asnNumerMap); + + updateAllASNIPNumber(asnNumerMap); + + long end=System.currentTimeMillis(); + logger.info("定时统计ASN IP个数结束:"+(end-start)+"。。。。。。。。。。。。。。"); + } + public void getAllASNIPNumber(List asnIpList,Map> asnNumerMap){ + logger.info("计算ASN IP开始：asn ip size:"+asnIpList.size()+"。。。。。。。。。。。。。。"); + long start=System.currentTimeMillis(); + if(!StringUtil.isEmpty(asnIpList)){ + try { + for (Iterator iterator = asnIpList.iterator(); iterator.hasNext();) { + Map asnIpMap=(Map) iterator.next(); + //groupId + Integer asnGroupId = (Integer)asnIpMap.get("asn_ip_group"); + //ipType(4:v4,6:v6) + Integer ipType= (Integer)asnIpMap.get("ip_type"); + //(1:mask,2:range,3:ip) + //Integer ipPattern= (Integer)asnIpMap.get("ip_pattern"); + //dest_ip_address + String ipAddress= (String)asnIpMap.get("dest_ip_address"); + long IPNumber=0; + if(ipType.equals(4)){ + if(ipAddress.indexOf("/") > -1){ + Integer mask=Integer.parseInt(ipAddress.split("/")[1]); + ipAddress=ipAddress.split("/")[0]; + IPNumber=IPUtil.getIpNum(ipAddress, mask); + }else{ + IPNumber=1; + } + //判断组是否已经存在 + if(asnNumerMap.keySet().contains(asnGroupId)){ + asnNumerMap.get(asnGroupId).put("v4", asnNumerMap.get(asnGroupId).get("v4")+IPNumber); + asnNumerMap.put(asnGroupId, asnNumerMap.get(asnGroupId)); + }else{ + Map map=new HashMap<>(); + map.put("v4", IPNumber); + map.put("v6", 0l); + asnNumerMap.put(asnGroupId, map); + } + }else{ + IPNumber=1; + //判断组是否已经存在 + if(asnNumerMap.keySet().contains(asnGroupId)){ + asnNumerMap.get(asnGroupId).put("v6", asnNumerMap.get(asnGroupId).get("v6")+IPNumber); + asnNumerMap.put(asnGroupId, asnNumerMap.get(asnGroupId)); + }else{ + Map map=new HashMap<>(); + map.put("v4", 0l); + map.put("v6", IPNumber); + asnNumerMap.put(asnGroupId, map); + } + } + } + } catch (Exception e) { + logger.error("计算ASN IP个数失败",e); + } + } + + long end=System.currentTimeMillis(); + logger.info("计算ASN IP个数结束:"+(end-start)+"。。。。。。。。。。。。。。"); + } + public void updateAllASNIPNumber(Map> asnNumerMap) { + logger.info("修改ASN IP个数开始：asn size:"+asnNumerMap.size()+"。。。。。。。。。。。。。。"); + long start=System.currentTimeMillis(); + if(!StringUtil.isEmpty(asnNumerMap)){ + int index=0; + SqlSessionFactory sqlSessionFactory=SpringContextHolder.getBean(SqlSessionFactory.class); + SqlSession batchSqlSession = null; + try { + for(Entry> e: asnNumerMap.entrySet()) { + batchSqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, false); + ((AsnGroupInfoDao) batchSqlSession.getMapper(AsnGroupInfoDao.class)).updateIpNum(e.getValue().get("v4"),e.getValue().get("v6"),e.getKey()); + if(index!= 0 && index%20000==0){ + batchSqlSession.commit(); + } + index++; + } + batchSqlSession.commit(); + }catch (Exception e) { + logger.error("修改ASN IP个数失败", e); + } finally { + if(batchSqlSession != null){ + batchSqlSession.close(); + } + } + } + long end=System.currentTimeMillis(); + logger.info("修改ASN IP个数结束:"+(end-start)+"。。。。。。。。。。。。。。"); + } +} diff --git a/src/main/resources/messages/message_en.properties b/src/main/resources/messages/message_en.properties index 92ab90505..dc85ddf0d 100644 --- a/src/main/resources/messages/message_en.properties +++ b/src/main/resources/messages/message_en.properties @@ -1494,4 +1494,6 @@ everyWeek=Weekly everyMonth=Monthly on=On validate_error=Unexpected error occurred while validating -Is_schduler=Scheduler \ No newline at end of file +Is_schduler=Scheduler +v4_num=IPv4 Number +v4_num=IPv6 Number \ No newline at end of file diff --git a/src/main/resources/messages/message_ru.properties b/src/main/resources/messages/message_ru.properties index 93ea08751..b447dd000 100644 --- a/src/main/resources/messages/message_ru.properties +++ b/src/main/resources/messages/message_ru.properties @@ -1495,4 +1495,6 @@ single=\u041E\u0434\u043D\u043E\u043A\u0440\u0430\u0442\u043D\u043E everyDay=\u0415\u0436\u0435\u0434\u043D\u0435\u0432\u043D\u043E everyWeek=\u0415\u0436\u0435\u043D\u0435\u0434\u0435\u043B\u044C\u043D\u043E everyMonth=\u0415\u0436\u0435\u043C\u0435\u0441\u044F\u0447\u043D\u043E -validate_error=Unexpected error occurred while validating \ No newline at end of file +validate_error=Unexpected error occurred while validating +v4_num=IPv4 Number +v4_num=IPv6 Number \ No newline at end of file diff --git a/src/main/resources/messages/message_zh_CN.properties b/src/main/resources/messages/message_zh_CN.properties index ea9bba4e7..c1c60eec9 100644 --- a/src/main/resources/messages/message_zh_CN.properties +++ b/src/main/resources/messages/message_zh_CN.properties @@ -1491,4 +1491,6 @@ single=\u5355\u6B21 everyDay=\u6BCF\u5929 everyWeek=\u6BCF\u5468 everyMonth=\u6BCF\u6708 -validate_error=\u9A8C\u8BC1\u65F6\u53D1\u751F\u610F\u5916\u9519\u8BEF \ No newline at end of file +validate_error=\u9A8C\u8BC1\u65F6\u53D1\u751F\u610F\u5916\u9519\u8BEF +v4_num=IPv4 Number +v4_num=IPv6 Number \ No newline at end of file diff --git a/src/main/resources/spring-mvc.xml b/src/main/resources/spring-mvc.xml index dbba6bf18..a094efb76 100644 --- a/src/main/resources/spring-mvc.xml +++ b/src/main/resources/spring-mvc.xml @@ -19,7 +19,9 @@ http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/cache - http://www.springframework.org/schema/cache/spring-cache.xsd"> + http://www.springframework.org/schema/cache/spring-cache.xsd + http://www.springframework.org/schema/task + http://www.springframework.org/schema/task/spring-task.xsd"> @@ -49,6 +51,9 @@ + + + @@ -95,10 +100,15 @@ - + + + + + + java.util.List getIspDicList(java.lang.String) ${fns:getIspDicList(str)} + + + 根据asnGroupId获取asn 的v4数量和v6数量 + getASNIPNum + com.nis.util.ConfigDictUtils + java.util.List getASNIPNum(java.lang.Integer) + ${fns:getASNIPNum(str)} + diff --git a/src/main/webapp/WEB-INF/views/basics/asnGroupList.jsp b/src/main/webapp/WEB-INF/views/basics/asnGroupList.jsp index 5ea6a6a95..f1d299829 100644 --- a/src/main/webapp/WEB-INF/views/basics/asnGroupList.jsp +++ b/src/main/webapp/WEB-INF/views/basics/asnGroupList.jsp @@ -263,6 +263,8 @@ + + @@ -284,6 +286,11 @@ ${cfg.asnId} + + + ${num} + + diff --git a/src/main/webapp/WEB-INF/views/basics/asnIpCfgList.jsp b/src/main/webapp/WEB-INF/views/basics/asnIpCfgList.jsp index 04e2fe0fe..2ef13a1a9 100644 --- a/src/main/webapp/WEB-INF/views/basics/asnIpCfgList.jsp +++ b/src/main/webapp/WEB-INF/views/basics/asnIpCfgList.jsp @@ -273,6 +273,8 @@ + + <%-- --%> @@ -306,6 +308,11 @@ ${cfg.country } ${cfg.detail } ${cfg.userRegion1} + + + ${num} + +