36 Commits

Author SHA1 Message Date
xiu2
9f2e5b5b5e add ipv6.txt 2020-11-30 18:10:41 +08:00
XIU2
7b4f6944be 优化 打印帮助时末尾换行(避免在命令行和下一行命令混在一起)
Merge pull request #13 from zhangsean/master
2020-11-30 17:10:07 +08:00
zhangsean
00b569d649 打印帮助换行 2020-11-30 17:05:07 +08:00
xiu2
4b4426c195 新增 IPv6 支持 2020-11-30 16:41:01 +08:00
xiu2
ff3a6d1d56 update 2020-11-25 12:31:57 +08:00
xiu2
a78c6e6270 update 2020-11-15 18:30:39 +08:00
xiu2
6b52fbf5ea update 2020-11-13 14:42:06 +08:00
xiu2
25fa4b65d8 优化 仅 Windows 系统才需要按下 回车键 或 Ctrl+C 退出 2020-11-12 08:11:38 +08:00
xiu2
dca761ec72 update 2020-11-11 22:56:53 +08:00
xiu2
0f5b18b305 update 2020-11-11 22:48:03 +08:00
xiu2
4e1678edc3 update 2020-11-11 19:35:47 +08:00
xiu2
65b451ec4d update 2020-11-11 19:28:14 +08:00
xiu2
72ecee9e26 update 2020-11-11 19:26:31 +08:00
xiu2
1d9f64a4a2 update 2020-11-11 18:19:12 +08:00
xiu2
40b22f660a 新增 指定延迟时间上限、下载速度下限条件 2020-11-11 18:10:53 +08:00
xiu2
12039f4850 修复 -p 0 时没有直接退出程序的问题;优化 代码 2020-11-10 21:03:09 +08:00
xiu2
129deeaf71 update 2020-11-10 19:50:43 +08:00
xiu2
3de6b38e00 优化 IP最后一段完全随机 2020-11-10 19:22:55 +08:00
xiu2
8c0e8732cc 新增 版本号标识 2020-11-10 15:55:52 +08:00
xiu2
8820c5f982 update 2020-11-10 15:35:24 +08:00
xiu2
d50c4806a6 调整 默认下载测速地址为自建地址 2020-11-08 16:46:27 +08:00
xiu2
306ce709c9 update 2020-11-08 10:48:24 +08:00
xiu2
956a35cab0 update 2020-11-08 10:43:26 +08:00
xiu2
3d49bb13ed update 2020-11-08 10:33:46 +08:00
xiu2
3ddd66b3c1 update 2020-11-07 10:38:36 +08:00
xiu2
9aa64db555 新增 自定义下载测速地址功能(-url https://xxx) 2020-11-07 10:07:00 +08:00
xiu2
9654cb8ea6 优化 下载测速文件大小 2020-11-06 12:32:23 +08:00
xiu2
13bae9c6f8 update 2020-11-06 10:01:35 +08:00
xiu2
f0fa3e4d0a update 2020-11-05 23:30:27 +08:00
xiu2
b83734b426 update 2020-11-05 23:26:18 +08:00
xiu2
c1348df16e update 2020-11-05 08:56:36 +08:00
xiu2
c52750ad9c update 2020-11-05 08:52:09 +08:00
xiu2
0e9461f3b7 update 2020-10-22 13:29:03 +08:00
xiu2
07e20028cc 修复 下载测速失效的问题 2020-10-07 02:27:56 +08:00
xiu2
4c92eae311 不输出结果文件 -o "" 改为 -o " " 2020-09-05 17:47:03 +08:00
xiu2
efdbc8f08e 优化直接输出结果排版;成功比率改为丢包率 2020-09-04 15:43:16 +08:00
6 changed files with 376 additions and 100 deletions

View File

@@ -21,16 +21,83 @@ func loadFirstIPOfRangeFromFile(ipFile string) []net.IPAddr {
if err != nil {
log.Fatal(err)
}
firstIP[15] = ipEndWith
for IPRange.Contains(firstIP) {
firstIPCopy := make([]byte, len(firstIP))
copy(firstIPCopy, firstIP)
firstIPs = append(firstIPs, net.IPAddr{IP: firstIPCopy})
firstIP[14]++
if firstIP[14] == 0 {
firstIP[13]++
if firstIP[13] == 0 {
firstIP[12]++
if ipv6Mode { // IPv6
var tempIP uint8
for IPRange.Contains(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])
firstIP[15] = randipEndWith() // 随机 IP 的最后一段
firstIP[14] = randipEndWith() // 随机 IP 的最后一段
firstIPCopy := make([]byte, len(firstIP))
copy(firstIPCopy, firstIP)
firstIPs = append(firstIPs, net.IPAddr{IP: firstIPCopy})
tempIP = firstIP[13]
firstIP[13] += randipEndWith()
if firstIP[13] < tempIP {
tempIP = firstIP[12]
firstIP[12] += randipEndWith()
if firstIP[12] < tempIP {
tempIP = firstIP[11]
firstIP[11] += randipEndWith()
if firstIP[11] < tempIP {
tempIP = firstIP[10]
firstIP[10] += randipEndWith()
if firstIP[10] < tempIP {
tempIP = firstIP[9]
firstIP[9] += randipEndWith()
if firstIP[9] < tempIP {
tempIP = firstIP[8]
firstIP[8] += randipEndWith()
if firstIP[8] < tempIP {
tempIP = firstIP[7]
firstIP[7] += randipEndWith()
if firstIP[7] < tempIP {
tempIP = firstIP[6]
firstIP[6] += randipEndWith()
if firstIP[6] < tempIP {
tempIP = firstIP[5]
firstIP[5] += randipEndWith()
if firstIP[5] < tempIP {
tempIP = firstIP[4]
firstIP[4] += randipEndWith()
if firstIP[4] < tempIP {
tempIP = firstIP[3]
firstIP[3] += randipEndWith()
if firstIP[3] < tempIP {
tempIP = firstIP[2]
firstIP[2] += randipEndWith()
if firstIP[2] < tempIP {
tempIP = firstIP[1]
firstIP[1] += randipEndWith()
if firstIP[1] < tempIP {
tempIP = firstIP[0]
firstIP[0] += randipEndWith()
}
}
}
}
}
}
}
}
}
}
}
}
}
}
} else { //IPv4
for IPRange.Contains(firstIP) {
firstIP[15] = randipEndWith() // 随机 IP 的最后一段 0.0.0.X
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
}
}
}
}

134
README.md
View File

@@ -9,30 +9,59 @@
国外很多网站都在使用 Cloudflare CDN但分配给中国访客的 IP 并不友好。
虽然 Cloudflare 公开了所有 [IP 段](https://www.cloudflare.com/ips/) ,但想要在这么多 IP 中找到适合自己的,怕是要累死,所以就有了这个软件。
该软件可以**测试 Cloudflare CDN 所有 IP 的延迟和速度,获得最快 IP**
你可以将 IP 添加到 `Hosts` 文件中,以提高访问使用 Cloudflare CDN 服务的国外网站速度!
该软件可以**测试 Cloudflare CDN 所有 IP 的延迟和速度,获得最快 IP**觉得好用请**点个⭐鼓励一下下~**
将 IP 添加到 `Hosts` 文件或 DNS 程序中,以提高访问使用 Cloudflare CDN 网站速度!
> 本项目也**适用于其他 CDN**,但是需要自行寻找 **CDN IP 段及下载测速地址**(否则只能延迟测速)!
****
### 快速使用
## 快速使用
1. 下载编译好的可执行文件 [蓝奏云](https://www.lanzoux.com/b0742hkxe) / [Github](https://github.com/XIU2/CloudflareSpeedTest/releases) 并解压。
2. 双击运行 `CloudflareST.exe`文件Windows系统等待测速...
### 下载运行
1. 下载编译好的可执行文件 [蓝奏云](https://xiu.lanzoux.com/b0742hkxe) / [Github](https://github.com/XIU2/CloudflareSpeedTest/releases) 并解压。
2. 双击运行 `CloudflareST.exe`文件Windows等待测速...
> **注意Linux 系统**请先赋予执行权限 `chmod +x CloudflareST` ,然后再执行 `./CloudflareST` 。
### 结果示例
测速完毕后,会直接显示**最快的 20 个 IP**,示例:
测速完毕后,会显示最快的 20 个 IP完整结果则保存在当前目录下的 `result.csv` 文件中,用记事本打开,排序为**延迟由低到高**,每一列用逗号分隔,分别是:
```
IP 地址, 测试次数, 成功次数, 成功比率, 平均延迟, 下载速度 (MB/s)
104.27.70.18, 4, 4, 1.00, 150.79, 12.89
IP 地址 已发送 已接收 丢包率 平均延迟 下载速度 (MB/s)
104.27.198.101 4 4 0.00 126.52 12.71
104.22.43.157 4 4 0.00 129.38 16.74
104.27.214.140 4 4 0.00 132.02 4.65
104.22.42.165 4 4 0.00 133.63 12.00
104.22.35.177 4 4 0.00 135.75 3.92
104.22.87.44 4 4 0.00 136.00 5.86
104.22.67.122 4 4 0.00 136.50 9.47
104.22.88.154 4 4 0.00 140.75 13.00
104.22.69.218 4 4 0.00 142.00 19.07
104.27.184.10 4 4 0.00 148.02 21.05
...
```
选择一个平均延迟与下载速度都不错的 IP 放到 `Hosts` 文件中(指向域名)。
完整结果保存在当前目录下的 `result.csv` 文件中,用**记事本/表格软件**打开,排序为**延迟由低到高**,分别是:
```
IP 地址, 已发送, 已接收, 丢包率, 平均延迟, 下载速度 (MB/s)
104.27.199.141, 4, 4, 0.00, 139.52, 11.71
```
> 大家可以按照自己的需求,对完整测速数据**进一步筛选处理**
选择一个平均延迟与下载速度都不错的 IP 放到 `Hosts` 文件中(指向使用 Cloudflare CDN 的网站域名)。
****
### 进阶使用
## 进阶使用
直接双击运行使用的是默认参数,如果想要测试速度更快、测试结果更全面,可以自定义参数。
``` cmd
C:\>CloudflareST.exe -h
CloudflareSpeedTest
CloudflareSpeedTest vX.X.X
测试 Cloudflare CDN 所有 IP 的延迟和速度,获取最快 IP
https://github.com/XIU2/CloudflareSpeedTest
@@ -45,59 +74,88 @@ https://github.com/XIU2/CloudflareSpeedTest
延迟测速端口;延迟测速 TCP 协议的端口;(默认 443)
-dn 20
下载测速数量;延迟测速并排序后,从最低延迟起下载测速数量,请勿太多(速度慢)(默认 20)
-dt 10
下载测速时间;单个 IP 测速最长时间,单位:秒;(默认 10)
-dt 5
下载测速时间;单个 IP 测速最长时间,单位:秒;(默认 5)
-url https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png
下载测速地址;用来 Cloudflare CDN 测速的文件地址,如含有空格请加上引号;
-tl 200
延迟时间上限;只输出指定延迟时间以下的结果,数量为 -dn 参数的值单位ms
-sl 5
下载速度下限;只输出指定下载速度以上的结果,数量为 -dn 参数的值单位MB/s
-p 20
直接显示结果;测速后直接显示指定数量的结果,为 -1 时不显示结果直接退出;(默认 20)
显示结果数量;测速后直接显示指定数量的结果,为 0 时不显示结果直接退出;(默认 20)
-f ip.txt
IP 数据文件;相对/绝对路径,如包含空格请加上引号;支持其他 CDN IP段记得禁用下载测速(默认 ip.txt)
IP 数据文件;如含有空格请加上引号;支持其他 CDN IP段记得禁用下载测速(默认 ip.txt)
-o result.csv
输出结果文件;相对/绝对路径,如包含空格请加上引号;为空时不输出结果文件( -o "" );允许其他后缀;(默认 result.csv)
输出结果文件;如含有空格请加上引号;为空时不输出结果文件(-o " ");允许其他后缀;(默认 result.csv)
-dd
禁用下载测速;如果带上该参数就是禁用下载测速;(默认 启用)
-ipv6
IPv6 测速模式;请确保 IP 数据文件内只包含 IPv6 IP段软件不支持同时测速 IPv4+IPv6(默认 IPv4)
-v
打印程序版本
-h
打印帮助说明
示例:
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -p 20 -f "ip.txt" -o "" -dd
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -f "ip.txt" -o "result.csv" -dd
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -f "C:\abc\ip.txt" -o "C:\abc\result.csv" -dd
```
#### 使用示例
> 如果**下载速度都是 0.00**,那说明默认的**下载测速地址**用的人太多又到上限了,**请去这个 [Issues](https://github.com/XIU2/CloudflareSpeedTest/issues/6) 获得解决方法!**
### 使用示例
在 CMD 中运行,或者把启动参数添加到快捷方式中。
> **注意:** 不需要加上所有参数,按需选择,参数前后顺序随意。
``` cmd
# CMD 示例
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10
``` bash
# 命令行示例
# 注意:各参数均有默认值,只有不使用默认值时,才需要手动指定参数的值(按需选择),参数不分前后顺序。
# 提示: Linux 系统只需要把下面命令中的 CloudflareST.exe 改为 ./CloudflareST 即可。
# 指定 IP数据文件输出结果文件,直接显示结果(-p 20 条
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -p 20 -f "ip.txt" -o "" -dd
# 指定 IPv4 数据文件,不显示结果直接退出(-p 值为 0
CloudflareST.exe -p 0 -f ip.txt -dd
# 指定 IP数据文件 及 输出结果文件(相对路径,即当前目录下
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -f "ip.txt" -o "result.csv" -dd
# 指定 IPv6 数据文件( ipv6.txt ),不显示结果直接退出(-p 值为 0
CloudflareST.exe -p 0 -f ipv6.txt -dd -ipv6
# 指定 IP数据文件输出结果文件(绝对路径,即 C:\abc\ 目录下
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -f "C:\abc\ip.txt" -o "C:\abc\result.csv" -dd
# 指定 IPv4 数据文件,不输出结果文件,直接显示结果(-p 值为 10 条
CloudflareST.exe -p 10 -f ip.txt -o " " -dd
# 指定 IPv4 数据文件 及 输出结果到文件(相对路径,即当前目录下,如果包含空格请加上引号)
CloudflareST.exe -f ip.txt -o result.csv -dd
# 指定 IPv4 数据文件 及 输出结果到文件(绝对路径,即 C:\abc\ 目录下,如果包含空格请加上引号)
CloudflareST.exe -f C:\abc\ip.txt -o C:\abc\result.csv -dd
# 指定下载测速地址(要求:可以直接下载、文件大小超过 200MB、用的是 Cloudflare CDN如果包含空格请加上引号
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 个
CloudflareST.exe -sl 5 -dn 10
# 延迟时间上限200 ms下载速度下限5 MB/s数量10 个
CloudflareST.exe -tl 200 -sl 5 -dn 10
# 如果一直凑不够指定数量,会一直测速下去。
# 建议指定下载速度下限时,同时指定延迟时间上限,如果测试到指定延迟还没凑够数,就会终止测速。
# 如果一个满足条件的 IP 都没有,那么就会正常输出结果(和不指定条件一样)。
# 如果你需要通过外部程序进一步筛选处理,那么只需要判断测速结果数量,如果上千个说明一个满足条件的 IP 都没有。
```
``` cmd
# 快捷方式示例(右键快捷方式 - 目标)
# Windows 快捷方式示例(右键快捷方式 - 目标)
## 如果有引号就放在引号外面,记得引号和 - 之间有空格。
"D:\Program Files\CloudflareST\CloudflareST.exe" -n 500 -t 4 -dn 20 -dt 10
### 如果要不输出结果文件,那么请加上 -o " ",引号里的是空格。
"D:\Program Files\CloudflareST\CloudflareST.exe" -n 500 -t 4 -dn 20 -dt 5
```
****
### 感谢项目
## 感谢项目
* https://github.com/Spedoske/CloudflareScanner
意外发现了这个项目,看了之后发现正好解决了我的问题,但是我更喜欢用户命令行方式运行,这样会更方便、有更多使用姿势,于是我临时学了下 Golang 并 Fork 修改了一份命令行方式交互的版本,如果有什么问题可以告诉我,虽然我不一定会~
意外发现了这个项目,看了之后发现正好解决了我的问题,但是我更喜欢用户命令行方式运行,这样会更方便、有更多使用姿势,于是我临时学了下 Golang 并 Fork 按照我自己的需求修改了一下(包括但不限于命令行方式交互、直接输出结果等),如果有什么问题可以告诉我,虽然我不一定会~
****
### 许可证
## 许可证
The GPL-3.0 License.

42
ipv6.txt Normal file
View File

@@ -0,0 +1,42 @@
2606:4700:10::6814:0/112
2606:4700:10::ac43:0/112
2606:4700:3000::/48
2606:4700:3001::/48
2606:4700:3002::/48
2606:4700:3003::/48
2606:4700:3004::/48
2606:4700:3005::/48
2606:4700:3006::/48
2606:4700:3007::/48
2606:4700:3008::/48
2606:4700:3009::/48
2606:4700:3010::/48
2606:4700:3011::/48
2606:4700:3012::/48
2606:4700:3013::/48
2606:4700:3014::/48
2606:4700:3015::/48
2606:4700:3016::/48
2606:4700:3017::/48
2606:4700:3018::/48
2606:4700:3019::/48
2606:4700:3020::/48
2606:4700:3021::/48
2606:4700:3022::/48
2606:4700:3023::/48
2606:4700:3024::/48
2606:4700:3025::/48
2606:4700:3026::/48
2606:4700:3027::/48
2606:4700:3028::/48
2606:4700:3029::/48
2606:4700:3030::/48
2606:4700:3031::/48
2606:4700:3032::/48
2606:4700:3033::/48
2606:4700:3034::/48
2606:4700:3035::/48
2606:4700:3036::/48
2606:4700:3037::/48
2606:4700:3038::/48
2606:4700:3039::/48

155
main.go
View File

@@ -4,6 +4,7 @@ import (
"flag"
"fmt"
"os"
"runtime"
"sort"
"strconv"
"sync"
@@ -14,16 +15,19 @@ import (
var version string
var disableDownload bool
var ipv6Mode bool
var tcpPort int
var ipFile string
var outputFile string
var printResult int
var printResultNum int
var timeLimit int
var speedLimit int
func init() {
var downloadSecond int64
var printVersion bool
const help = `
CloudflareSpeedTest
var help = `
CloudflareSpeedTest ` + version + `
测试 Cloudflare CDN 所有 IP 的延迟和速度,获取最快 IP
https://github.com/XIU2/CloudflareSpeedTest
@@ -36,34 +40,41 @@ https://github.com/XIU2/CloudflareSpeedTest
延迟测速端口;延迟测速 TCP 协议的端口;(默认 443)
-dn 20
下载测速数量;延迟测速并排序后,从最低延迟起下载测速数量,请勿太多(速度慢)(默认 20)
-dt 10
下载测速时间;单个 IP 测速最长时间,单位:秒;(默认 10)
-dt 5
下载测速时间;单个 IP 测速最长时间,单位:秒;(默认 5)
-url https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png
下载测速地址;用来 Cloudflare CDN 测速的文件地址,如含有空格请加上引号;
-tl 200
延迟时间上限;只输出指定延迟时间以下的结果,数量为 -dn 参数的值单位ms
-sl 5
下载速度下限;只输出指定下载速度以上的结果,数量为 -dn 参数的值单位MB/s
-p 20
直接显示结果;测速后直接显示指定数量的结果,为 -1 时不显示结果直接退出;(默认 20)
显示结果数量;测速后直接显示指定数量的结果,0 时不显示结果直接退出;(默认 20)
-f ip.txt
IP 数据文件;相对/绝对路径,如包含空格请加上引号;支持其他 CDN IP段记得禁用下载测速(默认 ip.txt)
IP 数据文件;如含有空格请加上引号;支持其他 CDN IP段记得禁用下载测速(默认 ip.txt)
-o result.csv
输出结果文件;相对/绝对路径,如包含空格请加上引号;为空时不输出结果文件( -o "" );允许其他后缀;(默认 result.csv)
输出结果文件;如含有空格请加上引号;为空时不输出结果文件(-o " ");允许其他后缀;(默认 result.csv)
-dd
禁用下载测速;如果带上该参数就是禁用下载测速;(默认 启用)
禁用下载测速;如果带上该参数就是禁用下载测速;(默认 启用下载测速)
-ipv6
IPv6 测速模式;请确保 IP 数据文件内只包含 IPv6 IP段软件不支持同时测速 IPv4+IPv6(默认 IPv4)
-v
打印程序版本
-h
打印帮助说明
示例:
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -p 20 -f "ip.txt" -o "" -dd
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -f "ip.txt" -o "result.csv" -dd
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -f "C:\abc\ip.txt" -o "C:\abc\result.csv" -dd`
`
flag.IntVar(&pingRoutine, "n", 500, "测速线程数量")
flag.IntVar(&pingTime, "t", 4, "延迟测速次数")
flag.IntVar(&tcpPort, "tp", 443, "延迟测速端口")
flag.IntVar(&downloadTestCount, "dn", 20, "下载测速数量")
flag.Int64Var(&downloadSecond, "dt", 10, "下载测速时间")
flag.IntVar(&printResult, "p", 20, "直接显示结果")
flag.Int64Var(&downloadSecond, "dt", 5, "下载测速时间")
flag.StringVar(&url, "url", "https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png", "下载测速地址")
flag.IntVar(&timeLimit, "tl", 0, "延迟时间上限")
flag.IntVar(&speedLimit, "sl", 0, "下载速度下限")
flag.IntVar(&printResultNum, "p", 20, "显示结果数量")
flag.BoolVar(&disableDownload, "dd", false, "禁用下载测速")
flag.BoolVar(&ipv6Mode, "ipv6", false, "禁用下载测速")
flag.StringVar(&ipFile, "f", "ip.txt", "IP 数据文件")
flag.StringVar(&outputFile, "o", "result.csv", "输出结果文件")
flag.BoolVar(&printVersion, "v", false, "打印程序版本")
@@ -91,25 +102,43 @@ https://github.com/XIU2/CloudflareSpeedTest
if downloadSecond <= 0 {
downloadSecond = 10
}
if printResult == 0 {
printResult = 20
if url == "" {
url = "https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png"
}
if timeLimit <= 0 {
timeLimit = 9999
}
if speedLimit < 0 {
speedLimit = 0
}
if printResultNum < 0 {
printResultNum = 20
}
if ipFile == "" {
ipFile = "ip.txt"
}
if outputFile == " " {
outputFile = ""
}
}
func main() {
initipEndWith() // 随机数
initRandSeed() // 随机数种子
failTime = pingTime // 设置接收次数
ips := loadFirstIPOfRangeFromFile(ipFile) // 读入IP
pingCount := len(ips) * pingTime // 计算进度条总数IP*测试次数)
bar := pb.Full.Start(pingCount) // 进度条总数
bar := pb.Simple.Start(pingCount) // 进度条总数
var wg sync.WaitGroup
var mu sync.Mutex
var data = make([]CloudflareIPData, 0)
var data_2 = make([]CloudflareIPData, 0)
fmt.Println("开始延迟测速模式TCP端口" + strconv.Itoa(tcpPort) + "")
fmt.Println("# XIU2/CloudflareSpeedTest " + version + "\n")
if ipv6Mode {
fmt.Println("开始延迟测速模式TCP IPv6端口" + strconv.Itoa(tcpPort) + "")
} else {
fmt.Println("开始延迟测速模式TCP IPv4端口" + strconv.Itoa(tcpPort) + "")
}
control := make(chan bool, pingRoutine)
for _, ip := range ips {
wg.Add(1)
@@ -126,15 +155,30 @@ func main() {
if !disableDownload { // 如果禁用下载测速就跳过
if len(data) > 0 { // IP数组长度(IP数量) 大于 0 时继续
if len(data) < downloadTestCount { // 如果IP数组长度(IP数量) 小于 下载测速次数则次数改为IP数
//fmt.Println("\n[信息] IP 数量小于下载测速次数(" + strconv.Itoa(downloadTestCount) + " < " + strconv.Itoa(len(data)) + "下载测速次数改为IP数。\n")
downloadTestCount = len(data)
fmt.Println("\n[信息] IP数量小于下载测速次数下载测速次数改为IP数。\n")
}
bar = pb.Simple.Start(downloadTestCount)
fmt.Println("开始下载测速:")
for i := 0; i < downloadTestCount; i++ {
var downloadTestCount_2 int // 临时的下载测速次数
if timeLimit == 9999 && speedLimit == 0 {
downloadTestCount_2 = downloadTestCount // 如果没有指定条件,则临时的下载次数变量为下载测速次数
fmt.Println("开始下载测速:")
} else if timeLimit > 0 || speedLimit >= 0 {
downloadTestCount_2 = len(data) // 如果指定了任意一个条件,则临时的下载次数变量改为总数量
fmt.Println("开始下载测速(延迟时间上限:" + strconv.Itoa(timeLimit) + " ms下载速度下限" + strconv.Itoa(speedLimit) + " MB/s")
}
bar = pb.Simple.Start(downloadTestCount_2)
for i := 0; i < downloadTestCount_2; i++ {
_, speed := DownloadSpeedHandler(data[i].ip)
data[i].downloadSpeed = speed
bar.Add(1)
if int(data[i].pingTime) <= timeLimit && int(float64(speed)/1024/1024) >= speedLimit {
data_2 = append(data_2, data[i]) // 延迟和速度均满足条件时,添加到新数组中
if len(data_2) == downloadTestCount { // 满足条件的 IP =下载测速次数,则跳出循环
break
}
} else if int(data[i].pingTime) > timeLimit {
break
}
}
bar.Finish()
} else {
@@ -142,31 +186,58 @@ func main() {
}
}
if outputFile != "" {
ExportCsv(outputFile, data) // 输出结果到文件
if len(data_2) > 0 { // 如果该数字有内容,说明进行过指定条件的下载测速
if outputFile != "" {
ExportCsv(outputFile, data_2) // 输出结果到文件(指定延迟时间或下载速度的)
}
printResult(data_2) // 显示最快结果(指定延迟时间或下载速度的)
} else {
if outputFile != "" {
ExportCsv(outputFile, data) // 输出结果到文件
}
printResult(data) // 显示最快结果
}
}
// 直接输出结果
if printResult > 0 { // 如果禁用下载测速就跳过
// 显示最快结果
func printResult(data []CloudflareIPData) {
sysType := runtime.GOOS
if printResultNum > 0 { // 如果禁止直接输出结果就跳过
dateString := convertToString(data) // 转为多维数组 [][]String
if len(dateString) > 0 { // IP数组长度(IP数量) 大于 0 时继续
if len(dateString) < printResult { // 如果IP数组长度(IP数量) 小于 打印次数则次数改为IP数量
printResult = len(dateString)
fmt.Println("\n[信息] IP数量小于显示结果数量显示结果数量改为IP数量。\n")
if len(dateString) < printResultNum { // 如果IP数组长度(IP数量) 小于 打印次数则次数改为IP数量
//fmt.Println("\n[信息] IP 数量小于显示结果数量(" + strconv.Itoa(printResultNum) + " < " + strconv.Itoa(len(dateString)) + "显示结果数量改为IP数量。\n")
printResultNum = len(dateString)
}
fmt.Println("\nIP 地址 \t", "测试次数\t", "成功次数\t", "成功比率\t", "平均延迟\t", "下载速度 (MB/s)")
for i := 0; i < printResult; i++ {
fmt.Println(dateString[i][0], "\t", dateString[i][1], "\t\t", dateString[i][2], "\t\t", dateString[i][3], "\t\t", dateString[i][4], "\t", dateString[i][5])
}
if outputFile != "" {
fmt.Printf("\n完整内容请查看 %v 文件。请按 回车键 或 Ctrl+C 退出。", outputFile)
if ipv6Mode { // IPv6 太长了,所以需要调整一下间隔
fmt.Printf("%-40s%-5s%-5s%-5s%-6s%-11s\n", "IP 地址", "已发送", "已接收", "丢包率", "平均延迟", "下载速度 (MB/s)")
for i := 0; i < printResultNum; i++ {
fmt.Printf("%-42s%-8s%-8s%-8s%-10s%-15s\n", ipPadding(dateString[i][0]), dateString[i][1], dateString[i][2], dateString[i][3], dateString[i][4], dateString[i][5])
}
} else {
fmt.Printf("\n请按 回车键 或 Ctrl+C 退出。")
fmt.Printf("%-16s%-5s%-5s%-5s%-6s%-11s\n", "IP 地址", "已发送", "已接收", "丢包率", "平均延迟", "下载速度 (MB/s)")
for i := 0; i < printResultNum; i++ {
fmt.Printf("%-18s%-8s%-8s%-8s%-10s%-15s\n", ipPadding(dateString[i][0]), dateString[i][1], dateString[i][2], dateString[i][3], dateString[i][4], dateString[i][5])
}
}
if sysType == "windows" { // 如果是 Windows 系统,则需要按下 回车键 或 Ctrl+C 退出
if outputFile != "" {
fmt.Printf("\n完整测速结果已写入 %v 文件,请使用记事本/表格软件查看。\n按下 回车键 或 Ctrl+C 退出。", outputFile)
} else {
fmt.Printf("\n按下 回车键 或 Ctrl+C 退出。")
}
var pause int
fmt.Scanln(&pause)
} else { // 其它系统直接退出
if outputFile != "" {
fmt.Println("\n完整测速结果已写入 " + outputFile + " 文件,请使用记事本/表格软件查看。")
}
}
var pause int
fmt.Scanln(&pause)
} else {
fmt.Println("\n[信息] IP数量为 0跳过输出结果。")
}
} else {
fmt.Println("\n完整测速结果已写入 " + outputFile + " 文件,请使用记事本/表格软件查看。")
}
}

View File

@@ -15,7 +15,13 @@ import (
//bool connectionSucceed float32 time
func tcping(ip net.IPAddr, tcpPort int) (bool, float32) {
startTime := time.Now()
conn, err := net.DialTimeout("tcp", ip.String()+":"+strconv.Itoa(tcpPort), tcpConnectTimeout)
var fullAddress string
if ipv6Mode { // IPv6 需要加上 []
fullAddress = "[" + ip.String() + "]:" + strconv.Itoa(tcpPort)
} else {
fullAddress = ip.String() + ":" + strconv.Itoa(tcpPort)
}
conn, err := net.DialTimeout("tcp", fullAddress, tcpConnectTimeout)
if err != nil {
return false, 0
} else {
@@ -107,8 +113,14 @@ func DownloadSpeedHandler(ip net.IPAddr) (bool, float32) {
Jar: nil,
Timeout: 0,
}
var fullAddress string
if ipv6Mode { // IPv6 需要加上 []
fullAddress = "[" + ip.String() + "]:443"
} else {
fullAddress = ip.String() + ":443"
}
client.Transport = &http.Transport{
DialContext: GetDialContextByAddr(ip.String() + ":443"),
DialContext: GetDialContextByAddr(fullAddress),
}
response, err := client.Get(url)

42
util.go
View File

@@ -23,7 +23,8 @@ type CloudflareIPData struct {
func (cf *CloudflareIPData) getRecvRate() float32 {
if cf.recvRate == 0 {
cf.recvRate = float32(cf.pingReceived) / float32(cf.pingCount)
pingLost := cf.pingCount - cf.pingReceived
cf.recvRate = float32(pingLost) / float32(cf.pingCount)
}
return cf.recvRate
}
@@ -36,7 +37,7 @@ func ExportCsv(filePath string, data []CloudflareIPData) {
}
defer fp.Close()
w := csv.NewWriter(fp) //创建一个新的写入文件流
w.Write([]string{"IP 地址", "测试次数", "成功次数", "成功比率", "平均延迟", "下载速度 (MB/s)"})
w.Write([]string{"IP 地址", "已发送", "已接收", "丢包率", "平均延迟", "下载速度 (MB/s)"})
w.WriteAll(convertToString(data))
w.Flush()
}
@@ -63,8 +64,6 @@ func convertToString(data []CloudflareIPData) [][]string {
var pingTime int
var pingRoutine int
var ipEndWith uint8 = 0
type progressEvent int
const (
@@ -73,7 +72,7 @@ const (
NormalPing
)
const url string = "https://apple.freecdn.workers.dev/105/media/us/iphone-11-pro/2019/3bd902e4-0752-4ac1-95f8-6225c32aec6d/films/product/iphone-11-pro-product-tpl-cc-us-2019_1280x720h.mp4"
var url string
var downloadTestTime time.Duration
@@ -88,9 +87,36 @@ var failTime int
type CloudflareIPDataSet []CloudflareIPData
func initipEndWith() {
func initRandSeed() {
rand.Seed(time.Now().UnixNano())
ipEndWith = uint8(rand.Intn(254) + 1)
}
func randipEndWith() uint8 {
return uint8(rand.Intn(254) + 1)
}
func GetRandomString() string {
str := "0123456789abcdef"
bytes := []byte(str)
result := []byte{}
r := rand.New(rand.NewSource(time.Now().UnixNano()))
for i := 0; i < 4; i++ {
result = append(result, bytes[r.Intn(len(bytes))])
}
return string(result)
}
func ipPadding(ip string) string {
var ipLength int
var ipPrint string
ipPrint = ip
ipLength = len(ipPrint)
if ipLength < 15 {
for i := 0; i <= 15-ipLength; i++ {
ipPrint += " "
}
}
return ipPrint
}
func handleProgressGenerator(pb *pb.ProgressBar) func(e progressEvent) {
@@ -112,7 +138,7 @@ func (cfs CloudflareIPDataSet) Len() int {
func (cfs CloudflareIPDataSet) Less(i, j int) bool {
if (cfs)[i].getRecvRate() != cfs[j].getRecvRate() {
return cfs[i].getRecvRate() > cfs[j].getRecvRate()
return cfs[i].getRecvRate() < cfs[j].getRecvRate()
}
return cfs[i].pingTime < cfs[j].pingTime
}