21 Commits

Author SHA1 Message Date
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
xiu2
e85a03c651 新增 自定义TCP端口 功能等 2020-09-03 20:07:15 +08:00
xiu2
5d00d7c5ff 新增 自定义TCP端口 功能。 2020-09-03 19:36:09 +08:00
5 changed files with 144 additions and 73 deletions

View File

@@ -21,8 +21,9 @@ func loadFirstIPOfRangeFromFile(ipFile string) []net.IPAddr {
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }
firstIP[15] = ipEndWith
for IPRange.Contains(firstIP) { for IPRange.Contains(firstIP) {
randipEndWith() // 随机 IP 的最后一段
firstIP[15] = ipEndWith
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})

View File

@@ -10,25 +10,52 @@
虽然 Cloudflare 公开了所有 [IP 段](https://www.cloudflare.com/ips/) ,但想要在这么多 IP 中找到适合自己的,怕是要累死,所以就有了这个软件。 虽然 Cloudflare 公开了所有 [IP 段](https://www.cloudflare.com/ips/) ,但想要在这么多 IP 中找到适合自己的,怕是要累死,所以就有了这个软件。
该软件可以**测试 Cloudflare CDN 所有 IP 的延迟和速度,获得最快 IP** 该软件可以**测试 Cloudflare CDN 所有 IP 的延迟和速度,获得最快 IP**
你可以将 IP 添加到 `Hosts` 文件中,以提高访问使用 Cloudflare CDN 服务的国外网站速度! 你可以将 IP 添加到 `Hosts` 文件中,以提高访问使用 Cloudflare CDN 网站速度!
**** ****
### 快速使用 ## 快速使用
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**,示例:
测速完毕后,会把结果保存在当前目录下的 `result.csv` 文件中,用记事本打开,排序为**延迟由低到高**,每一列用逗号分隔,分别是:
``` ```
IP 地址, 测试次数, 成功次数, 成功比率, 平均延迟, 下载速度 (MB/s) IP 地址 已发送 已接收 丢包率 平均延迟 下载速度 (MB/s)
104.27.70.18, 4, 4, 1.00, 150.79, 12.89 104.27.199.141 4 4 0.00 139.52 11.71
104.22.73.158 4 4 0.00 141.38 6.74
104.27.204.240 4 4 0.00 142.02 4.65
104.22.72.117 4 4 0.00 143.63 12.00
104.22.75.117 4 4 0.00 145.75 3.92
104.22.77.24 4 4 0.00 146.00 5.86
104.22.66.140 4 4 0.00 146.50 9.47
104.22.78.104 4 4 0.00 146.75 13.00
104.22.69.208 4 4 0.00 147.00 19.07
104.27.194.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 的网站域名)。
**** ****
### 进阶使用 ## 进阶使用
直接双击运行使用的是默认参数,如果想要测试速度更快、测试结果更全面,可以自定义参数。 直接双击运行使用的是默认参数,如果想要测试速度更快、测试结果更全面,可以自定义参数。
> **提示Linux 系统**只需要把下面命令中的 **.exe 删除**即可通用。
``` cmd ``` cmd
C:\>CloudflareST.exe -h C:\>CloudflareST.exe -h
@@ -41,57 +68,68 @@ https://github.com/XIU2/CloudflareSpeedTest
测速线程数量;数值越大速度越快,请勿超过 1000(结果误差大)(默认 500) 测速线程数量;数值越大速度越快,请勿超过 1000(结果误差大)(默认 500)
-t 4 -t 4
延迟测速次数;单个 IP 测速次数,为 1 时将过滤丢包的IPTCP协议(默认 4) 延迟测速次数;单个 IP 测速次数,为 1 时将过滤丢包的IPTCP协议(默认 4)
-tp 443
延迟测速端口;延迟测速 TCP 协议的端口;(默认 443)
-dn 20 -dn 20
下载测速数量;延迟测速并排序后,从最低延迟起下载测速数量,请勿太多(速度慢)(默认 20) 下载测速数量;延迟测速并排序后,从最低延迟起下载测速数量,请勿太多(速度慢)(默认 20)
-dt 10 -dt 5
下载测速时间;单个 IP 测速最长时间,单位:秒;(默认 10) 下载测速时间;单个 IP 测速最长时间,单位:秒;(默认 5)
-url https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png
下载测速地址;用来 Cloudflare CDN 测速的文件地址,如含有空格请加上引号;
-p 20 -p 20
直接显示结果;测速后直接显示指定数量的结果,为 -1 时不显示结果直接退出;(默认 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
输出结果文件;相对/绝对路径,如包含空格请加上引号;允许 .txt 等后缀;(默认 result.csv) 输出结果文件;如含有空格请加上引号;为空格时不输出结果文件(-o " ");允许其他后缀;(默认 result.csv)
-dd -dd
禁用下载测速;如果带上该参数就是禁用下载测速;(默认 启用) 禁用下载测速;如果带上该参数就是禁用下载测速;(默认 启用)
-v -v
打印程序版本 打印程序版本
-h -h
打印帮助说明 打印帮助说明
示例:
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -p 20
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -p -1 -f "ip.txt" -o "result.csv" -dd
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -p -1 -f "C:\abc\ip.txt" -o "C:\abc\result.csv" -dd
``` ```
#### 使用示例 > 如果**下载速度都是 0.00**,那说明默认的**下载测速地址**用的人太多又到上限了,**请去这个 [Issues](https://github.com/XIU2/CloudflareSpeedTest/issues/6) 获得解决方法!**
### 使用示例
在 CMD 中运行,或者把启动参数添加到快捷方式中。 在 CMD 中运行,或者把启动参数添加到快捷方式中。
> **注意:** 不需要加上所有参数,按需选择,参数前后顺序随意。 > **注意:** 不需要加上所有参数,按需选择,参数前后顺序随意。
> **提示: Linux 系统**只需要把下面命令中的 **.exe 删除**即可通用。
``` cmd ``` cmd
# CMD 示例 # 命令行示例
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -p 20 CloudflareST.exe -n 500 -t 4 -dn 20 -dt 5
# 指定 IP数据文件 及 输出结果文件(相对路径,即当前目录下 # 指定 IP数据文件,不显示结果直接退出(-p 值为 0
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -p -1 -f "ip.txt" -o "result.csv" -dd CloudflareST.exe -n 500 -t 4 -dn 20 -dt 5 -p 0 -f "ip.txt" -dd
# 指定 IP数据文件输出结果文件(绝对路径,即 C:\abc\ 目录下 # 指定 IP数据文件,不输出结果文件,直接显示结果(-p 值为 20 条
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -p -1 -f "C:\abc\ip.txt" -o "C:\abc\result.csv" -dd CloudflareST.exe -n 500 -t 4 -dn 20 -dt 5 -p 20 -f "ip.txt" -o " " -dd
# 指定 IP数据文件 及 输出结果到文件(相对路径,即当前目录下,如果包含空格请加上引号)
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 5 -f ip.txt -o result.csv -dd
# 指定 IP数据文件 及 输出结果到文件(绝对路径,即 C:\abc\ 目录下,如果包含空格请加上引号)
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 5 -f C:\abc\ip.txt -o C:\abc\result.csv -dd
# 指定下载测速地址(要求:可以直接下载的文件、文件大小超过 200MB、网站用的是 Cloudflare CDN如果包含空格请加上引号
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 5 -url https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png
``` ```
``` cmd ``` cmd
# 快捷方式示例(右键快捷方式 - 目标) # 快捷方式示例(右键快捷方式 - 目标)
## 如果有引号就放在引号外面,记得引号和 - 之间有空格。 ## 如果有引号就放在引号外面,记得引号和 - 之间有空格。
"D:\Program Files\CloudflareST\CloudflareST.exe" -n 500 -t 4 -dn 20 -dt 10 -p 20 "D:\Program Files\CloudflareST\CloudflareST.exe" -n 500 -t 4 -dn 20 -dt 5
``` ```
**** ****
### 感谢项目 ## 感谢项目
* https://github.com/Spedoske/CloudflareScanner * https://github.com/Spedoske/CloudflareScanner
意外发现了这个项目,看了之后发现正好解决了我的问题,但是我更喜欢用户命令行方式运行,这样会更方便、有更多使用姿势,于是我临时学了下 Golang 并 Fork 修改了一份命令行方式交互的版本,如果有什么问题可以告诉我,虽然我不一定会~ 意外发现了这个项目,看了之后发现正好解决了我的问题,但是我更喜欢用户命令行方式运行,这样会更方便、有更多使用姿势,于是我临时学了下 Golang 并 Fork 按照我自己的需求修改了一下(包括但不限于命令行方式交互、直接输出结果等),如果有什么问题可以告诉我,虽然我不一定会~
**** ****
### 许可证 ## 许可证
The GPL-3.0 License. The GPL-3.0 License.

69
main.go
View File

@@ -5,6 +5,7 @@ import (
"fmt" "fmt"
"os" "os"
"sort" "sort"
"strconv"
"sync" "sync"
"time" "time"
@@ -13,6 +14,7 @@ import (
var version string var version string
var disableDownload bool var disableDownload bool
var tcpPort int
var ipFile string var ipFile string
var outputFile string var outputFile string
var printResult int var printResult int
@@ -20,8 +22,8 @@ var printResult int
func init() { func init() {
var downloadSecond int64 var downloadSecond int64
var printVersion bool var printVersion bool
const help = ` var help = `
CloudflareSpeedTest CloudflareSpeedTest ` + version + `
测试 Cloudflare CDN 所有 IP 的延迟和速度,获取最快 IP 测试 Cloudflare CDN 所有 IP 的延迟和速度,获取最快 IP
https://github.com/XIU2/CloudflareSpeedTest https://github.com/XIU2/CloudflareSpeedTest
@@ -30,33 +32,34 @@ https://github.com/XIU2/CloudflareSpeedTest
测速线程数量;数值越大速度越快,请勿超过 1000(结果误差大)(默认 500) 测速线程数量;数值越大速度越快,请勿超过 1000(结果误差大)(默认 500)
-t 4 -t 4
延迟测速次数;单个 IP 测速次数,为 1 时将过滤丢包的IPTCP协议(默认 4) 延迟测速次数;单个 IP 测速次数,为 1 时将过滤丢包的IPTCP协议(默认 4)
-tp 443
延迟测速端口;延迟测速 TCP 协议的端口;(默认 443)
-dn 20 -dn 20
下载测速数量;延迟测速并排序后,从最低延迟起下载测速数量,请勿太多(速度慢)(默认 20) 下载测速数量;延迟测速并排序后,从最低延迟起下载测速数量,请勿太多(速度慢)(默认 20)
-dt 10 -dt 5
下载测速时间;单个 IP 测速最长时间,单位:秒;(默认 10) 下载测速时间;单个 IP 测速最长时间,单位:秒;(默认 5)
-url https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png
下载测速地址;用来 Cloudflare CDN 测速的文件地址,如含有空格请加上引号;
-p 20 -p 20
直接显示结果;测速后直接显示指定数量的结果,为 -1 时不显示结果直接退出;(默认 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
输出结果文件;相对/绝对路径,如包含空格请加上引号;允许 .txt 等后缀;(默认 result.csv) 输出结果文件;如含有空格请加上引号;为空格时不输出结果文件(-o " ");允许其他后缀;(默认 result.csv)
-dd -dd
禁用下载测速;如果带上该参数就是禁用下载测速;(默认 启用) 禁用下载测速;如果带上该参数就是禁用下载测速;(默认 启用)
-v -v
打印程序版本 打印程序版本
-h -h
打印帮助说明 打印帮助说明`
示例:
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -p 20
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -p -1 -f "ip.txt" -o "result.csv" -dd
CloudflareST.exe -n 500 -t 4 -dn 20 -dt 10 -p -1 -f "C:\abc\ip.txt" -o "C:\abc\result.csv" -dd`
flag.IntVar(&pingRoutine, "n", 500, "测速线程数量") flag.IntVar(&pingRoutine, "n", 500, "测速线程数量")
flag.IntVar(&pingTime, "t", 4, "延迟测速次数") flag.IntVar(&pingTime, "t", 4, "延迟测速次数")
flag.IntVar(&tcpPort, "tp", 443, "延迟测速端口")
flag.IntVar(&downloadTestCount, "dn", 20, "下载测速数量") flag.IntVar(&downloadTestCount, "dn", 20, "下载测速数量")
flag.Int64Var(&downloadSecond, "dt", 10, "下载测速时间") flag.Int64Var(&downloadSecond, "dt", 5, "下载测速时间")
flag.IntVar(&printResult, "p", 20, "直接显示结果") flag.StringVar(&url, "url", "https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png", "下载测速地址")
flag.IntVar(&printResult, "p", 20, "显示结果数量")
flag.BoolVar(&disableDownload, "dd", false, "禁用下载测速") flag.BoolVar(&disableDownload, "dd", false, "禁用下载测速")
flag.StringVar(&ipFile, "f", "ip.txt", "IP 数据文件") flag.StringVar(&ipFile, "f", "ip.txt", "IP 数据文件")
flag.StringVar(&outputFile, "o", "result.csv", "输出结果文件") flag.StringVar(&outputFile, "o", "result.csv", "输出结果文件")
@@ -76,40 +79,47 @@ https://github.com/XIU2/CloudflareSpeedTest
if pingTime <= 0 { if pingTime <= 0 {
pingTime = 4 pingTime = 4
} }
if tcpPort < 1 || tcpPort > 65535 {
tcpPort = 443
}
if downloadTestCount <= 0 { if downloadTestCount <= 0 {
downloadTestCount = 20 downloadTestCount = 20
} }
if downloadSecond <= 0 { if downloadSecond <= 0 {
downloadSecond = 10 downloadSecond = 10
} }
if url == "" {
url = "https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png"
}
if printResult == 0 { if printResult == 0 {
printResult = 20 printResult = 20
} }
if ipFile == "" { if ipFile == "" {
ipFile = "ip.txt" ipFile = "ip.txt"
} }
if outputFile == "" { if outputFile == " " {
outputFile = "result.csv" outputFile = ""
} }
} }
func main() { func main() {
initipEndWith() // 随机数 initRandSeed() // 随机数种子
failTime = pingTime // 设置接收次数 failTime = pingTime // 设置接收次数
ips := loadFirstIPOfRangeFromFile(ipFile) // 读入IP ips := loadFirstIPOfRangeFromFile(ipFile) // 读入IP
pingCount := len(ips) * pingTime // 计算进度条总数IP*测试次数) pingCount := len(ips) * pingTime // 计算进度条总数IP*测试次数)
bar := pb.Full.Start(pingCount) // 进度条总数 bar := pb.Simple.Start(pingCount) // 进度条总数
var wg sync.WaitGroup var wg sync.WaitGroup
var mu sync.Mutex var mu sync.Mutex
var data = make([]CloudflareIPData, 0) var data = make([]CloudflareIPData, 0)
fmt.Println("开始延迟测速(TCP)") fmt.Println("# XIU2/CloudflareSpeedTest " + version + "\n")
fmt.Println("开始延迟测速模式TCP端口" + strconv.Itoa(tcpPort) + "")
control := make(chan bool, pingRoutine) control := make(chan bool, pingRoutine)
for _, ip := range ips { for _, ip := range ips {
wg.Add(1) wg.Add(1)
control <- false control <- false
handleProgress := handleProgressGenerator(bar) // 多线程进度条 handleProgress := handleProgressGenerator(bar) // 多线程进度条
go tcpingGoroutine(&wg, &mu, ip, pingTime, &data, control, handleProgress) go tcpingGoroutine(&wg, &mu, ip, tcpPort, pingTime, &data, control, handleProgress)
} }
wg.Wait() wg.Wait()
bar.Finish() bar.Finish()
@@ -136,6 +146,10 @@ func main() {
} }
} }
if outputFile != "" {
ExportCsv(outputFile, data) // 输出结果到文件
}
// 直接输出结果 // 直接输出结果
if printResult > 0 { // 如果禁用下载测速就跳过 if printResult > 0 { // 如果禁用下载测速就跳过
dateString := convertToString(data) // 转为多维数组 [][]String dateString := convertToString(data) // 转为多维数组 [][]String
@@ -144,18 +158,19 @@ func main() {
printResult = len(dateString) printResult = len(dateString)
fmt.Println("\n[信息] IP数量小于显示结果数量显示结果数量改为IP数量。\n") fmt.Println("\n[信息] IP数量小于显示结果数量显示结果数量改为IP数量。\n")
} }
fmt.Println("\nIP 地址 \t", "测试次数\t", "成功次数\t", "成功比率\t", "平均延迟\t", "下载速度 (MB/s)") fmt.Printf("%-16s%-5s%-5s%-5s%-6s%-11s\n", "IP 地址", "已发送", "已接收", "丢包率", "平均延迟", "下载速度 (MB/s)")
for i := 0; i < printResult; i++ { 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]) 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 outputFile != "" {
fmt.Printf("\n完整内容请查看 %v 文件。请按 回车键 或 Ctrl+C 退出。", outputFile)
} else {
fmt.Printf("\n请按 回车键 或 Ctrl+C 退出。")
} }
fmt.Printf("\n完整内容请查看 %v 文件。请按 回车键 或 Ctrl+C 退出。", outputFile)
var pause int var pause int
fmt.Scanln(&pause) fmt.Scanln(&pause)
} else { } else {
fmt.Println("\n[信息] IP数量为 0跳过输出结果。") fmt.Println("\n[信息] IP数量为 0跳过输出结果。")
} }
} }
// 输出结果到文件
ExportCsv(outputFile, data)
} }

