IPRangeLoader.go 5.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167
  1. package main
  2. import (
  3. "bufio"
  4. "log"
  5. "net"
  6. "os"
  7. "strconv"
  8. "strings"
  9. )
  10. // 根据子网掩码获取主机数量
  11. func getCidrHostNum(maskLen int) int {
  12. cidrIPNum := int(0)
  13. if maskLen < 32 {
  14. var i int = int(32 - maskLen - 1)
  15. for ; i >= 1; i-- {
  16. cidrIPNum += 1 << i
  17. }
  18. cidrIPNum += 2
  19. } else {
  20. cidrIPNum = 1
  21. }
  22. if cidrIPNum > 255 {
  23. cidrIPNum = 255
  24. }
  25. return cidrIPNum
  26. }
  27. // 获取 IP 最后一段最小值和最大值
  28. func getCidrIPRange(cidr string) (uint8, uint8) {
  29. ip := strings.Split(cidr, "/")[0]
  30. ipSegs := strings.Split(ip, ".")
  31. maskLen, _ := strconv.Atoi(strings.Split(cidr, "/")[1])
  32. seg4MinIP, seg4MaxIP := getIPSeg4Range(ipSegs, maskLen)
  33. //ipPrefix := ipSegs[0] + "." + ipSegs[1] + "." + ipSegs[2] + "."
  34. return seg4MinIP,
  35. seg4MaxIP
  36. }
  37. // 获取 IP 最后一段的区间
  38. func getIPSeg4Range(ipSegs []string, maskLen int) (uint8, uint8) {
  39. ipSeg, _ := strconv.Atoi(ipSegs[3])
  40. return getIPSegRange(uint8(ipSeg), uint8(32-maskLen))
  41. }
  42. // 根据输入的基础IP地址和CIDR掩码计算一个IP片段的区间
  43. func getIPSegRange(userSegIP, offset uint8) (uint8, uint8) {
  44. var ipSegMax uint8 = 255
  45. netSegIP := ipSegMax << offset
  46. segMinIP := netSegIP & userSegIP
  47. segMaxIP := userSegIP&(255<<offset) | ^(255 << offset)
  48. return uint8(segMinIP), uint8(segMaxIP)
  49. }
  50. func loadFirstIPOfRangeFromFile(ipFile string) []net.IPAddr {
  51. file, err := os.Open(ipFile)
  52. if err != nil {
  53. log.Fatal(err)
  54. }
  55. firstIPs := make([]net.IPAddr, 0)
  56. scanner := bufio.NewScanner(file)
  57. scanner.Split(bufio.ScanLines)
  58. for scanner.Scan() {
  59. IPString := scanner.Text()
  60. firstIP, IPRange, err := net.ParseCIDR(IPString)
  61. //fmt.Println(firstIP)
  62. //fmt.Println(IPRange)
  63. if err != nil {
  64. log.Fatal(err)
  65. }
  66. if !ipv6Mode { // IPv4
  67. minIP, maxIP := getCidrIPRange(scanner.Text()) // 获取 IP 最后一段最小值和最大值
  68. Mask, _ := strconv.Atoi(strings.Split(scanner.Text(), "/")[1]) // 获取子网掩码
  69. MaxIPNum := getCidrHostNum(Mask) // 根据子网掩码获取主机数量
  70. for IPRange.Contains(firstIP) {
  71. if allip { // 如果是测速全部 IP
  72. for i := int(minIP); i <= int(maxIP); i++ { // 遍历 IP 最后一段最小值到最大值
  73. firstIP[15] = uint8(i)
  74. firstIPCopy := make([]byte, len(firstIP))
  75. copy(firstIPCopy, firstIP)
  76. firstIPs = append(firstIPs, net.IPAddr{IP: firstIPCopy})
  77. }
  78. } else { // 随机 IP 的最后一段 0.0.0.X
  79. firstIP[15] = minIP + randipEndWith(MaxIPNum)
  80. firstIPCopy := make([]byte, len(firstIP))
  81. copy(firstIPCopy, firstIP)
  82. firstIPs = append(firstIPs, net.IPAddr{IP: firstIPCopy})
  83. }
  84. firstIP[14]++ // 0.0.(X+1).X
  85. if firstIP[14] == 0 {
  86. firstIP[13]++ // 0.(X+1).X.X
  87. if firstIP[13] == 0 {
  88. firstIP[12]++ // (X+1).X.X.X
  89. }
  90. }
  91. }
  92. } else { //IPv6
  93. var tempIP uint8
  94. for IPRange.Contains(firstIP) {
  95. //fmt.Println(firstIP)
  96. //fmt.Println(firstIP[0], firstIP[1], firstIP[2], firstIP[3], firstIP[4], firstIP[5], firstIP[6], firstIP[7], firstIP[8], firstIP[9], firstIP[10], firstIP[11], firstIP[12], firstIP[13], firstIP[14], firstIP[15])
  97. firstIP[15] = randipEndWith(255) // 随机 IP 的最后一段
  98. firstIP[14] = randipEndWith(255) // 随机 IP 的最后一段
  99. firstIPCopy := make([]byte, len(firstIP))
  100. copy(firstIPCopy, firstIP)
  101. firstIPs = append(firstIPs, net.IPAddr{IP: firstIPCopy})
  102. tempIP = firstIP[13]
  103. firstIP[13] += randipEndWith(255)
  104. if firstIP[13] < tempIP {
  105. tempIP = firstIP[12]
  106. firstIP[12] += randipEndWith(255)
  107. if firstIP[12] < tempIP {
  108. tempIP = firstIP[11]
  109. firstIP[11] += randipEndWith(255)
  110. if firstIP[11] < tempIP {
  111. tempIP = firstIP[10]
  112. firstIP[10] += randipEndWith(255)
  113. if firstIP[10] < tempIP {
  114. tempIP = firstIP[9]
  115. firstIP[9] += randipEndWith(255)
  116. if firstIP[9] < tempIP {
  117. tempIP = firstIP[8]
  118. firstIP[8] += randipEndWith(255)
  119. if firstIP[8] < tempIP {
  120. tempIP = firstIP[7]
  121. firstIP[7] += randipEndWith(255)
  122. if firstIP[7] < tempIP {
  123. tempIP = firstIP[6]
  124. firstIP[6] += randipEndWith(255)
  125. if firstIP[6] < tempIP {
  126. tempIP = firstIP[5]
  127. firstIP[5] += randipEndWith(255)
  128. if firstIP[5] < tempIP {
  129. tempIP = firstIP[4]
  130. firstIP[4] += randipEndWith(255)
  131. if firstIP[4] < tempIP {
  132. tempIP = firstIP[3]
  133. firstIP[3] += randipEndWith(255)
  134. if firstIP[3] < tempIP {
  135. tempIP = firstIP[2]
  136. firstIP[2] += randipEndWith(255)
  137. if firstIP[2] < tempIP {
  138. tempIP = firstIP[1]
  139. firstIP[1] += randipEndWith(255)
  140. if firstIP[1] < tempIP {
  141. tempIP = firstIP[0]
  142. firstIP[0] += randipEndWith(255)
  143. }
  144. }
  145. }
  146. }
  147. }
  148. }
  149. }
  150. }
  151. }
  152. }
  153. }
  154. }
  155. }
  156. }
  157. }
  158. }
  159. return firstIPs
  160. }