11 Commits

Author SHA1 Message Date
xiu2
638273b7e7 修复 下载测速时间不准确、卡住的问题 2020-12-24 23:09:07 +08:00
xiu2
dc68529244 update 2020-12-23 11:01:37 +08:00
xiu2
29c927d3cd update 2020-12-22 23:57:46 +08:00
xiu2
fb190c661d update 2020-12-21 11:30:10 +08:00
xiu2
9e39be140a update 2020-12-21 11:15:11 +08:00
xiu2
09a578decf 优化 参数说明 2020-12-19 14:36:25 +08:00
xiu2
8ef6b3b7c2 优化 参数说明 2020-12-19 14:14:16 +08:00
xiu2
cc6b5dd7a6 update 2020-12-19 10:11:43 +08:00
xiu2
6c1166fc5e 新增 下载速度排序;修复 下载测速时间 -dt 参数自定义值无效的问题;回调 下载测速时间默认值为 10 秒 2020-12-19 09:54:18 +08:00
xiu2
f9ac05a072 update 2020-12-14 10:36:40 +08:00
xiu2
976dd79913 优化 IP 段子网掩码解析 2020-12-11 12:12:09 +08:00
6 changed files with 173 additions and 129 deletions

View File

@@ -9,18 +9,49 @@ import (
"strings" "strings"
) )
// 根据子网掩码获取主机数量
func getCidrHostNum(maskLen int) int { func getCidrHostNum(maskLen int) int {
cidrIpNum := int(0) cidrIPNum := int(0)
if maskLen < 32 { if maskLen < 32 {
var i int = int(32 - maskLen - 1) var i int = int(32 - maskLen - 1)
for ; i >= 1; i-- { for ; i >= 1; i-- {
cidrIpNum += 1 << i cidrIPNum += 1 << i
} }
cidrIpNum += 2 cidrIPNum += 2
} else { } else {
cidrIpNum = 1 cidrIPNum = 1
} }
return cidrIpNum if cidrIPNum > 255 {
cidrIPNum = 255
}
return cidrIPNum
}
// 获取 IP 最后一段最小值和最大值
func getCidrIPRange(cidr string) (uint8, uint8) {
ip := strings.Split(cidr, "/")[0]
ipSegs := strings.Split(ip, ".")
maskLen, _ := strconv.Atoi(strings.Split(cidr, "/")[1])
seg4MinIP, seg4MaxIP := getIPSeg4Range(ipSegs, maskLen)
//ipPrefix := ipSegs[0] + "." + ipSegs[1] + "." + ipSegs[2] + "."
return seg4MinIP,
seg4MaxIP
}
// 获取 IP 最后一段的区间
func getIPSeg4Range(ipSegs []string, maskLen int) (uint8, uint8) {
ipSeg, _ := strconv.Atoi(ipSegs[3])
return getIPSegRange(uint8(ipSeg), uint8(32-maskLen))
}
// 根据输入的基础IP地址和CIDR掩码计算一个IP片段的区间
func getIPSegRange(userSegIP, offset uint8) (uint8, uint8) {
var ipSegMax uint8 = 255
netSegIP := ipSegMax << offset
segMinIP := netSegIP & userSegIP
segMaxIP := userSegIP&(255<<offset) | ^(255 << offset)
return uint8(segMinIP), uint8(segMaxIP)
} }
func loadFirstIPOfRangeFromFile(ipFile string) []net.IPAddr { func loadFirstIPOfRangeFromFile(ipFile string) []net.IPAddr {
@@ -36,67 +67,86 @@ func loadFirstIPOfRangeFromFile(ipFile string) []net.IPAddr {
firstIP, IPRange, err := net.ParseCIDR(IPString) firstIP, IPRange, err := net.ParseCIDR(IPString)
//fmt.Println(firstIP) //fmt.Println(firstIP)
//fmt.Println(IPRange) //fmt.Println(IPRange)
Mask, _ := strconv.Atoi(strings.Split(scanner.Text(), "/")[1])
MaxIPNum := getCidrHostNum(Mask)
if MaxIPNum > 255 {
MaxIPNum = 255
}
//fmt.Println(MaxIPNum)
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }
if ipv6Mode { // IPv6 if !ipv6Mode { // IPv4
minIP, maxIP := getCidrIPRange(scanner.Text()) // 获取 IP 最后一段最小值和最大值
Mask, _ := strconv.Atoi(strings.Split(scanner.Text(), "/")[1]) // 获取子网掩码
MaxIPNum := getCidrHostNum(Mask) // 根据子网掩码获取主机数量
for IPRange.Contains(firstIP) {
if allip { // 如果是测速全部 IP
for i := int(minIP); i <= int(maxIP); i++ { // 遍历 IP 最后一段最小值到最大值
firstIP[15] = uint8(i)
firstIPCopy := make([]byte, len(firstIP))
copy(firstIPCopy, firstIP)
firstIPs = append(firstIPs, net.IPAddr{IP: firstIPCopy})
}
} else { // 随机 IP 的最后一段 0.0.0.X
firstIP[15] = minIP + randipEndWith(MaxIPNum)
firstIPCopy := make([]byte, len(firstIP))
copy(firstIPCopy, firstIP)
firstIPs = append(firstIPs, net.IPAddr{IP: firstIPCopy})
}
firstIP[14]++ // 0.0.(X+1).X
if firstIP[14] == 0 {
firstIP[13]++ // 0.(X+1).X.X
if firstIP[13] == 0 {
firstIP[12]++ // (X+1).X.X.X
}
}
}
} else { //IPv6
var tempIP uint8 var tempIP uint8
MaxIPNum = 255
for IPRange.Contains(firstIP) { for IPRange.Contains(firstIP) {
//fmt.Println(firstIP) //fmt.Println(firstIP)
//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]) //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])
firstIP[15] = randipEndWith(MaxIPNum) // 随机 IP 的最后一段 firstIP[15] = randipEndWith(255) // 随机 IP 的最后一段
firstIP[14] = randipEndWith(MaxIPNum) // 随机 IP 的最后一段 firstIP[14] = randipEndWith(255) // 随机 IP 的最后一段
firstIPCopy := make([]byte, len(firstIP)) firstIPCopy := make([]byte, len(firstIP))
copy(firstIPCopy, firstIP) copy(firstIPCopy, firstIP)
firstIPs = append(firstIPs, net.IPAddr{IP: firstIPCopy}) firstIPs = append(firstIPs, net.IPAddr{IP: firstIPCopy})
tempIP = firstIP[13] tempIP = firstIP[13]
firstIP[13] += randipEndWith(MaxIPNum) firstIP[13] += randipEndWith(255)
if firstIP[13] < tempIP { if firstIP[13] < tempIP {
tempIP = firstIP[12] tempIP = firstIP[12]
firstIP[12] += randipEndWith(MaxIPNum) firstIP[12] += randipEndWith(255)
if firstIP[12] < tempIP { if firstIP[12] < tempIP {
tempIP = firstIP[11] tempIP = firstIP[11]
firstIP[11] += randipEndWith(MaxIPNum) firstIP[11] += randipEndWith(255)
if firstIP[11] < tempIP { if firstIP[11] < tempIP {
tempIP = firstIP[10] tempIP = firstIP[10]
firstIP[10] += randipEndWith(MaxIPNum) firstIP[10] += randipEndWith(255)
if firstIP[10] < tempIP { if firstIP[10] < tempIP {
tempIP = firstIP[9] tempIP = firstIP[9]
firstIP[9] += randipEndWith(MaxIPNum) firstIP[9] += randipEndWith(255)
if firstIP[9] < tempIP { if firstIP[9] < tempIP {
tempIP = firstIP[8] tempIP = firstIP[8]
firstIP[8] += randipEndWith(MaxIPNum) firstIP[8] += randipEndWith(255)
if firstIP[8] < tempIP { if firstIP[8] < tempIP {
tempIP = firstIP[7] tempIP = firstIP[7]
firstIP[7] += randipEndWith(MaxIPNum) firstIP[7] += randipEndWith(255)
if firstIP[7] < tempIP { if firstIP[7] < tempIP {
tempIP = firstIP[6] tempIP = firstIP[6]
firstIP[6] += randipEndWith(MaxIPNum) firstIP[6] += randipEndWith(255)
if firstIP[6] < tempIP { if firstIP[6] < tempIP {
tempIP = firstIP[5] tempIP = firstIP[5]
firstIP[5] += randipEndWith(MaxIPNum) firstIP[5] += randipEndWith(255)
if firstIP[5] < tempIP { if firstIP[5] < tempIP {
tempIP = firstIP[4] tempIP = firstIP[4]
firstIP[4] += randipEndWith(MaxIPNum) firstIP[4] += randipEndWith(255)
if firstIP[4] < tempIP { if firstIP[4] < tempIP {
tempIP = firstIP[3] tempIP = firstIP[3]
firstIP[3] += randipEndWith(MaxIPNum) firstIP[3] += randipEndWith(255)
if firstIP[3] < tempIP { if firstIP[3] < tempIP {
tempIP = firstIP[2] tempIP = firstIP[2]
firstIP[2] += randipEndWith(MaxIPNum) firstIP[2] += randipEndWith(255)
if firstIP[2] < tempIP { if firstIP[2] < tempIP {
tempIP = firstIP[1] tempIP = firstIP[1]
firstIP[1] += randipEndWith(MaxIPNum) firstIP[1] += randipEndWith(255)
if firstIP[1] < tempIP { if firstIP[1] < tempIP {
tempIP = firstIP[0] tempIP = firstIP[0]
firstIP[0] += randipEndWith(MaxIPNum) firstIP[0] += randipEndWith(255)
} }
} }
} }
@@ -111,41 +161,6 @@ func loadFirstIPOfRangeFromFile(ipFile string) []net.IPAddr {
} }
} }
} }
} else { //IPv4
for IPRange.Contains(firstIP) {
//fmt.Println(firstIP)
//fmt.Println(firstIP[15])
if allip {
if firstIP[15] == 0 { // 当 IP 最后一段为 0 时会按顺序生成 IP
for i := 0; i < MaxIPNum; i++ {
firstIP[15] = uint8(i) // 按顺序生成 IP 的最后一段 0.0.0.X
//fmt.Println(firstIP)
firstIPCopy := make([]byte, len(firstIP))
copy(firstIPCopy, firstIP)
firstIPs = append(firstIPs, net.IPAddr{IP: firstIPCopy})
}
} else { // 当 IP 最后一段不为 0 时,则保留 IP 最后一段
firstIPCopy := make([]byte, len(firstIP))
copy(firstIPCopy, firstIP)
firstIPs = append(firstIPs, net.IPAddr{IP: firstIPCopy})
}
} else {
if firstIP[15] == 0 {
firstIP[15] = randipEndWith(MaxIPNum) // 随机 IP 的最后一段 0.0.0.X
}
firstIPCopy := make([]byte, len(firstIP))
copy(firstIPCopy, firstIP)
firstIPs = append(firstIPs, net.IPAddr{IP: firstIPCopy})
}
firstIP[15] = 0
firstIP[14]++ // 0.0.(X+1).X
if firstIP[14] == 0 {
firstIP[13]++ // 0.(X+1).X.X
if firstIP[13] == 0 {
firstIP[12]++ // (X+1).X.X.X
}
}
}
} }
} }
return firstIPs return firstIPs

View File

@@ -19,38 +19,41 @@
### 下载运行 ### 下载运行
1. 下载编译好的可执行文件 [蓝奏云](https://xiu.lanzoux.com/b0742hkxe) / [Github](https://github.com/XIU2/CloudflareSpeedTest/releases) 并解压。 1. 下载编译好的可执行文件 [蓝奏云](https://xiu.lanzoux.com/b0742hkxe) / [Github](https://github.com/XIU2/CloudflareSpeedTest/releases) 并解压。
2. 双击运行 `CloudflareST.exe`文件Windows等待测速... 2. 双击运行 `CloudflareST.exe`文件Windows等待测速完成...
> **提示Linux 系统**请先赋予执行权限 `chmod +x CloudflareST` ,然后再执行 `./CloudflareST` > **提示Linux 系统**请先赋予执行权限 `chmod +x CloudflareST` ,然后再执行 `./CloudflareST`
> **注意:建议测速时避开高峰期(晚上~凌晨)**,否则测速结果会与其他时间**差距很大...**
### 结果示例 ### 结果示例
测速完毕后,默认会显示**最快的 20 个 IP**,示例: 测速完毕后,默认会显示**最快的 20 个 IP**,示例(我的白天测速结果)
``` ```
IP 地址 已发送 已接收 丢包率 平均延迟 下载速度 (MB/s) IP 地址 已发送 已接收 丢包率 平均延迟 下载速度 (MB/s)
104.27.198.101 4 4 0.00 126.52 12.71 104.27.200.69 4 4 0.00 146.23 28.64
104.22.43.157 4 4 0.00 129.38 16.74 172.67.60.78 4 4 0.00 139.82 15.02
104.27.214.140 4 4 0.00 132.02 4.65 104.25.140.153 4 4 0.00 146.49 14.90
104.22.42.165 4 4 0.00 133.63 12.00 104.27.192.65 4 4 0.00 140.28 14.07
104.22.35.177 4 4 0.00 135.75 3.92 172.67.62.214 4 4 0.00 139.29 12.71
104.22.87.44 4 4 0.00 136.00 5.86 104.27.207.5 4 4 0.00 145.92 11.95
104.22.67.122 4 4 0.00 136.50 9.47 172.67.54.193 4 4 0.00 146.71 11.55
104.22.88.154 4 4 0.00 140.75 13.00 104.22.66.8 4 4 0.00 147.42 11.11
104.22.69.218 4 4 0.00 142.00 19.07 104.27.197.63 4 4 0.00 131.29 10.26
104.27.184.10 4 4 0.00 148.02 21.05 172.67.58.91 4 4 0.00 140.19 9.14
... ...
``` ```
选择一个平均延迟与下载速度都不错的 IP至于拿来干嘛取决于你~ 测速结果第一行是**兼顾平均延迟与下载速度的最快 IP**,至于拿来干嘛?取决于你~
完整结果保存在当前目录下的 `result.csv` 文件中,用**记事本/表格软件**打开,排序为**延迟由低到高**,分别是 完整结果保存在当前目录下的 `result.csv` 文件中,用**记事本/表格软件**打开,格式如下
``` ```
IP 地址, 已发送, 已接收, 丢包率, 平均延迟, 下载速度 (MB/s) IP 地址, 已发送, 已接收, 丢包率, 平均延迟, 下载速度 (MB/s)
104.27.198.101, 4, 4, 0.00, 126.52, 12.71 104.27.200.69, 4, 4, 0.00, 146.23, 28.64
``` ```
> 大家可以按照自己的需求,对完整结果**进一步筛选处理**,或者去看一看进阶使用(如设定测速条件)!
> 大家可以按自己需求,对完整结果**进一步筛选处理**,或者去看一看进阶使用**指定过滤条件**
**** ****
## 进阶使用 ## 进阶使用
@@ -66,33 +69,33 @@ https://github.com/XIU2/CloudflareSpeedTest
参数: 参数:
-n 500 -n 500
测速线程数量;数值越大速度越快,请勿超过 1000(结果误差大)(默认 500) 测速线程数量;线程数量越多延迟测速越快,请勿超过 1000 (误差大)(默认 500)
-t 4 -t 4
延迟测速次数;单个 IP 测速次数,为 1 时将过滤丢包的IPTCP协议(默认 4) 延迟测速次数;单个 IP 延迟测速次数,为 1 时将过滤丢包的IPTCP协议(默认 4)
-tp 443 -tp 443
延迟测速端口;延迟测速 TCP 协议的端口;(默认 443) 延迟测速端口;延迟测速 TCP 协议的端口;(默认 443)
-dn 20 -dn 20
下载测速数量;延迟测速并排序后,从最低延迟起下载测速数量,请勿太多(速度慢)(默认 20) 下载测速数量;延迟测速并排序后,从最低延迟起下载测速数量;(默认 20)
-dt 5 -dt 10
下载测速时间;单个 IP 测速最长时间,单位:秒;(默认 5) 下载测速时间;单个 IP 下载测速最长时间,单位:秒;(默认 10)
-url https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png -url https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png
下载测速地址;用来 Cloudflare CDN 测速的文件地址,如含有空格请加上引号; 下载测速地址;用来下载测速的 Cloudflare CDN 文件地址,如地址含有空格请加上引号;
-tl 200 -tl 200
延迟时间上限;只输出指定延迟时间以下的结果,数量为 -dn 参数的值,单位:ms 平均延迟上限;只输出低于指定平均延迟的 IP与下载速度下限搭配使用(默认 9999 ms)
-sl 5 -sl 5
下载速度下限;只输出指定下载速度以上的结果,数量为 -dn 参数的值,单位:MB/s 下载速度下限;只输出高于指定下载速度的 IP凑够指定数量 [-dn] 才会停止测速;(默认 0 MB/s)
-p 20 -p 20
显示结果数量;测速后直接显示指定数量的结果,为 0 时不显示结果直接退出;(默认 20) 显示结果数量;测速后直接显示指定数量的结果,为 0 时不显示结果直接退出;(默认 20)
-f ip.txt -f ip.txt
IP 数据文件;如含有空格请加上引号;支持其他 CDN IP段,记得禁用下载测速(默认 ip.txt) IP数据文件;如路径含有空格请加上引号;支持其他 CDN IP段(默认 ip.txt)
-o result.csv -o result.csv
输出结果文件;如含有空格请加上引号;为空格时不输出结果文件(-o " ");允许其他后缀(默认 result.csv) 输出结果文件;如路径含有空格请加上引号;为空格时不输出 [-o " "](默认 result.csv)
-dd -dd
禁用下载测速;如果带上该参数就是禁用下载测速(默认 启用) 禁用下载测速;禁用后测速结果会按延迟排序(默认按下载速度排序)(默认 启用)
-ipv6 -ipv6
IPv6 测速模式;确保 IP 数据文件内只包含 IPv6 IP段软件不支持同时测速 IPv4+IPv6(默认 IPv4) IPv6测速模式确保 IP 数据文件内只包含 IPv6 IP段软件不支持同时测速 IPv4+IPv6(默认 IPv4)
-allip -allip
测速全部 IP如果带上该参数将会对每个 IP (仅 IPv4) 进行测速;(默认 每个 IP 段随机测速一个 IP) 测速全部IP对 IP 段中的每个 IP (仅支持 IPv4) 进行测速;(默认 每个 IP 段随机测速一个 IP)
-v -v
打印程序版本+检查版本更新 打印程序版本+检查版本更新
-h -h
@@ -116,32 +119,39 @@ CloudflareST.exe -p 0 -f ip.txt -dd
# 指定 IPv6 数据文件( ipv6.txt ),不显示结果直接退出(-p 值为 0 # 指定 IPv6 数据文件( ipv6.txt ),不显示结果直接退出(-p 值为 0
CloudflareST.exe -p 0 -f ipv6.txt -dd -ipv6 CloudflareST.exe -p 0 -f ipv6.txt -dd -ipv6
# ——————————————————————
# 指定 IPv4 数据文件,不输出结果到文件,直接显示结果(-p 值为 10 条) # 指定 IPv4 数据文件,不输出结果到文件,直接显示结果(-p 值为 10 条)
CloudflareST.exe -p 10 -f ip.txt -o " " -dd CloudflareST.exe -p 10 -f ip.txt -o " " -dd
# 指定 IPv4 数据文件 及 输出结果到文件(相对路径,即当前目录下,如果包含空格请加上引号) # 指定 IPv4 数据文件 及 输出结果到文件(相对路径,即当前目录下,如含空格请加上引号)
CloudflareST.exe -f ip.txt -o result.csv -dd CloudflareST.exe -f ip.txt -o result.csv -dd
# 指定 IPv4 数据文件 及 输出结果到文件(绝对路径,即 C:\abc\ 目录下,如果包含空格请加上引号) # 指定 IPv4 数据文件 及 输出结果到文件(绝对路径,即 C:\abc\ 目录下,如含空格请加上引号)
CloudflareST.exe -f C:\abc\ip.txt -o C:\abc\result.csv -dd CloudflareST.exe -f C:\abc\ip.txt -o C:\abc\result.csv -dd
# 指定下载测速地址(要求:可以直接下载、文件大小超过 200MB、用的是 Cloudflare CDN如果包含空格请加上引号 # ——————————————————————
# 指定下载测速地址(要求:可以直接下载、文件大小超过 200MB、用的是 Cloudflare CDN如含空格请加上引号
CloudflareST.exe -url https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png CloudflareST.exe -url https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png
# 指定测速条件(只有同时满足三个条件时才会停止测速): # ——————————————————————
# 延迟时间上限200 ms下载速度下限0 MB/s数量10 个
CloudflareST.exe -tl 200 -dn 10
# 延迟时间上限0 ms下载速度下限5 MB/s数量10 个 # 指定测速条件(只有同时满足三个条件时才会停止测速):
# 平均延迟上限9999 ms下载速度下限5 MB/s数量10 个
# 即需要找到 10 个平均延迟低于 9999 ms 且 下载速度高于 5 MB/s 的 IP 才会停止测速。
CloudflareST.exe -sl 5 -dn 10 CloudflareST.exe -sl 5 -dn 10
# 延迟时间上限200 ms下载速度下限5 MB/s数量10 个 # 没有指定平均延迟上限时,如果一直凑不够满足条件的 IP 数量,会一直测速下去。
# 所以建议同时指定 下载速度下限 和 平均延迟上限,这样测试到指定延迟还没凑够数量,就会终止测速。
# 平均延迟上限200 ms下载速度下限5 MB/s数量10 个
# 即需要找到 10 个平均延迟低于 200 ms 且 下载速度高于 5 MB/s 的 IP 才会停止测速。
CloudflareST.exe -tl 200 -sl 5 -dn 10 CloudflareST.exe -tl 200 -sl 5 -dn 10
# 如果一直凑不够指定数量,会一直测速下去。 # 如果一个满足条件的 IP 都没找到,那么就会和不指定条件一样输出完整结果。
# 建议指定下载速度下限时,同时指定延迟时间上限,如果测试到指定延迟还没凑够数,就会终止测速。 # 所以建议先不指定条件测速一遍,看看平均延迟和下载速度大概在什么范围,避免指定条件过低/过高!
# 如果一个满足条件的 IP 都没有,那么就会正常输出结果(和不指定条件一样)。
# 如果你需要通过外部程序进一步筛选处理,那么只需要判断测速结果数量,如果上千个说明一个满足条件的 IP 都没有。
``` ```
``` cmd ``` cmd

5
ip.txt
View File

@@ -1,3 +1,5 @@
1.1.1.0/24
1.0.0.0/24
173.245.48.0/20 173.245.48.0/20
103.21.244.0/22 103.21.244.0/22
103.22.200.0/22 103.22.200.0/22
@@ -12,3 +14,6 @@
104.16.0.0/12 104.16.0.0/12
172.64.0.0/13 172.64.0.0/13
131.0.72.0/22 131.0.72.0/22
35.200.109.86/32
202.81.235.61/32
202.81.235.92/32

39
main.go
View File

@@ -17,10 +17,9 @@ import (
var version, ipFile, outputFile, versionNew string var version, ipFile, outputFile, versionNew string
var disableDownload, ipv6Mode, allip bool var disableDownload, ipv6Mode, allip bool
var tcpPort, printResultNum, timeLimit, speedLimit int var tcpPort, printResultNum, timeLimit, speedLimit, downloadSecond int
func init() { func init() {
var downloadSecond int64
var printVersion bool var printVersion bool
var help = ` var help = `
CloudflareSpeedTest ` + version + ` CloudflareSpeedTest ` + version + `
@@ -29,33 +28,33 @@ https://github.com/XIU2/CloudflareSpeedTest
参数: 参数:
-n 500 -n 500
测速线程数量;数值越大速度越快,请勿超过 1000(结果误差大)(默认 500) 测速线程数量;线程数量越多延迟测速越快,请勿超过 1000 (误差大)(默认 500)
-t 4 -t 4
延迟测速次数;单个 IP 测速次数,为 1 时将过滤丢包的IPTCP协议(默认 4) 延迟测速次数;单个 IP 延迟测速次数,为 1 时将过滤丢包的IPTCP协议(默认 4)
-tp 443 -tp 443
延迟测速端口;延迟测速 TCP 协议的端口;(默认 443) 延迟测速端口;延迟测速 TCP 协议的端口;(默认 443)
-dn 20 -dn 20
下载测速数量;延迟测速并排序后,从最低延迟起下载测速数量,请勿太多(速度慢)(默认 20) 下载测速数量;延迟测速并排序后,从最低延迟起下载测速数量;(默认 20)
-dt 5 -dt 10
下载测速时间;单个 IP 测速最长时间,单位:秒;(默认 5) 下载测速时间;单个 IP 下载测速最长时间,单位:秒;(默认 10)
-url https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png -url https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png
下载测速地址;用来 Cloudflare CDN 测速的文件地址,如含有空格请加上引号; 下载测速地址;用来下载测速的 Cloudflare CDN 文件地址,如地址含有空格请加上引号;
-tl 200 -tl 200
延迟时间上限;只输出指定延迟时间以下的结果,数量为 -dn 参数的值,单位:ms 平均延迟上限;只输出低于指定平均延迟的 IP与下载速度下限搭配使用(默认 9999 ms)
-sl 5 -sl 5
下载速度下限;只输出指定下载速度以上的结果,数量为 -dn 参数的值,单位:MB/s 下载速度下限;只输出高于指定下载速度的 IP凑够指定数量 [-dn] 才会停止测速;(默认 0 MB/s)
-p 20 -p 20
显示结果数量;测速后直接显示指定数量的结果,为 0 时不显示结果直接退出;(默认 20) 显示结果数量;测速后直接显示指定数量的结果,为 0 时不显示结果直接退出;(默认 20)
-f ip.txt -f ip.txt
IP 数据文件;如含有空格请加上引号;支持其他 CDN IP段,记得禁用下载测速(默认 ip.txt) IP数据文件;如路径含有空格请加上引号;支持其他 CDN IP段(默认 ip.txt)
-o result.csv -o result.csv
输出结果文件;如含有空格请加上引号;为空格时不输出结果文件(-o " ");允许其他后缀(默认 result.csv) 输出结果文件;如路径含有空格请加上引号;为空格时不输出 [-o " "](默认 result.csv)
-dd -dd
禁用下载测速;如果带上该参数将会禁用下载测速(默认 启用下载测速) 禁用下载测速;禁用后测速结果会按延迟排序(默认按下载速度排序)(默认 启用)
-ipv6 -ipv6
IPv6 测速模式;确保 IP 数据文件内只包含 IPv6 IP段软件不支持同时测速 IPv4+IPv6(默认 IPv4) IPv6测速模式确保 IP 数据文件内只包含 IPv6 IP段软件不支持同时测速 IPv4+IPv6(默认 IPv4)
-allip -allip
测速全部 IP如果带上该参数将会对每个 IP (仅 IPv4) 进行测速;(默认 每个 IP 段随机测速一个 IP) 测速全部IP对 IP 段中的每个 IP (仅支持 IPv4) 进行测速;(默认 每个 IP 段随机测速一个 IP)
-v -v
打印程序版本+检查版本更新 打印程序版本+检查版本更新
-h -h
@@ -66,9 +65,9 @@ https://github.com/XIU2/CloudflareSpeedTest
flag.IntVar(&pingTime, "t", 4, "延迟测速次数") flag.IntVar(&pingTime, "t", 4, "延迟测速次数")
flag.IntVar(&tcpPort, "tp", 443, "延迟测速端口") flag.IntVar(&tcpPort, "tp", 443, "延迟测速端口")
flag.IntVar(&downloadTestCount, "dn", 20, "下载测速数量") flag.IntVar(&downloadTestCount, "dn", 20, "下载测速数量")
flag.Int64Var(&downloadSecond, "dt", 5, "下载测速时间") flag.IntVar(&downloadSecond, "dt", 10, "下载测速时间")
flag.StringVar(&url, "url", "https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png", "下载测速地址") flag.StringVar(&url, "url", "https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png", "下载测速地址")
flag.IntVar(&timeLimit, "tl", 0, "延迟时间上限") flag.IntVar(&timeLimit, "tl", 9999, "延迟时间上限")
flag.IntVar(&speedLimit, "sl", 0, "下载速度下限") flag.IntVar(&speedLimit, "sl", 0, "下载速度下限")
flag.IntVar(&printResultNum, "p", 20, "显示结果数量") flag.IntVar(&printResultNum, "p", 20, "显示结果数量")
flag.BoolVar(&disableDownload, "dd", false, "禁用下载测速") flag.BoolVar(&disableDownload, "dd", false, "禁用下载测速")
@@ -78,8 +77,6 @@ https://github.com/XIU2/CloudflareSpeedTest
flag.StringVar(&outputFile, "o", "result.csv", "输出结果文件") flag.StringVar(&outputFile, "o", "result.csv", "输出结果文件")
flag.BoolVar(&printVersion, "v", false, "打印程序版本") flag.BoolVar(&printVersion, "v", false, "打印程序版本")
downloadTestTime = time.Duration(downloadSecond) * time.Second
flag.Usage = func() { fmt.Print(help) } flag.Usage = func() { fmt.Print(help) }
flag.Parse() flag.Parse()
if printVersion { if printVersion {
@@ -139,6 +136,7 @@ func main() {
var mu sync.Mutex var mu sync.Mutex
var data = make([]CloudflareIPData, 0) var data = make([]CloudflareIPData, 0)
var data_2 = make([]CloudflareIPData, 0) var data_2 = make([]CloudflareIPData, 0)
downloadTestTime = time.Duration(downloadSecond) * time.Second
fmt.Println("# XIU2/CloudflareSpeedTest " + version + "\n") fmt.Println("# XIU2/CloudflareSpeedTest " + version + "\n")
if ipv6Mode { if ipv6Mode {
@@ -194,6 +192,7 @@ func main() {
} }
if len(data_2) > 0 { // 如果该数字有内容,说明进行过指定条件的下载测速 if len(data_2) > 0 { // 如果该数字有内容,说明进行过指定条件的下载测速
sort.Sort(CloudflareIPDataSetD(data_2)) // 排序
if outputFile != "" { if outputFile != "" {
ExportCsv(outputFile, data_2) // 输出结果到文件(指定延迟时间或下载速度的) ExportCsv(outputFile, data_2) // 输出结果到文件(指定延迟时间或下载速度的)
} }

View File

@@ -112,7 +112,7 @@ func DownloadSpeedHandler(ip net.IPAddr) (bool, float32) {
Transport: nil, Transport: nil,
CheckRedirect: nil, CheckRedirect: nil,
Jar: nil, Jar: nil,
Timeout: 0, Timeout: downloadTestTime,
} }
var fullAddress string var fullAddress string
if ipv6Mode { // IPv6 需要加上 [] if ipv6Mode { // IPv6 需要加上 []
@@ -124,7 +124,6 @@ func DownloadSpeedHandler(ip net.IPAddr) (bool, float32) {
DialContext: GetDialContextByAddr(fullAddress), DialContext: GetDialContextByAddr(fullAddress),
} }
response, err := client.Get(url) response, err := client.Get(url)
if err != nil { if err != nil {
return false, 0 return false, 0
} else { } else {
@@ -165,7 +164,7 @@ func DownloadSpeedHandler(ip net.IPAddr) (bool, float32) {
} }
} }
} }
return true, float32(e.Value()) / (float32(downloadTestTime.Seconds()) / 100) return true, float32(e.Value()) / (float32(downloadTestTime.Seconds()) / 150)
} else { } else {
return false, 0 return false, 0
} }

16
util.go
View File

@@ -85,8 +85,12 @@ const tcpConnectTimeout = time.Second * 1
var failTime int var failTime int
// 平均延迟排序(丢包另算)
type CloudflareIPDataSet []CloudflareIPData type CloudflareIPDataSet []CloudflareIPData
// 下载速度排序
type CloudflareIPDataSetD []CloudflareIPData
func initRandSeed() { func initRandSeed() {
rand.Seed(time.Now().UnixNano()) rand.Seed(time.Now().UnixNano())
} }
@@ -146,3 +150,15 @@ func (cfs CloudflareIPDataSet) Less(i, j int) bool {
func (cfs CloudflareIPDataSet) Swap(i, j int) { func (cfs CloudflareIPDataSet) Swap(i, j int) {
cfs[i], cfs[j] = cfs[j], cfs[i] cfs[i], cfs[j] = cfs[j], cfs[i]
} }
func (cfs CloudflareIPDataSetD) Len() int {
return len(cfs)
}
func (cfs CloudflareIPDataSetD) Less(i, j int) bool {
return cfs[i].downloadSpeed > cfs[j].downloadSpeed
}
func (cfs CloudflareIPDataSetD) Swap(i, j int) {
cfs[i], cfs[j] = cfs[j], cfs[i]
}