View File

@@ -13,9 +13,9 @@ import (
) )
//bool connectionSucceed float32 time //bool connectionSucceed float32 time
func tcping(ip net.IPAddr) (bool, float32) { func tcping(ip net.IPAddr, tcpPort int) (bool, float32) {
startTime := time.Now() startTime := time.Now()
conn, err := net.DialTimeout("tcp", ip.String()+":"+strconv.Itoa(defaultTcpPort), tcpConnectTimeout) conn, err := net.DialTimeout("tcp", ip.String()+":"+strconv.Itoa(tcpPort), tcpConnectTimeout)
if err != nil { if err != nil {
return false, 0 return false, 0
} else { } else {
@@ -27,11 +27,11 @@ func tcping(ip net.IPAddr) (bool, float32) {
} }
//pingReceived pingTotalTime //pingReceived pingTotalTime
func checkConnection(ip net.IPAddr) (int, float32) { func checkConnection(ip net.IPAddr, tcpPort int) (int, float32) {
pingRecv := 0 pingRecv := 0
var pingTime float32 = 0.0 var pingTime float32 = 0.0
for i := 1; i <= failTime; i++ { for i := 1; i <= failTime; i++ {
pingSucceed, pingTimeCurrent := tcping(ip) pingSucceed, pingTimeCurrent := tcping(ip, tcpPort)
if pingSucceed { if pingSucceed {
pingRecv++ pingRecv++
pingTime += pingTimeCurrent pingTime += pingTimeCurrent
@@ -41,12 +41,12 @@ func checkConnection(ip net.IPAddr) (int, float32) {
} }
//return Success packetRecv averagePingTime specificIPAddr //return Success packetRecv averagePingTime specificIPAddr
func tcpingHandler(ip net.IPAddr, pingCount int, progressHandler func(e progressEvent)) (bool, int, float32, net.IPAddr) { func tcpingHandler(ip net.IPAddr, tcpPort int, pingCount int, progressHandler func(e progressEvent)) (bool, int, float32, net.IPAddr) {
ipCanConnect := false ipCanConnect := false
pingRecv := 0 pingRecv := 0
var pingTime float32 = 0.0 var pingTime float32 = 0.0
for !ipCanConnect { for !ipCanConnect {
pingRecvCurrent, pingTimeCurrent := checkConnection(ip) pingRecvCurrent, pingTimeCurrent := checkConnection(ip, tcpPort)
if pingRecvCurrent != 0 { if pingRecvCurrent != 0 {
ipCanConnect = true ipCanConnect = true
pingRecv = pingRecvCurrent pingRecv = pingRecvCurrent
@@ -62,7 +62,7 @@ func tcpingHandler(ip net.IPAddr, pingCount int, progressHandler func(e progress
if ipCanConnect { if ipCanConnect {
progressHandler(AvailableIPFound) progressHandler(AvailableIPFound)
for i := failTime; i < pingCount; i++ { for i := failTime; i < pingCount; i++ {
pingSuccess, pingTimeCurrent := tcping(ip) pingSuccess, pingTimeCurrent := tcping(ip, tcpPort)
progressHandler(NormalPing) progressHandler(NormalPing)
if pingSuccess { if pingSuccess {
pingRecv++ pingRecv++
@@ -76,9 +76,9 @@ func tcpingHandler(ip net.IPAddr, pingCount int, progressHandler func(e progress
} }
} }
func tcpingGoroutine(wg *sync.WaitGroup, mutex *sync.Mutex, ip net.IPAddr, pingCount int, csv *[]CloudflareIPData, control chan bool, progressHandler func(e progressEvent)) { func tcpingGoroutine(wg *sync.WaitGroup, mutex *sync.Mutex, ip net.IPAddr, tcpPort int, pingCount int, csv *[]CloudflareIPData, control chan bool, progressHandler func(e progressEvent)) {
defer wg.Done() defer wg.Done()
success, pingRecv, pingTimeAvg, currentIP := tcpingHandler(ip, pingCount, progressHandler) success, pingRecv, pingTimeAvg, currentIP := tcpingHandler(ip, tcpPort, pingCount, progressHandler)
if success { if success {
mutex.Lock() mutex.Lock()
var cfdata CloudflareIPData var cfdata CloudflareIPData

29
util.go
View File

@@ -23,7 +23,8 @@ type CloudflareIPData struct {
func (cf *CloudflareIPData) getRecvRate() float32 { func (cf *CloudflareIPData) getRecvRate() float32 {
if cf.recvRate == 0 { 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 return cf.recvRate
} }
@@ -36,7 +37,7 @@ func ExportCsv(filePath string, data []CloudflareIPData) {
} }
defer fp.Close() defer fp.Close()
w := csv.NewWriter(fp) //创建一个新的写入文件流 w := csv.NewWriter(fp) //创建一个新的写入文件流
w.Write([]string{"IP 地址", "测试次数", "成功次数", "成功比率", "平均延迟", "下载速度 (MB/s)"}) w.Write([]string{"IP 地址", "已发送", "已接收", "丢包率", "平均延迟", "下载速度 (MB/s)"})
w.WriteAll(convertToString(data)) w.WriteAll(convertToString(data))
w.Flush() w.Flush()
} }
@@ -73,7 +74,7 @@ const (
NormalPing 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 var downloadTestTime time.Duration
@@ -81,18 +82,34 @@ const downloadBufferSize = 1024
var downloadTestCount int var downloadTestCount int
const defaultTcpPort = 443 //const defaultTcpPort = 443
const tcpConnectTimeout = time.Second * 1 const tcpConnectTimeout = time.Second * 1
var failTime int var failTime int
type CloudflareIPDataSet []CloudflareIPData type CloudflareIPDataSet []CloudflareIPData
func initipEndWith() { func initRandSeed() {
rand.Seed(time.Now().UnixNano()) rand.Seed(time.Now().UnixNano())
}
func randipEndWith() {
ipEndWith = uint8(rand.Intn(254) + 1) ipEndWith = uint8(rand.Intn(254) + 1)
} }
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) { func handleProgressGenerator(pb *pb.ProgressBar) func(e progressEvent) {
return func(e progressEvent) { return func(e progressEvent) {
switch e { switch e {
@@ -112,7 +129,7 @@ func (cfs CloudflareIPDataSet) Len() int {
func (cfs CloudflareIPDataSet) Less(i, j int) bool { func (cfs CloudflareIPDataSet) Less(i, j int) bool {
if (cfs)[i].getRecvRate() != cfs[j].getRecvRate() { 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 return cfs[i].pingTime < cfs[j].pingTime
} }