mirror of
https://github.com/XIU2/CloudflareSpeedTest.git
synced 2026-03-16 03:55:59 +08:00
Compare commits
34 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
e8537fb0ae | ||
|
|
f1147c5cbf | ||
|
|
8a7b0f12f5 | ||
|
|
6a3504e98c | ||
|
|
78a8f9c6c4 | ||
|
|
aa11024026 | ||
|
|
cf1a01b614 | ||
|
|
b9159db975 | ||
|
|
157b89d88e | ||
|
|
d1c304ff59 | ||
|
|
ceff5971d2 | ||
|
|
32d544184b | ||
|
|
f82471671c | ||
|
|
638273b7e7 | ||
|
|
dc68529244 | ||
|
|
29c927d3cd | ||
|
|
fb190c661d | ||
|
|
9e39be140a | ||
|
|
09a578decf | ||
|
|
8ef6b3b7c2 | ||
|
|
cc6b5dd7a6 | ||
|
|
6c1166fc5e | ||
|
|
f9ac05a072 | ||
|
|
976dd79913 | ||
|
|
c8ef175207 | ||
|
|
31dc7aed3c | ||
|
|
e3a6f80a14 | ||
|
|
38e1d26341 | ||
|
|
166d9abe7c | ||
|
|
f9c310bfb4 | ||
|
|
0d54b65f33 | ||
|
|
9f2e5b5b5e | ||
|
|
7b4f6944be | ||
|
|
00b569d649 |
273
IPRangeLoader.go
273
IPRangeLoader.go
@@ -1,106 +1,167 @@
|
|||||||
package main
|
package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"bufio"
|
"bufio"
|
||||||
"log"
|
"log"
|
||||||
"net"
|
"net"
|
||||||
"os"
|
"os"
|
||||||
)
|
"strconv"
|
||||||
|
"strings"
|
||||||
func loadFirstIPOfRangeFromFile(ipFile string) []net.IPAddr {
|
)
|
||||||
file, err := os.Open(ipFile)
|
|
||||||
if err != nil {
|
// 根据子网掩码获取主机数量
|
||||||
log.Fatal(err)
|
func getCidrHostNum(maskLen int) int {
|
||||||
}
|
cidrIPNum := int(0)
|
||||||
firstIPs := make([]net.IPAddr, 0)
|
if maskLen < 32 {
|
||||||
scanner := bufio.NewScanner(file)
|
var i int = int(32 - maskLen - 1)
|
||||||
scanner.Split(bufio.ScanLines)
|
for ; i >= 1; i-- {
|
||||||
for scanner.Scan() {
|
cidrIPNum += 1 << i
|
||||||
IPString := scanner.Text()
|
}
|
||||||
firstIP, IPRange, err := net.ParseCIDR(IPString)
|
cidrIPNum += 2
|
||||||
if err != nil {
|
} else {
|
||||||
log.Fatal(err)
|
cidrIPNum = 1
|
||||||
}
|
}
|
||||||
if ipv6Mode { // IPv6
|
if cidrIPNum > 255 {
|
||||||
var tempIP uint8
|
cidrIPNum = 255
|
||||||
for IPRange.Contains(firstIP) {
|
}
|
||||||
//fmt.Println(firstIP)
|
return cidrIPNum
|
||||||
//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 的最后一段
|
// 获取 IP 最后一段最小值和最大值
|
||||||
firstIPCopy := make([]byte, len(firstIP))
|
func getCidrIPRange(cidr string) (uint8, uint8) {
|
||||||
copy(firstIPCopy, firstIP)
|
ip := strings.Split(cidr, "/")[0]
|
||||||
firstIPs = append(firstIPs, net.IPAddr{IP: firstIPCopy})
|
ipSegs := strings.Split(ip, ".")
|
||||||
tempIP = firstIP[13]
|
maskLen, _ := strconv.Atoi(strings.Split(cidr, "/")[1])
|
||||||
firstIP[13] += randipEndWith()
|
seg4MinIP, seg4MaxIP := getIPSeg4Range(ipSegs, maskLen)
|
||||||
if firstIP[13] < tempIP {
|
//ipPrefix := ipSegs[0] + "." + ipSegs[1] + "." + ipSegs[2] + "."
|
||||||
tempIP = firstIP[12]
|
|
||||||
firstIP[12] += randipEndWith()
|
return seg4MinIP,
|
||||||
if firstIP[12] < tempIP {
|
seg4MaxIP
|
||||||
tempIP = firstIP[11]
|
}
|
||||||
firstIP[11] += randipEndWith()
|
|
||||||
if firstIP[11] < tempIP {
|
// 获取 IP 最后一段的区间
|
||||||
tempIP = firstIP[10]
|
func getIPSeg4Range(ipSegs []string, maskLen int) (uint8, uint8) {
|
||||||
firstIP[10] += randipEndWith()
|
ipSeg, _ := strconv.Atoi(ipSegs[3])
|
||||||
if firstIP[10] < tempIP {
|
return getIPSegRange(uint8(ipSeg), uint8(32-maskLen))
|
||||||
tempIP = firstIP[9]
|
}
|
||||||
firstIP[9] += randipEndWith()
|
|
||||||
if firstIP[9] < tempIP {
|
// 根据输入的基础IP地址和CIDR掩码计算一个IP片段的区间
|
||||||
tempIP = firstIP[8]
|
func getIPSegRange(userSegIP, offset uint8) (uint8, uint8) {
|
||||||
firstIP[8] += randipEndWith()
|
var ipSegMax uint8 = 255
|
||||||
if firstIP[8] < tempIP {
|
netSegIP := ipSegMax << offset
|
||||||
tempIP = firstIP[7]
|
segMinIP := netSegIP & userSegIP
|
||||||
firstIP[7] += randipEndWith()
|
segMaxIP := userSegIP&(255<<offset) | ^(255 << offset)
|
||||||
if firstIP[7] < tempIP {
|
return uint8(segMinIP), uint8(segMaxIP)
|
||||||
tempIP = firstIP[6]
|
}
|
||||||
firstIP[6] += randipEndWith()
|
|
||||||
if firstIP[6] < tempIP {
|
func loadFirstIPOfRangeFromFile(ipFile string) []net.IPAddr {
|
||||||
tempIP = firstIP[5]
|
file, err := os.Open(ipFile)
|
||||||
firstIP[5] += randipEndWith()
|
if err != nil {
|
||||||
if firstIP[5] < tempIP {
|
log.Fatal(err)
|
||||||
tempIP = firstIP[4]
|
}
|
||||||
firstIP[4] += randipEndWith()
|
firstIPs := make([]net.IPAddr, 0)
|
||||||
if firstIP[4] < tempIP {
|
scanner := bufio.NewScanner(file)
|
||||||
tempIP = firstIP[3]
|
scanner.Split(bufio.ScanLines)
|
||||||
firstIP[3] += randipEndWith()
|
for scanner.Scan() {
|
||||||
if firstIP[3] < tempIP {
|
IPString := scanner.Text()
|
||||||
tempIP = firstIP[2]
|
firstIP, IPRange, err := net.ParseCIDR(IPString)
|
||||||
firstIP[2] += randipEndWith()
|
//fmt.Println(firstIP)
|
||||||
if firstIP[2] < tempIP {
|
//fmt.Println(IPRange)
|
||||||
tempIP = firstIP[1]
|
if err != nil {
|
||||||
firstIP[1] += randipEndWith()
|
log.Fatal(err)
|
||||||
if firstIP[1] < tempIP {
|
}
|
||||||
tempIP = firstIP[0]
|
if !ipv6Mode { // IPv4
|
||||||
firstIP[0] += randipEndWith()
|
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)
|
||||||
} else { //IPv4
|
firstIPs = append(firstIPs, net.IPAddr{IP: firstIPCopy})
|
||||||
for IPRange.Contains(firstIP) {
|
}
|
||||||
firstIP[15] = randipEndWith() // 随机 IP 的最后一段 0.0.0.X
|
firstIP[14]++ // 0.0.(X+1).X
|
||||||
firstIPCopy := make([]byte, len(firstIP))
|
if firstIP[14] == 0 {
|
||||||
copy(firstIPCopy, firstIP)
|
firstIP[13]++ // 0.(X+1).X.X
|
||||||
firstIPs = append(firstIPs, net.IPAddr{IP: firstIPCopy})
|
if firstIP[13] == 0 {
|
||||||
firstIP[14]++ // 0.0.(X+1).X
|
firstIP[12]++ // (X+1).X.X.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
|
||||||
}
|
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(255) // 随机 IP 的最后一段
|
||||||
return firstIPs
|
firstIP[14] = randipEndWith(255) // 随机 IP 的最后一段
|
||||||
}
|
firstIPCopy := make([]byte, len(firstIP))
|
||||||
|
copy(firstIPCopy, firstIP)
|
||||||
|
firstIPs = append(firstIPs, net.IPAddr{IP: firstIPCopy})
|
||||||
|
tempIP = firstIP[13]
|
||||||
|
firstIP[13] += randipEndWith(255)
|
||||||
|
if firstIP[13] < tempIP {
|
||||||
|
tempIP = firstIP[12]
|
||||||
|
firstIP[12] += randipEndWith(255)
|
||||||
|
if firstIP[12] < tempIP {
|
||||||
|
tempIP = firstIP[11]
|
||||||
|
firstIP[11] += randipEndWith(255)
|
||||||
|
if firstIP[11] < tempIP {
|
||||||
|
tempIP = firstIP[10]
|
||||||
|
firstIP[10] += randipEndWith(255)
|
||||||
|
if firstIP[10] < tempIP {
|
||||||
|
tempIP = firstIP[9]
|
||||||
|
firstIP[9] += randipEndWith(255)
|
||||||
|
if firstIP[9] < tempIP {
|
||||||
|
tempIP = firstIP[8]
|
||||||
|
firstIP[8] += randipEndWith(255)
|
||||||
|
if firstIP[8] < tempIP {
|
||||||
|
tempIP = firstIP[7]
|
||||||
|
firstIP[7] += randipEndWith(255)
|
||||||
|
if firstIP[7] < tempIP {
|
||||||
|
tempIP = firstIP[6]
|
||||||
|
firstIP[6] += randipEndWith(255)
|
||||||
|
if firstIP[6] < tempIP {
|
||||||
|
tempIP = firstIP[5]
|
||||||
|
firstIP[5] += randipEndWith(255)
|
||||||
|
if firstIP[5] < tempIP {
|
||||||
|
tempIP = firstIP[4]
|
||||||
|
firstIP[4] += randipEndWith(255)
|
||||||
|
if firstIP[4] < tempIP {
|
||||||
|
tempIP = firstIP[3]
|
||||||
|
firstIP[3] += randipEndWith(255)
|
||||||
|
if firstIP[3] < tempIP {
|
||||||
|
tempIP = firstIP[2]
|
||||||
|
firstIP[2] += randipEndWith(255)
|
||||||
|
if firstIP[2] < tempIP {
|
||||||
|
tempIP = firstIP[1]
|
||||||
|
firstIP[1] += randipEndWith(255)
|
||||||
|
if firstIP[1] < tempIP {
|
||||||
|
tempIP = firstIP[0]
|
||||||
|
firstIP[0] += randipEndWith(255)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return firstIPs
|
||||||
|
}
|
||||||
|
|||||||
341
README.md
341
README.md
@@ -1,161 +1,180 @@
|
|||||||
# XIU2/CloudflareSpeedTest
|
# XIU2/CloudflareSpeedTest
|
||||||
|
|
||||||
[](https://github.com/XIU2/CloudflareSpeedTest/blob/master/go.mod)
|
[](https://github.com/XIU2/CloudflareSpeedTest/blob/master/go.mod)
|
||||||
[](https://github.com/XIU2/CloudflareSpeedTest/releases/latest)
|
[](https://github.com/XIU2/CloudflareSpeedTest/releases/latest)
|
||||||
[](https://github.com/XIU2/CloudflareSpeedTest/blob/master/LICENSE)
|
[](https://github.com/XIU2/CloudflareSpeedTest/blob/master/LICENSE)
|
||||||
[](https://github.com/XIU2/CloudflareSpeedTest/stargazers)
|
[](https://github.com/XIU2/CloudflareSpeedTest/stargazers)
|
||||||
[](https://github.com/XIU2/CloudflareSpeedTest/network/members)
|
[](https://github.com/XIU2/CloudflareSpeedTest/network/members)
|
||||||
|
|
||||||
国外很多网站都在使用 Cloudflare CDN，但分配给中国访客的 IP 并不友好。
|
国外很多网站都在使用 Cloudflare CDN，但分配给中国访客的 IP 并不友好。
|
||||||
虽然 Cloudflare 公开了所有 [IP 段](https://www.cloudflare.com/ips/) ，但想要在这么多 IP 中找到适合自己的，怕是要累死，所以就有了这个软件。
|
虽然 Cloudflare 公开了所有 [IP 段](https://www.cloudflare.com/ips/) ，但想要在这么多 IP 中找到适合自己的，怕是要累死，所以就有了这个软件。
|
||||||
|
|
||||||
该软件可以**测试 Cloudflare CDN 所有 IP 的延迟和速度，获得最快 IP**！觉得好用请**点个⭐鼓励一下下~**
|
该软件可以**测试 Cloudflare CDN 延迟和速度，获取最快 IP (IPv4+IPv6)**！觉得好用请**点个⭐鼓励一下下~**
|
||||||
将 IP 添加到 `Hosts` 文件或 DNS 程序中，以提高访问使用 Cloudflare CDN 的网站速度！
|
|
||||||
|
> _本项目也**适用于其他 CDN**，但是需要自行寻找 **CDN IP 段及下载测速地址**（否则只能延迟测速）。_
|
||||||
> 本项目也**适用于其他 CDN**，但是需要自行寻找 **CDN IP 段及下载测速地址**（否则只能延迟测速）！
|
|
||||||
|
> _我另一个开源项目： **[一个 \[油猴脚本\] 轻松解决「Github」文件下载速度慢的问题！](https://github.com/XIU2/UserScript)**_
|
||||||
****
|
|
||||||
## 快速使用
|
****
|
||||||
|
## 快速使用
|
||||||
### 下载运行
|
|
||||||
|
### 下载运行
|
||||||
1. 下载编译好的可执行文件 [蓝奏云](https://xiu.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` 。
|
|
||||||
|
> _**提示：Linux 系统**请先赋予权限 `chmod +x CloudflareST` ，然后再 `./CloudflareST` 运行。_
|
||||||
### 结果示例
|
|
||||||
|
> _**注意：建议测速时避开晚上高峰期（20:00~24:00）**，否则测速结果会与其他时间**差距很大...**_
|
||||||
测速完毕后，会直接显示**最快的 20 个 IP**，示例：
|
|
||||||
|
### 结果示例
|
||||||
```
|
|
||||||
IP 地址 已发送 已接收 丢包率 平均延迟 下载速度 (MB/s)
|
测速完毕后，默认会显示**最快的 20 个 IP**，示例（我的白天测速结果）：
|
||||||
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
|
IP 地址 已发送 已接收 丢包率 平均延迟 下载速度 (MB/s)
|
||||||
104.22.42.165 4 4 0.00 133.63 12.00
|
104.27.200.69 4 4 0.00 146.23 28.64
|
||||||
104.22.35.177 4 4 0.00 135.75 3.92
|
172.67.60.78 4 4 0.00 139.82 15.02
|
||||||
104.22.87.44 4 4 0.00 136.00 5.86
|
104.25.140.153 4 4 0.00 146.49 14.90
|
||||||
104.22.67.122 4 4 0.00 136.50 9.47
|
104.27.192.65 4 4 0.00 140.28 14.07
|
||||||
104.22.88.154 4 4 0.00 140.75 13.00
|
172.67.62.214 4 4 0.00 139.29 12.71
|
||||||
104.22.69.218 4 4 0.00 142.00 19.07
|
104.27.207.5 4 4 0.00 145.92 11.95
|
||||||
104.27.184.10 4 4 0.00 148.02 21.05
|
172.67.54.193 4 4 0.00 146.71 11.55
|
||||||
...
|
104.22.66.8 4 4 0.00 147.42 11.11
|
||||||
```
|
104.27.197.63 4 4 0.00 131.29 10.26
|
||||||
|
172.67.58.91 4 4 0.00 140.19 9.14
|
||||||
完整结果保存在当前目录下的 `result.csv` 文件中，用**记事本/表格软件**打开，排序为**延迟由低到高**，分别是：
|
...
|
||||||
|
```
|
||||||
```
|
|
||||||
IP 地址, 已发送, 已接收, 丢包率, 平均延迟, 下载速度 (MB/s)
|
> _软件是先**延迟测速并按从低到高排序**后，再**从最低延迟的 IP 开始下载测速**的，所以：_
|
||||||
104.27.199.141, 4, 4, 0.00, 139.52, 11.71
|
|
||||||
```
|
测速结果第一行就是**既下载速度最快、又平均延迟最低的最快 IP**！至于拿来干嘛？取决于你~
|
||||||
> 大家可以按照自己的需求，对完整测速数据**进一步筛选处理**！
|
|
||||||
|
完整结果保存在当前目录下的 `result.csv` 文件中，用**记事本/表格软件**打开，格式如下：
|
||||||
选择一个平均延迟与下载速度都不错的 IP 放到 `Hosts` 文件中（指向使用 Cloudflare CDN 的网站域名）。
|
|
||||||
|
```
|
||||||
****
|
IP 地址, 已发送, 已接收, 丢包率, 平均延迟, 下载速度 (MB/s)
|
||||||
## 进阶使用
|
104.27.200.69, 4, 4, 0.00, 146.23, 28.64
|
||||||
|
```
|
||||||
直接双击运行使用的是默认参数，如果想要测试速度更快、测试结果更全面，可以自定义参数。
|
|
||||||
|
> _大家可以按自己需求，对完整结果**进一步筛选处理**，或者去看一看进阶使用**指定过滤条件**！_
|
||||||
``` cmd
|
|
||||||
C:\>CloudflareST.exe -h
|
****
|
||||||
|
## 进阶使用
|
||||||
CloudflareSpeedTest vX.X.X
|
|
||||||
测试 Cloudflare CDN 所有 IP 的延迟和速度，获取最快 IP！
|
直接运行使用的是默认参数，如果想要测速结果更全面、更符合自己的要求，可以自定义参数。
|
||||||
https://github.com/XIU2/CloudflareSpeedTest
|
|
||||||
|
``` cmd
|
||||||
参数：
|
C:\>CloudflareST.exe -h
|
||||||
-n 500
|
|
||||||
测速线程数量；数值越大速度越快，请勿超过 1000(结果误差大)；(默认 500)
|
CloudflareSpeedTest vX.X.X
|
||||||
-t 4
|
测试 Cloudflare CDN 所有 IP 的延迟和速度，获取最快 IP (IPv4+IPv6)！
|
||||||
延迟测速次数；单个 IP 测速次数，为 1 时将过滤丢包的IP，TCP协议；(默认 4)
|
https://github.com/XIU2/CloudflareSpeedTest
|
||||||
-tp 443
|
|
||||||
延迟测速端口；延迟测速 TCP 协议的端口；(默认 443)
|
参数：
|
||||||
-dn 20
|
-n 500
|
||||||
下载测速数量；延迟测速并排序后，从最低延迟起下载测速数量，请勿太多(速度慢)；(默认 20)
|
测速线程数量；越多测速越快，性能弱的设备 (如路由器) 请适当调低；(默认 500 最多 1000)
|
||||||
-dt 5
|
-t 4
|
||||||
下载测速时间；单个 IP 测速最长时间，单位：秒；(默认 5)
|
延迟测速次数；单个 IP 延迟测速次数，为 1 时将过滤丢包的IP，TCP协议；(默认 4)
|
||||||
-url https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png
|
-tp 443
|
||||||
下载测速地址；用来 Cloudflare CDN 测速的文件地址，如含有空格请加上引号；
|
延迟测速端口；延迟测速 TCP 协议的端口；(默认 443)
|
||||||
-tl 200
|
-dn 20
|
||||||
延迟时间上限；只输出指定延迟时间以下的结果，数量为 -dn 参数的值，单位：ms；
|
下载测速数量；延迟测速并排序后，从最低延迟起下载测速的数量；(默认 20)
|
||||||
-sl 5
|
-dt 10
|
||||||
下载速度下限；只输出指定下载速度以上的结果，数量为 -dn 参数的值，单位：MB/s；
|
下载测速时间；单个 IP 下载测速最长时间，单位：秒；(默认 10)
|
||||||
-p 20
|
-url https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png
|
||||||
显示结果数量；测速后直接显示指定数量的结果，为 0 时不显示结果直接退出；(默认 20)
|
下载测速地址；用来下载测速的 Cloudflare CDN 文件地址，如地址含有空格请加上引号；
|
||||||
-f ip.txt
|
-tl 200
|
||||||
IP 数据文件；如含有空格请加上引号；支持其他 CDN IP段，记得禁用下载测速；(默认 ip.txt)
|
平均延迟上限；只输出低于指定平均延迟的 IP，与下载速度下限搭配使用；(默认 9999 ms)
|
||||||
-o result.csv
|
-sl 5
|
||||||
输出结果文件；如含有空格请加上引号；为空格时不输出结果文件(-o " ")；允许其他后缀；(默认 result.csv)
|
下载速度下限；只输出高于指定下载速度的 IP，凑够指定数量 [-dn] 才会停止测速；(默认 0 MB/s)
|
||||||
-dd
|
-p 20
|
||||||
禁用下载测速；如果带上该参数就是禁用下载测速；(默认 启用)
|
显示结果数量；测速后直接显示指定数量的结果，为 0 时不显示结果直接退出；(默认 20)
|
||||||
-ipv6
|
-f ip.txt
|
||||||
IPv6 测速模式；请确保 IP 数据文件内只包含 IPv6 IP段，软件不支持同时测速 IPv4+IPv6；(默认 IPv4)
|
IP段数据文件；如路径含有空格请加上引号；支持其他 CDN IP段；(默认 ip.txt)
|
||||||
-v
|
-o result.csv
|
||||||
打印程序版本
|
输出结果文件；如路径含有空格请加上引号；值为空格时不输出 [-o " "]；(默认 result.csv)
|
||||||
-h
|
-dd
|
||||||
打印帮助说明
|
禁用下载测速；禁用后测速结果会按延迟排序 (默认按下载速度排序)；(默认 启用)
|
||||||
```
|
-ipv6
|
||||||
|
IPv6测速模式；确保 IP 段数据文件内只包含 IPv6 IP段，软件不支持同时测速 IPv4+IPv6；(默认 IPv4)
|
||||||
> 如果**下载速度都是 0.00**，那说明默认的**下载测速地址**用的人太多又到上限了，**请去这个 [Issues](https://github.com/XIU2/CloudflareSpeedTest/issues/6) 获得解决方法！**
|
-allip
|
||||||
|
测速全部的IP；对 IP 段中的每个 IP (仅支持 IPv4) 进行测速；(默认 每个 IP 段随机测速一个 IP)
|
||||||
### 使用示例
|
-v
|
||||||
|
打印程序版本+检查版本更新
|
||||||
在 CMD 中运行，或者把启动参数添加到快捷方式中。
|
-h
|
||||||
|
打印帮助说明
|
||||||
``` bash
|
```
|
||||||
# 命令行示例
|
|
||||||
# 注意：各参数均有默认值，只有不使用默认值时，才需要手动指定参数的值（按需选择），参数不分前后顺序。
|
> _如果**下载速度都是 0.00**，那可能默认的**下载测速地址**用的人太多到上限了，**请去这个 [Issues](https://github.com/XIU2/CloudflareSpeedTest/issues/6) 获得解决方法！**_
|
||||||
# 提示： Linux 系统只需要把下面命令中的 CloudflareST.exe 改为 ./CloudflareST 即可。
|
|
||||||
|
### 使用示例
|
||||||
# 指定 IPv4 数据文件，不显示结果直接退出（-p 值为 0）
|
|
||||||
CloudflareST.exe -p 0 -f ip.txt -dd
|
在 CMD 中运行，或者把启动参数添加到快捷方式中。
|
||||||
|
|
||||||
# 指定 IPv6 数据文件( ipv6.txt )，不显示结果直接退出（-p 值为 0）
|
``` bash
|
||||||
CloudflareST.exe -p 0 -f ipv6.txt -dd -ipv6
|
# 命令行示例
|
||||||
|
# 注意：各参数均有默认值，只有不使用默认值时，才需要手动指定参数的值（按需选择），参数不分前后顺序。
|
||||||
# 指定 IPv4 数据文件，不输出结果到文件，直接显示结果（-p 值为 10 条）
|
# 提示： Linux 系统只需要把下面命令中的 CloudflareST.exe 改为 ./CloudflareST 即可。
|
||||||
CloudflareST.exe -p 10 -f ip.txt -o " " -dd
|
|
||||||
|
# 指定 IPv4 数据文件，不显示结果直接退出（-p 值为 0）
|
||||||
# 指定 IPv4 数据文件 及 输出结果到文件（相对路径，即当前目录下，如果包含空格请加上引号）
|
CloudflareST.exe -p 0 -f ip.txt -dd
|
||||||
CloudflareST.exe -f ip.txt -o result.csv -dd
|
|
||||||
|
# 指定 IPv6 数据文件( ipv6.txt )，不显示结果直接退出（-p 值为 0）
|
||||||
# 指定 IPv4 数据文件 及 输出结果到文件（绝对路径，即 C:\abc\ 目录下，如果包含空格请加上引号）
|
CloudflareST.exe -p 0 -f ipv6.txt -dd -ipv6
|
||||||
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
|
# 指定 IPv4 数据文件，不输出结果到文件，直接显示结果（-p 值为 10 条）
|
||||||
|
CloudflareST.exe -p 10 -f ip.txt -o " " -dd
|
||||||
# 指定测速条件（只有同时满足三个条件时才会停止测速）：
|
|
||||||
# 延迟时间上限：200 ms，下载速度下限：0 MB/s，数量：10 个
|
# 指定 IPv4 数据文件 及 输出结果到文件（相对路径，即当前目录下，如含空格请加上引号）
|
||||||
CloudflareST.exe -tl 200 -dn 10
|
CloudflareST.exe -f ip.txt -o result.csv -dd
|
||||||
|
|
||||||
# 延迟时间上限：0 ms，下载速度下限：5 MB/s，数量：10 个
|
# 指定 IPv4 数据文件 及 输出结果到文件（绝对路径，即 C:\abc\ 目录下，如含空格请加上引号）
|
||||||
CloudflareST.exe -sl 5 -dn 10
|
CloudflareST.exe -f C:\abc\ip.txt -o C:\abc\result.csv -dd
|
||||||
|
|
||||||
# 延迟时间上限：200 ms，下载速度下限：5 MB/s，数量：10 个
|
# ——————————————————————
|
||||||
CloudflareST.exe -tl 200 -sl 5 -dn 10
|
|
||||||
|
# 指定下载测速地址（要求：可以直接下载、文件大小超过 200MB、用的是 Cloudflare CDN），如含空格请加上引号
|
||||||
# 如果一直凑不够指定数量，会一直测速下去。
|
CloudflareST.exe -url https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png
|
||||||
# 建议指定下载速度下限时，同时指定延迟时间上限，如果测试到指定延迟还没凑够数，就会终止测速。
|
|
||||||
# 如果一个满足条件的 IP 都没有，那么就会正常输出结果（和不指定条件一样）。
|
# ——————————————————————
|
||||||
# 如果你需要通过外部程序进一步筛选处理，那么只需要判断测速结果数量，如果上千个说明一个满足条件的 IP 都没有。
|
|
||||||
```
|
# 指定测速条件（只有同时满足三个条件时才会停止测速）：
|
||||||
|
|
||||||
``` cmd
|
# 平均延迟上限：9999 ms，下载速度下限：5 MB/s，数量：10 个
|
||||||
# Windows 快捷方式示例（右键快捷方式 - 目标）
|
# 即需要找到 10 个平均延迟低于 9999 ms 且 下载速度高于 5 MB/s 的 IP 才会停止测速。
|
||||||
## 如果有引号就放在引号外面，记得引号和 - 之间有空格。
|
CloudflareST.exe -sl 5 -dn 10
|
||||||
### 如果要不输出结果文件，那么请加上 -o " "，引号里的是空格。
|
|
||||||
"D:\Program Files\CloudflareST\CloudflareST.exe" -n 500 -t 4 -dn 20 -dt 5
|
# 没有指定平均延迟上限时，如果一直凑不够满足条件的 IP 数量，会一直测速下去。
|
||||||
```
|
# 所以建议同时指定 下载速度下限 和 平均延迟上限，这样测试到指定延迟还没凑够数量，就会终止测速。
|
||||||
|
|
||||||
****
|
# 平均延迟上限：200 ms，下载速度下限：5 MB/s，数量：10 个
|
||||||
## 感谢项目
|
# 即需要找到 10 个平均延迟低于 200 ms 且 下载速度高于 5 MB/s 的 IP 才会停止测速。
|
||||||
* https://github.com/Spedoske/CloudflareScanner
|
CloudflareST.exe -tl 200 -sl 5 -dn 10
|
||||||
|
|
||||||
意外发现了这个项目，看了之后发现正好解决了我的问题，但是我更喜欢用户命令行方式运行，这样会更方便、有更多使用姿势，于是我临时学了下 Golang 并 Fork 按照我自己的需求修改了一下（包括但不限于命令行方式交互、直接输出结果等），如果有什么问题可以告诉我，虽然我不一定会~
|
# 如果一个满足条件的 IP 都没找到，那么就会和不指定条件一样输出完整结果。
|
||||||
|
# 所以建议先不指定条件测速一遍，看看平均延迟和下载速度大概在什么范围，避免指定条件过低/过高！
|
||||||
****
|
```
|
||||||
## 许可证
|
|
||||||
The GPL-3.0 License.
|
``` bash
|
||||||
|
# Windows 快捷方式示例（右键快捷方式 - 目标）
|
||||||
|
# 如果要不输出结果文件，那么请加上 -o " "，引号里的是空格（没有空格会导致该参数被省略）。
|
||||||
|
|
||||||
|
D:\ABC\CloudflareST\CloudflareST.exe -n 500 -t 4 -dn 20 -dt 5 -o " "
|
||||||
|
|
||||||
|
# 如果文件路径包含引号，则需要把启动参数放在引号外面，记得引号和 - 之间有空格。
|
||||||
|
"D:\Program Files\CloudflareST\CloudflareST.exe" -n 500 -t 4 -dn 20 -dt 5 -o " "
|
||||||
|
```
|
||||||
|
|
||||||
|
****
|
||||||
|
## 感谢项目
|
||||||
|
* https://github.com/Spedoske/CloudflareScanner
|
||||||
|
|
||||||
|
> _因为该项目已经很长时间没更新了，而我又产生了很多功能需求，所以我干脆临时学了下 Go 语言就上手了..._
|
||||||
|
> _本软件基于该项目制作，但**已添加大量功能及修复 BUG**，并根据大家的使用反馈去添加、优化功能（闲）..._
|
||||||
|
|
||||||
|
****
|
||||||
|
## 许可证
|
||||||
|
The GPL-3.0 License.
|
||||||
|
|||||||
4
ip.txt
4
ip.txt
@@ -1,3 +1,7 @@
|
|||||||
|
1.1.1.0/24
|
||||||
|
1.0.0.0/24
|
||||||
|
1.1.1.1/32
|
||||||
|
1.0.0.1/32
|
||||||
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
|
||||||
|
|||||||
42
ipv6.txt
Normal file
42
ipv6.txt
Normal 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
|
||||||
513
main.go
513
main.go
@@ -1,242 +1,271 @@
|
|||||||
package main
|
package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"flag"
|
"flag"
|
||||||
"fmt"
|
"fmt"
|
||||||
"os"
|
"io/ioutil"
|
||||||
"runtime"
|
"net/http"
|
||||||
"sort"
|
"os"
|
||||||
"strconv"
|
"runtime"
|
||||||
"sync"
|
"sort"
|
||||||
"time"
|
"strconv"
|
||||||
|
"sync"
|
||||||
"github.com/cheggaaa/pb/v3"
|
"time"
|
||||||
)
|
|
||||||
|
"github.com/cheggaaa/pb/v3"
|
||||||
var version string
|
)
|
||||||
var disableDownload bool
|
|
||||||
var ipv6Mode bool
|
var version, ipFile, outputFile, versionNew string
|
||||||
var tcpPort int
|
var disableDownload, ipv6Mode, allip bool
|
||||||
var ipFile string
|
var tcpPort, printResultNum, timeLimit, speedLimit, downloadSecond int
|
||||||
var outputFile string
|
|
||||||
var printResultNum int
|
func init() {
|
||||||
var timeLimit int
|
var printVersion bool
|
||||||
var speedLimit int
|
var help = `
|
||||||
|
CloudflareSpeedTest ` + version + `
|
||||||
func init() {
|
测试 Cloudflare CDN 所有 IP 的延迟和速度，获取最快 IP (IPv4+IPv6)！
|
||||||
var downloadSecond int64
|
https://github.com/XIU2/CloudflareSpeedTest
|
||||||
var printVersion bool
|
|
||||||
var help = `
|
参数：
|
||||||
CloudflareSpeedTest ` + version + `
|
-n 500
|
||||||
测试 Cloudflare CDN 所有 IP 的延迟和速度，获取最快 IP！
|
测速线程数量；越多测速越快，性能弱的设备 (如路由器) 请适当调低；(默认 500 最多 1000)
|
||||||
https://github.com/XIU2/CloudflareSpeedTest
|
-t 4
|
||||||
|
延迟测速次数；单个 IP 延迟测速次数，为 1 时将过滤丢包的IP，TCP协议；(默认 4)
|
||||||
参数：
|
-tp 443
|
||||||
-n 500
|
延迟测速端口；延迟测速 TCP 协议的端口；(默认 443)
|
||||||
测速线程数量；数值越大速度越快，请勿超过 1000(结果误差大)；(默认 500)
|
-dn 20
|
||||||
-t 4
|
下载测速数量；延迟测速并排序后，从最低延迟起下载测速的数量；(默认 20)
|
||||||
延迟测速次数；单个 IP 测速次数，为 1 时将过滤丢包的IP，TCP协议；(默认 4)
|
-dt 10
|
||||||
-tp 443
|
下载测速时间；单个 IP 下载测速最长时间，单位：秒；(默认 10)
|
||||||
延迟测速端口；延迟测速 TCP 协议的端口；(默认 443)
|
-url https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png
|
||||||
-dn 20
|
下载测速地址；用来下载测速的 Cloudflare CDN 文件地址，如地址含有空格请加上引号；
|
||||||
下载测速数量；延迟测速并排序后，从最低延迟起下载测速数量，请勿太多(速度慢)；(默认 20)
|
-tl 200
|
||||||
-dt 5
|
平均延迟上限；只输出低于指定平均延迟的 IP，与下载速度下限搭配使用；(默认 9999 ms)
|
||||||
下载测速时间；单个 IP 测速最长时间，单位：秒；(默认 5)
|
-sl 5
|
||||||
-url https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png
|
下载速度下限；只输出高于指定下载速度的 IP，凑够指定数量 [-dn] 才会停止测速；(默认 0 MB/s)
|
||||||
下载测速地址；用来 Cloudflare CDN 测速的文件地址，如含有空格请加上引号；
|
-p 20
|
||||||
-tl 200
|
显示结果数量；测速后直接显示指定数量的结果，为 0 时不显示结果直接退出；(默认 20)
|
||||||
延迟时间上限；只输出指定延迟时间以下的结果，数量为 -dn 参数的值，单位：ms；
|
-f ip.txt
|
||||||
-sl 5
|
IP段数据文件；如路径含有空格请加上引号；支持其他 CDN IP段；(默认 ip.txt)
|
||||||
下载速度下限；只输出指定下载速度以上的结果，数量为 -dn 参数的值，单位：MB/s；
|
-o result.csv
|
||||||
-p 20
|
输出结果文件；如路径含有空格请加上引号；值为空格时不输出 [-o " "]；(默认 result.csv)
|
||||||
显示结果数量；测速后直接显示指定数量的结果，值为 0 时不显示结果直接退出；(默认 20)
|
-dd
|
||||||
-f ip.txt
|
禁用下载测速；禁用后测速结果会按延迟排序 (默认按下载速度排序)；(默认 启用)
|
||||||
IP 数据文件；如含有空格请加上引号；支持其他 CDN IP段，记得禁用下载测速；(默认 ip.txt)
|
-ipv6
|
||||||
-o result.csv
|
IPv6测速模式；确保 IP 段数据文件内只包含 IPv6 IP段，软件不支持同时测速 IPv4+IPv6；(默认 IPv4)
|
||||||
输出结果文件；如含有空格请加上引号；为空格时不输出结果文件(-o " ")；允许其他后缀；(默认 result.csv)
|
-allip
|
||||||
-dd
|
测速全部的IP；对 IP 段中的每个 IP (仅支持 IPv4) 进行测速；(默认 每个 IP 段随机测速一个 IP)
|
||||||
禁用下载测速；如果带上该参数就是禁用下载测速；(默认 启用下载测速)
|
-v
|
||||||
-ipv6
|
打印程序版本+检查版本更新
|
||||||
IPv6 测速模式；请确保 IP 数据文件内只包含 IPv6 IP段，软件不支持同时测速 IPv4+IPv6；(默认 IPv4)
|
-h
|
||||||
-v
|
打印帮助说明
|
||||||
打印程序版本
|
`
|
||||||
-h
|
|
||||||
打印帮助说明`
|
flag.IntVar(&pingRoutine, "n", 500, "测速线程数量")
|
||||||
|
flag.IntVar(&pingTime, "t", 4, "延迟测速次数")
|
||||||
flag.IntVar(&pingRoutine, "n", 500, "测速线程数量")
|
flag.IntVar(&tcpPort, "tp", 443, "延迟测速端口")
|
||||||
flag.IntVar(&pingTime, "t", 4, "延迟测速次数")
|
flag.IntVar(&downloadTestCount, "dn", 20, "下载测速数量")
|
||||||
flag.IntVar(&tcpPort, "tp", 443, "延迟测速端口")
|
flag.IntVar(&downloadSecond, "dt", 10, "下载测速时间")
|
||||||
flag.IntVar(&downloadTestCount, "dn", 20, "下载测速数量")
|
flag.StringVar(&url, "url", "https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png", "下载测速地址")
|
||||||
flag.Int64Var(&downloadSecond, "dt", 5, "下载测速时间")
|
flag.IntVar(&timeLimit, "tl", 9999, "延迟时间上限")
|
||||||
flag.StringVar(&url, "url", "https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png", "下载测速地址")
|
flag.IntVar(&speedLimit, "sl", 0, "下载速度下限")
|
||||||
flag.IntVar(&timeLimit, "tl", 0, "延迟时间上限")
|
flag.IntVar(&printResultNum, "p", 20, "显示结果数量")
|
||||||
flag.IntVar(&speedLimit, "sl", 0, "下载速度下限")
|
flag.BoolVar(&disableDownload, "dd", false, "禁用下载测速")
|
||||||
flag.IntVar(&printResultNum, "p", 20, "显示结果数量")
|
flag.BoolVar(&ipv6Mode, "ipv6", false, "禁用下载测速")
|
||||||
flag.BoolVar(&disableDownload, "dd", false, "禁用下载测速")
|
flag.BoolVar(&allip, "allip", false, "测速全部 IP")
|
||||||
flag.BoolVar(&ipv6Mode, "ipv6", 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", "输出结果文件")
|
flag.BoolVar(&printVersion, "v", false, "打印程序版本")
|
||||||
flag.BoolVar(&printVersion, "v", false, "打印程序版本")
|
|
||||||
|
flag.Usage = func() { fmt.Print(help) }
|
||||||
downloadTestTime = time.Duration(downloadSecond) * time.Second
|
flag.Parse()
|
||||||
|
if printVersion {
|
||||||
flag.Usage = func() { fmt.Print(help) }
|
println(version)
|
||||||
flag.Parse()
|
fmt.Println("检查版本更新中...")
|
||||||
if printVersion {
|
checkUpdate()
|
||||||
println(version)
|
if versionNew != "" {
|
||||||
os.Exit(0)
|
fmt.Println("发现新版本 [" + versionNew + "]！请前往 [https://github.com/XIU2/CloudflareSpeedTest] 更新！")
|
||||||
}
|
} else {
|
||||||
if pingRoutine <= 0 {
|
fmt.Println("当前为最新版本 [" + version + "]！")
|
||||||
pingRoutine = 500
|
}
|
||||||
}
|
os.Exit(0)
|
||||||
if pingTime <= 0 {
|
}
|
||||||
pingTime = 4
|
if pingRoutine <= 0 {
|
||||||
}
|
pingRoutine = 500
|
||||||
if tcpPort < 1 || tcpPort > 65535 {
|
}
|
||||||
tcpPort = 443
|
if pingTime <= 0 {
|
||||||
}
|
pingTime = 4
|
||||||
if downloadTestCount <= 0 {
|
}
|
||||||
downloadTestCount = 20
|
if tcpPort < 1 || tcpPort > 65535 {
|
||||||
}
|
tcpPort = 443
|
||||||
if downloadSecond <= 0 {
|
}
|
||||||
downloadSecond = 10
|
if downloadTestCount <= 0 {
|
||||||
}
|
downloadTestCount = 20
|
||||||
if url == "" {
|
}
|
||||||
url = "https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png"
|
if downloadSecond <= 0 {
|
||||||
}
|
downloadSecond = 10
|
||||||
if timeLimit <= 0 {
|
}
|
||||||
timeLimit = 9999
|
if url == "" {
|
||||||
}
|
url = "https://cf.xiu2.xyz/Github/CloudflareSpeedTest.png"
|
||||||
if speedLimit < 0 {
|
}
|
||||||
speedLimit = 0
|
if timeLimit <= 0 {
|
||||||
}
|
timeLimit = 9999
|
||||||
if printResultNum < 0 {
|
}
|
||||||
printResultNum = 20
|
if speedLimit < 0 {
|
||||||
}
|
speedLimit = 0
|
||||||
if ipFile == "" {
|
}
|
||||||
ipFile = "ip.txt"
|
if printResultNum < 0 {
|
||||||
}
|
printResultNum = 20
|
||||||
if outputFile == " " {
|
}
|
||||||
outputFile = ""
|
if ipFile == "" {
|
||||||
}
|
ipFile = "ip.txt"
|
||||||
}
|
}
|
||||||
|
if outputFile == " " {
|
||||||
func main() {
|
outputFile = ""
|
||||||
initRandSeed() // 置随机数种子
|
}
|
||||||
failTime = pingTime // 设置接收次数
|
}
|
||||||
ips := loadFirstIPOfRangeFromFile(ipFile) // 读入IP
|
|
||||||
pingCount := len(ips) * pingTime // 计算进度条总数（IP*测试次数）
|
func main() {
|
||||||
bar := pb.Simple.Start(pingCount) // 进度条总数
|
go checkUpdate() // 检查版本更新
|
||||||
var wg sync.WaitGroup
|
initRandSeed() // 置随机数种子
|
||||||
var mu sync.Mutex
|
failTime = pingTime // 设置接收次数
|
||||||
var data = make([]CloudflareIPData, 0)
|
ips := loadFirstIPOfRangeFromFile(ipFile) // 读入IP
|
||||||
var data_2 = make([]CloudflareIPData, 0)
|
pingCount := len(ips) * pingTime // 计算进度条总数（IP*测试次数）
|
||||||
|
bar := pb.Simple.Start(pingCount) // 进度条总数
|
||||||
fmt.Println("# XIU2/CloudflareSpeedTest " + version + "\n")
|
var wg sync.WaitGroup
|
||||||
if ipv6Mode {
|
var mu sync.Mutex
|
||||||
fmt.Println("开始延迟测速（模式：TCP IPv6，端口：" + strconv.Itoa(tcpPort) + "）：")
|
var data = make([]CloudflareIPData, 0)
|
||||||
} else {
|
var data_2 = make([]CloudflareIPData, 0)
|
||||||
fmt.Println("开始延迟测速（模式：TCP IPv4，端口：" + strconv.Itoa(tcpPort) + "）：")
|
downloadTestTime = time.Duration(downloadSecond) * time.Second
|
||||||
}
|
|
||||||
control := make(chan bool, pingRoutine)
|
fmt.Println("# XIU2/CloudflareSpeedTest " + version + "\n")
|
||||||
for _, ip := range ips {
|
if ipv6Mode {
|
||||||
wg.Add(1)
|
fmt.Println("开始延迟测速（模式：TCP IPv6，端口：" + strconv.Itoa(tcpPort) + "）：")
|
||||||
control <- false
|
} else {
|
||||||
handleProgress := handleProgressGenerator(bar) // 多线程进度条
|
fmt.Println("开始延迟测速（模式：TCP IPv4，端口：" + strconv.Itoa(tcpPort) + "）：")
|
||||||
go tcpingGoroutine(&wg, &mu, ip, tcpPort, pingTime, &data, control, handleProgress)
|
}
|
||||||
}
|
control := make(chan bool, pingRoutine)
|
||||||
wg.Wait()
|
for _, ip := range ips {
|
||||||
bar.Finish()
|
wg.Add(1)
|
||||||
|
control <- false
|
||||||
sort.Sort(CloudflareIPDataSet(data)) // 排序
|
handleProgress := handleProgressGenerator(bar) // 多线程进度条
|
||||||
|
go tcpingGoroutine(&wg, &mu, ip, tcpPort, pingTime, &data, control, handleProgress)
|
||||||
// 下载测速
|
}
|
||||||
if !disableDownload { // 如果禁用下载测速就跳过
|
wg.Wait()
|
||||||
if len(data) > 0 { // IP数组长度(IP数量) 大于 0 时继续
|
bar.Finish()
|
||||||
if len(data) < downloadTestCount { // 如果IP数组长度(IP数量) 小于 下载测速次数，则次数改为IP数
|
|
||||||
//fmt.Println("\n[信息] IP 数量小于下载测速次数（" + strconv.Itoa(downloadTestCount) + " < " + strconv.Itoa(len(data)) + "），下载测速次数改为IP数。\n")
|
sort.Sort(CloudflareIPDataSet(data)) // 排序
|
||||||
downloadTestCount = len(data)
|
|
||||||
}
|
// 下载测速
|
||||||
var downloadTestCount_2 int // 临时的下载测速次数
|
if !disableDownload { // 如果禁用下载测速就跳过
|
||||||
if timeLimit == 9999 && speedLimit == 0 {
|
if len(data) > 0 { // IP数组长度(IP数量) 大于 0 时继续
|
||||||
downloadTestCount_2 = downloadTestCount // 如果没有指定条件，则临时的下载次数变量为下载测速次数
|
if len(data) < downloadTestCount { // 如果IP数组长度(IP数量) 小于 下载测速次数，则次数改为IP数
|
||||||
fmt.Println("开始下载测速：")
|
//fmt.Println("\n[信息] IP 数量小于下载测速次数（" + strconv.Itoa(downloadTestCount) + " < " + strconv.Itoa(len(data)) + "），下载测速次数改为IP数。\n")
|
||||||
} else if timeLimit > 0 || speedLimit >= 0 {
|
downloadTestCount = len(data)
|
||||||
downloadTestCount_2 = len(data) // 如果指定了任意一个条件，则临时的下载次数变量改为总数量
|
}
|
||||||
fmt.Println("开始下载测速（延迟时间上限：" + strconv.Itoa(timeLimit) + " ms，下载速度下限：" + strconv.Itoa(speedLimit) + " MB/s）：")
|
var downloadTestCount_2 int // 临时的下载测速次数
|
||||||
}
|
if timeLimit == 9999 && speedLimit == 0 {
|
||||||
bar = pb.Simple.Start(downloadTestCount_2)
|
downloadTestCount_2 = downloadTestCount // 如果没有指定条件，则临时变量为下载测速次数
|
||||||
for i := 0; i < downloadTestCount_2; i++ {
|
fmt.Println("开始下载测速：")
|
||||||
_, speed := DownloadSpeedHandler(data[i].ip)
|
} else if timeLimit > 0 || speedLimit >= 0 {
|
||||||
data[i].downloadSpeed = speed
|
downloadTestCount_2 = len(data) // 如果指定了任意一个条件，则临时变量改为总数量
|
||||||
bar.Add(1)
|
fmt.Println("开始下载测速（延迟时间上限：" + strconv.Itoa(timeLimit) + " ms，下载速度下限：" + strconv.Itoa(speedLimit) + " MB/s）：")
|
||||||
if int(data[i].pingTime) <= timeLimit && int(float64(speed)/1024/1024) >= speedLimit {
|
}
|
||||||
data_2 = append(data_2, data[i]) // 延迟和速度均满足条件时，添加到新数组中
|
bar = pb.Simple.Start(downloadTestCount)
|
||||||
if len(data_2) == downloadTestCount { // 满足条件的 IP =下载测速次数，则跳出循环
|
for i := 0; i < downloadTestCount_2; i++ {
|
||||||
break
|
_, speed := DownloadSpeedHandler(data[i].ip)
|
||||||
}
|
data[i].downloadSpeed = speed
|
||||||
} else if int(data[i].pingTime) > timeLimit {
|
if int(data[i].pingTime) <= timeLimit && int(float64(speed)/1024/1024) >= speedLimit {
|
||||||
break
|
data_2 = append(data_2, data[i]) // 延迟和速度均满足条件时，添加到新数组中
|
||||||
}
|
bar.Add(1)
|
||||||
}
|
if len(data_2) == downloadTestCount { // 满足条件的 IP =下载测速次数，则跳出循环
|
||||||
bar.Finish()
|
break
|
||||||
} else {
|
}
|
||||||
fmt.Println("\n[信息] IP数量为 0，跳过下载测速。")
|
} else if int(data[i].pingTime) > timeLimit {
|
||||||
}
|
break
|
||||||
}
|
}
|
||||||
|
}
|
||||||
if len(data_2) > 0 { // 如果该数字有内容，说明进行过指定条件的下载测速
|
bar.Finish()
|
||||||
if outputFile != "" {
|
} else {
|
||||||
ExportCsv(outputFile, data_2) // 输出结果到文件（指定延迟时间或下载速度的）
|
fmt.Println("\n[信息] IP数量为 0，跳过下载测速。")
|
||||||
}
|
}
|
||||||
printResult(data_2) // 显示最快结果（指定延迟时间或下载速度的）
|
}
|
||||||
} else {
|
|
||||||
if outputFile != "" {
|
if len(data_2) > 0 { // 如果该数字有内容，说明进行过指定条件的下载测速
|
||||||
ExportCsv(outputFile, data) // 输出结果到文件
|
sort.Sort(CloudflareIPDataSetD(data_2)) // 排序
|
||||||
}
|
if outputFile != "" {
|
||||||
printResult(data) // 显示最快结果
|
ExportCsv(outputFile, data_2) // 输出结果到文件（指定延迟时间或下载速度的）
|
||||||
}
|
}
|
||||||
}
|
printResult(data_2) // 显示最快结果（指定延迟时间或下载速度的）
|
||||||
|
} else {
|
||||||
// 显示最快结果
|
if outputFile != "" {
|
||||||
func printResult(data []CloudflareIPData) {
|
ExportCsv(outputFile, data) // 输出结果到文件
|
||||||
sysType := runtime.GOOS
|
}
|
||||||
if printResultNum > 0 { // 如果禁止直接输出结果就跳过
|
printResult(data) // 显示最快结果
|
||||||
dateString := convertToString(data) // 转为多维数组 [][]String
|
}
|
||||||
if len(dateString) > 0 { // IP数组长度(IP数量) 大于 0 时继续
|
}
|
||||||
if len(dateString) < printResultNum { // 如果IP数组长度(IP数量) 小于 打印次数，则次数改为IP数量
|
|
||||||
//fmt.Println("\n[信息] IP 数量小于显示结果数量（" + strconv.Itoa(printResultNum) + " < " + strconv.Itoa(len(dateString)) + "），显示结果数量改为IP数量。\n")
|
// 显示最快结果
|
||||||
printResultNum = len(dateString)
|
func printResult(data []CloudflareIPData) {
|
||||||
}
|
sysType := runtime.GOOS
|
||||||
if ipv6Mode { // IPv6 太长了，所以需要调整一下间隔
|
if printResultNum > 0 { // 如果禁止直接输出结果就跳过
|
||||||
fmt.Printf("%-40s%-5s%-5s%-5s%-6s%-11s\n", "IP 地址", "已发送", "已接收", "丢包率", "平均延迟", "下载速度 (MB/s)")
|
dateString := convertToString(data) // 转为多维数组 [][]String
|
||||||
for i := 0; i < printResultNum; i++ {
|
if len(dateString) > 0 { // IP数组长度(IP数量) 大于 0 时继续
|
||||||
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])
|
if len(dateString) < printResultNum { // 如果IP数组长度(IP数量) 小于 打印次数，则次数改为IP数量
|
||||||
}
|
//fmt.Println("\n[信息] IP 数量小于显示结果数量（" + strconv.Itoa(printResultNum) + " < " + strconv.Itoa(len(dateString)) + "），显示结果数量改为IP数量。\n")
|
||||||
} else {
|
printResultNum = len(dateString)
|
||||||
fmt.Printf("%-16s%-5s%-5s%-5s%-6s%-11s\n", "IP 地址", "已发送", "已接收", "丢包率", "平均延迟", "下载速度 (MB/s)")
|
}
|
||||||
for i := 0; i < printResultNum; i++ {
|
if ipv6Mode { // IPv6 太长了，所以需要调整一下间隔
|
||||||
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])
|
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])
|
||||||
|
}
|
||||||
if sysType == "windows" { // 如果是 Windows 系统，则需要按下 回车键 或 Ctrl+C 退出
|
} else {
|
||||||
if outputFile != "" {
|
fmt.Printf("%-16s%-5s%-5s%-5s%-6s%-11s\n", "IP 地址", "已发送", "已接收", "丢包率", "平均延迟", "下载速度 (MB/s)")
|
||||||
fmt.Printf("\n完整测速结果已写入 %v 文件，请使用记事本/表格软件查看。\n按下 回车键 或 Ctrl+C 退出。", outputFile)
|
for i := 0; i < printResultNum; i++ {
|
||||||
} else {
|
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])
|
||||||
fmt.Printf("\n按下 回车键 或 Ctrl+C 退出。")
|
}
|
||||||
}
|
}
|
||||||
var pause int
|
|
||||||
fmt.Scanln(&pause)
|
if versionNew != "" {
|
||||||
} else { // 其它系统直接退出
|
fmt.Println("\n发现新版本 [" + versionNew + "]！请前往 [https://github.com/XIU2/CloudflareSpeedTest] 更新！")
|
||||||
if outputFile != "" {
|
}
|
||||||
fmt.Println("\n完整测速结果已写入 " + outputFile + " 文件，请使用记事本/表格软件查看。")
|
|
||||||
}
|
if sysType == "windows" { // 如果是 Windows 系统，则需要按下 回车键 或 Ctrl+C 退出
|
||||||
}
|
if outputFile != "" {
|
||||||
} else {
|
fmt.Printf("\n完整测速结果已写入 %v 文件，请使用记事本/表格软件查看。\n按下 回车键 或 Ctrl+C 退出。", outputFile)
|
||||||
fmt.Println("\n[信息] IP数量为 0，跳过输出结果。")
|
} else {
|
||||||
}
|
fmt.Printf("\n按下 回车键 或 Ctrl+C 退出。")
|
||||||
} else {
|
}
|
||||||
fmt.Println("\n完整测速结果已写入 " + outputFile + " 文件，请使用记事本/表格软件查看。")
|
var pause int
|
||||||
}
|
fmt.Scanln(&pause)
|
||||||
}
|
} else { // 其它系统直接退出
|
||||||
|
if outputFile != "" {
|
||||||
|
fmt.Println("\n完整测速结果已写入 " + outputFile + " 文件，请使用记事本/表格软件查看。")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
fmt.Println("\n[信息] IP数量为 0，跳过输出结果。")
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
fmt.Println("\n完整测速结果已写入 " + outputFile + " 文件，请使用记事本/表格软件查看。")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// 检查更新
|
||||||
|
func checkUpdate() {
|
||||||
|
timeout := time.Duration(10 * time.Second)
|
||||||
|
client := http.Client{Timeout: timeout}
|
||||||
|
res, err := client.Get("https://api.xiuer.pw/ver/cloudflarespeedtest.txt")
|
||||||
|
if err == nil {
|
||||||
|
// 读取资源数据 body: []byte
|
||||||
|
body, err := ioutil.ReadAll(res.Body)
|
||||||
|
// 关闭资源流
|
||||||
|
res.Body.Close()
|
||||||
|
if err == nil {
|
||||||
|
if string(body) != version {
|
||||||
|
versionNew = string(body)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
344
tcping.go
344
tcping.go
@@ -1,172 +1,172 @@
|
|||||||
package main
|
package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"io"
|
"io"
|
||||||
"net"
|
"net"
|
||||||
"net/http"
|
"net/http"
|
||||||
"strconv"
|
"strconv"
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/VividCortex/ewma"
|
"github.com/VividCortex/ewma"
|
||||||
)
|
)
|
||||||
|
|
||||||
//bool connectionSucceed float32 time
|
//bool connectionSucceed float32 time
|
||||||
func tcping(ip net.IPAddr, tcpPort int) (bool, float32) {
|
func tcping(ip net.IPAddr, tcpPort int) (bool, float32) {
|
||||||
startTime := time.Now()
|
startTime := time.Now()
|
||||||
var fullAddress string
|
var fullAddress string
|
||||||
if ipv6Mode { // IPv6 需要加上 []
|
//fmt.Println(ip.String())
|
||||||
fullAddress = "[" + ip.String() + "]:" + strconv.Itoa(tcpPort)
|
if ipv6Mode { // IPv6 需要加上 []
|
||||||
} else {
|
fullAddress = "[" + ip.String() + "]:" + strconv.Itoa(tcpPort)
|
||||||
fullAddress = ip.String() + ":" + strconv.Itoa(tcpPort)
|
} else {
|
||||||
}
|
fullAddress = ip.String() + ":" + strconv.Itoa(tcpPort)
|
||||||
conn, err := net.DialTimeout("tcp", fullAddress, tcpConnectTimeout)
|
}
|
||||||
if err != nil {
|
conn, err := net.DialTimeout("tcp", fullAddress, tcpConnectTimeout)
|
||||||
return false, 0
|
if err != nil {
|
||||||
} else {
|
return false, 0
|
||||||
var endTime = time.Since(startTime)
|
} else {
|
||||||
var duration = float32(endTime.Microseconds()) / 1000.0
|
var endTime = time.Since(startTime)
|
||||||
_ = conn.Close()
|
var duration = float32(endTime.Microseconds()) / 1000.0
|
||||||
return true, duration
|
_ = conn.Close()
|
||||||
}
|
return true, duration
|
||||||
}
|
}
|
||||||
|
}
|
||||||
//pingReceived pingTotalTime
|
|
||||||
func checkConnection(ip net.IPAddr, tcpPort int) (int, float32) {
|
//pingReceived pingTotalTime
|
||||||
pingRecv := 0
|
func checkConnection(ip net.IPAddr, tcpPort int) (int, float32) {
|
||||||
var pingTime float32 = 0.0
|
pingRecv := 0
|
||||||
for i := 1; i <= failTime; i++ {
|
var pingTime float32 = 0.0
|
||||||
pingSucceed, pingTimeCurrent := tcping(ip, tcpPort)
|
for i := 1; i <= failTime; i++ {
|
||||||
if pingSucceed {
|
pingSucceed, pingTimeCurrent := tcping(ip, tcpPort)
|
||||||
pingRecv++
|
if pingSucceed {
|
||||||
pingTime += pingTimeCurrent
|
pingRecv++
|
||||||
}
|
pingTime += pingTimeCurrent
|
||||||
}
|
}
|
||||||
return pingRecv, pingTime
|
}
|
||||||
}
|
return pingRecv, pingTime
|
||||||
|
}
|
||||||
//return Success packetRecv averagePingTime specificIPAddr
|
|
||||||
func tcpingHandler(ip net.IPAddr, tcpPort int, pingCount int, progressHandler func(e progressEvent)) (bool, int, float32, net.IPAddr) {
|
//return Success packetRecv averagePingTime specificIPAddr
|
||||||
ipCanConnect := false
|
func tcpingHandler(ip net.IPAddr, tcpPort int, pingCount int, progressHandler func(e progressEvent)) (bool, int, float32, net.IPAddr) {
|
||||||
pingRecv := 0
|
ipCanConnect := false
|
||||||
var pingTime float32 = 0.0
|
pingRecv := 0
|
||||||
for !ipCanConnect {
|
var pingTime float32 = 0.0
|
||||||
pingRecvCurrent, pingTimeCurrent := checkConnection(ip, tcpPort)
|
for !ipCanConnect {
|
||||||
if pingRecvCurrent != 0 {
|
pingRecvCurrent, pingTimeCurrent := checkConnection(ip, tcpPort)
|
||||||
ipCanConnect = true
|
if pingRecvCurrent != 0 {
|
||||||
pingRecv = pingRecvCurrent
|
ipCanConnect = true
|
||||||
pingTime = pingTimeCurrent
|
pingRecv = pingRecvCurrent
|
||||||
} else {
|
pingTime = pingTimeCurrent
|
||||||
ip.IP[15]++
|
} else {
|
||||||
if ip.IP[15] == 0 {
|
ip.IP[15]++
|
||||||
break
|
if ip.IP[15] == 0 {
|
||||||
}
|
break
|
||||||
break
|
}
|
||||||
}
|
break
|
||||||
}
|
}
|
||||||
if ipCanConnect {
|
}
|
||||||
progressHandler(AvailableIPFound)
|
if ipCanConnect {
|
||||||
for i := failTime; i < pingCount; i++ {
|
progressHandler(AvailableIPFound)
|
||||||
pingSuccess, pingTimeCurrent := tcping(ip, tcpPort)
|
for i := failTime; i < pingCount; i++ {
|
||||||
progressHandler(NormalPing)
|
pingSuccess, pingTimeCurrent := tcping(ip, tcpPort)
|
||||||
if pingSuccess {
|
progressHandler(NormalPing)
|
||||||
pingRecv++
|
if pingSuccess {
|
||||||
pingTime += pingTimeCurrent
|
pingRecv++
|
||||||
}
|
pingTime += pingTimeCurrent
|
||||||
}
|
}
|
||||||
return true, pingRecv, pingTime / float32(pingRecv), ip
|
}
|
||||||
} else {
|
return true, pingRecv, pingTime / float32(pingRecv), ip
|
||||||
progressHandler(NoAvailableIPFound)
|
} else {
|
||||||
return false, 0, 0, net.IPAddr{}
|
progressHandler(NoAvailableIPFound)
|
||||||
}
|
return false, 0, 0, net.IPAddr{}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
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()
|
func tcpingGoroutine(wg *sync.WaitGroup, mutex *sync.Mutex, ip net.IPAddr, tcpPort int, pingCount int, csv *[]CloudflareIPData, control chan bool, progressHandler func(e progressEvent)) {
|
||||||
success, pingRecv, pingTimeAvg, currentIP := tcpingHandler(ip, tcpPort, pingCount, progressHandler)
|
defer wg.Done()
|
||||||
if success {
|
success, pingRecv, pingTimeAvg, currentIP := tcpingHandler(ip, tcpPort, pingCount, progressHandler)
|
||||||
mutex.Lock()
|
if success {
|
||||||
var cfdata CloudflareIPData
|
mutex.Lock()
|
||||||
cfdata.ip = currentIP
|
var cfdata CloudflareIPData
|
||||||
cfdata.pingReceived = pingRecv
|
cfdata.ip = currentIP
|
||||||
cfdata.pingTime = pingTimeAvg
|
cfdata.pingReceived = pingRecv
|
||||||
cfdata.pingCount = pingCount
|
cfdata.pingTime = pingTimeAvg
|
||||||
*csv = append(*csv, cfdata)
|
cfdata.pingCount = pingCount
|
||||||
mutex.Unlock()
|
*csv = append(*csv, cfdata)
|
||||||
}
|
mutex.Unlock()
|
||||||
<-control
|
}
|
||||||
}
|
<-control
|
||||||
|
}
|
||||||
func GetDialContextByAddr(fakeSourceAddr string) func(ctx context.Context, network, address string) (net.Conn, error) {
|
|
||||||
return func(ctx context.Context, network, address string) (net.Conn, error) {
|
func GetDialContextByAddr(fakeSourceAddr string) func(ctx context.Context, network, address string) (net.Conn, error) {
|
||||||
c, e := (&net.Dialer{}).DialContext(ctx, network, fakeSourceAddr)
|
return func(ctx context.Context, network, address string) (net.Conn, error) {
|
||||||
return c, e
|
c, e := (&net.Dialer{}).DialContext(ctx, network, fakeSourceAddr)
|
||||||
}
|
return c, e
|
||||||
}
|
}
|
||||||
|
}
|
||||||
//bool : can download,float32 downloadSpeed
|
|
||||||
func DownloadSpeedHandler(ip net.IPAddr) (bool, float32) {
|
//bool : can download,float32 downloadSpeed
|
||||||
var client = http.Client{
|
func DownloadSpeedHandler(ip net.IPAddr) (bool, float32) {
|
||||||
Transport: nil,
|
var client = http.Client{
|
||||||
CheckRedirect: nil,
|
Transport: nil,
|
||||||
Jar: nil,
|
CheckRedirect: nil,
|
||||||
Timeout: 0,
|
Jar: nil,
|
||||||
}
|
Timeout: downloadTestTime,
|
||||||
var fullAddress string
|
}
|
||||||
if ipv6Mode { // IPv6 需要加上 []
|
var fullAddress string
|
||||||
fullAddress = "[" + ip.String() + "]:443"
|
if ipv6Mode { // IPv6 需要加上 []
|
||||||
} else {
|
fullAddress = "[" + ip.String() + "]:443"
|
||||||
fullAddress = ip.String() + ":443"
|
} else {
|
||||||
}
|
fullAddress = ip.String() + ":443"
|
||||||
client.Transport = &http.Transport{
|
}
|
||||||
DialContext: GetDialContextByAddr(fullAddress),
|
client.Transport = &http.Transport{
|
||||||
}
|
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 {
|
||||||
defer func() { _ = response.Body.Close() }()
|
defer func() { _ = response.Body.Close() }()
|
||||||
if response.StatusCode == 200 {
|
if response.StatusCode == 200 {
|
||||||
timeStart := time.Now()
|
timeStart := time.Now()
|
||||||
timeEnd := timeStart.Add(downloadTestTime)
|
timeEnd := timeStart.Add(downloadTestTime)
|
||||||
|
|
||||||
contentLength := response.ContentLength
|
contentLength := response.ContentLength
|
||||||
buffer := make([]byte, downloadBufferSize)
|
buffer := make([]byte, downloadBufferSize)
|
||||||
|
|
||||||
var contentRead int64 = 0
|
var contentRead int64 = 0
|
||||||
var timeSlice = downloadTestTime / 100
|
var timeSlice = downloadTestTime / 100
|
||||||
var timeCounter = 1
|
var timeCounter = 1
|
||||||
var lastContentRead int64 = 0
|
var lastContentRead int64 = 0
|
||||||
|
|
||||||
var nextTime = timeStart.Add(timeSlice * time.Duration(timeCounter))
|
var nextTime = timeStart.Add(timeSlice * time.Duration(timeCounter))
|
||||||
e := ewma.NewMovingAverage()
|
e := ewma.NewMovingAverage()
|
||||||
|
|
||||||
for contentLength != contentRead {
|
for contentLength != contentRead {
|
||||||
var currentTime = time.Now()
|
var currentTime = time.Now()
|
||||||
if currentTime.After(nextTime) {
|
if currentTime.After(nextTime) {
|
||||||
timeCounter += 1
|
timeCounter += 1
|
||||||
nextTime = timeStart.Add(timeSlice * time.Duration(timeCounter))
|
nextTime = timeStart.Add(timeSlice * time.Duration(timeCounter))
|
||||||
e.Add(float64(contentRead - lastContentRead))
|
e.Add(float64(contentRead - lastContentRead))
|
||||||
lastContentRead = contentRead
|
lastContentRead = contentRead
|
||||||
}
|
}
|
||||||
if currentTime.After(timeEnd) {
|
if currentTime.After(timeEnd) {
|
||||||
break
|
break
|
||||||
}
|
}
|
||||||
bufferRead, err := response.Body.Read(buffer)
|
bufferRead, err := response.Body.Read(buffer)
|
||||||
contentRead += int64(bufferRead)
|
contentRead += int64(bufferRead)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if err != io.EOF {
|
if err != io.EOF {
|
||||||
break
|
break
|
||||||
} else {
|
} else {
|
||||||
e.Add(float64(contentRead-lastContentRead) / (float64(nextTime.Sub(currentTime)) / float64(timeSlice)))
|
e.Add(float64(contentRead-lastContentRead) / (float64(nextTime.Sub(currentTime)) / float64(timeSlice)))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return true, float32(e.Value()) / (float32(downloadTestTime.Seconds()) / 100)
|
return true, float32(e.Value()) / (float32(downloadTestTime.Seconds()) / 120)
|
||||||
} else {
|
} else {
|
||||||
return false, 0
|
return false, 0
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
312
util.go
312
util.go
@@ -1,148 +1,164 @@
|
|||||||
package main
|
package main
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"encoding/csv"
|
"encoding/csv"
|
||||||
"log"
|
"log"
|
||||||
"math/rand"
|
"math/rand"
|
||||||
"net"
|
"net"
|
||||||
"os"
|
"os"
|
||||||
"strconv"
|
"strconv"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/cheggaaa/pb/v3"
|
"github.com/cheggaaa/pb/v3"
|
||||||
)
|
)
|
||||||
|
|
||||||
type CloudflareIPData struct {
|
type CloudflareIPData struct {
|
||||||
ip net.IPAddr
|
ip net.IPAddr
|
||||||
pingCount int
|
pingCount int
|
||||||
pingReceived int
|
pingReceived int
|
||||||
recvRate float32
|
recvRate float32
|
||||||
downloadSpeed float32
|
downloadSpeed float32
|
||||||
pingTime float32
|
pingTime float32
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cf *CloudflareIPData) getRecvRate() float32 {
|
func (cf *CloudflareIPData) getRecvRate() float32 {
|
||||||
if cf.recvRate == 0 {
|
if cf.recvRate == 0 {
|
||||||
pingLost := cf.pingCount - cf.pingReceived
|
pingLost := cf.pingCount - cf.pingReceived
|
||||||
cf.recvRate = float32(pingLost) / float32(cf.pingCount)
|
cf.recvRate = float32(pingLost) / float32(cf.pingCount)
|
||||||
}
|
}
|
||||||
return cf.recvRate
|
return cf.recvRate
|
||||||
}
|
}
|
||||||
|
|
||||||
func ExportCsv(filePath string, data []CloudflareIPData) {
|
func ExportCsv(filePath string, data []CloudflareIPData) {
|
||||||
fp, err := os.Create(filePath)
|
fp, err := os.Create(filePath)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("创建文件["+filePath+"]句柄失败,%v", err)
|
log.Fatalf("创建文件["+filePath+"]句柄失败,%v", err)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
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()
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cf *CloudflareIPData) toString() []string {
|
func (cf *CloudflareIPData) toString() []string {
|
||||||
result := make([]string, 6)
|
result := make([]string, 6)
|
||||||
result[0] = cf.ip.String()
|
result[0] = cf.ip.String()
|
||||||
result[1] = strconv.Itoa(cf.pingCount)
|
result[1] = strconv.Itoa(cf.pingCount)
|
||||||
result[2] = strconv.Itoa(cf.pingReceived)
|
result[2] = strconv.Itoa(cf.pingReceived)
|
||||||
result[3] = strconv.FormatFloat(float64(cf.getRecvRate()), 'f', 2, 32)
|
result[3] = strconv.FormatFloat(float64(cf.getRecvRate()), 'f', 2, 32)
|
||||||
result[4] = strconv.FormatFloat(float64(cf.pingTime), 'f', 2, 32)
|
result[4] = strconv.FormatFloat(float64(cf.pingTime), 'f', 2, 32)
|
||||||
result[5] = strconv.FormatFloat(float64(cf.downloadSpeed)/1024/1024, 'f', 2, 32)
|
result[5] = strconv.FormatFloat(float64(cf.downloadSpeed)/1024/1024, 'f', 2, 32)
|
||||||
return result
|
return result
|
||||||
}
|
}
|
||||||
|
|
||||||
func convertToString(data []CloudflareIPData) [][]string {
|
func convertToString(data []CloudflareIPData) [][]string {
|
||||||
result := make([][]string, 0)
|
result := make([][]string, 0)
|
||||||
for _, v := range data {
|
for _, v := range data {
|
||||||
result = append(result, v.toString())
|
result = append(result, v.toString())
|
||||||
}
|
}
|
||||||
return result
|
return result
|
||||||
}
|
}
|
||||||
|
|
||||||
var pingTime int
|
var pingTime int
|
||||||
var pingRoutine int
|
var pingRoutine int
|
||||||
|
|
||||||
type progressEvent int
|
type progressEvent int
|
||||||
|
|
||||||
const (
|
const (
|
||||||
NoAvailableIPFound progressEvent = iota
|
NoAvailableIPFound progressEvent = iota
|
||||||
AvailableIPFound
|
AvailableIPFound
|
||||||
NormalPing
|
NormalPing
|
||||||
)
|
)
|
||||||
|
|
||||||
var url string
|
var url string
|
||||||
|
|
||||||
var downloadTestTime time.Duration
|
var downloadTestTime time.Duration
|
||||||
|
|
||||||
const downloadBufferSize = 1024
|
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 initRandSeed() {
|
|
||||||
rand.Seed(time.Now().UnixNano())
|
// 下载速度排序
|
||||||
}
|
type CloudflareIPDataSetD []CloudflareIPData
|
||||||
|
|
||||||
func randipEndWith() uint8 {
|
func initRandSeed() {
|
||||||
return uint8(rand.Intn(254) + 1)
|
rand.Seed(time.Now().UnixNano())
|
||||||
}
|
}
|
||||||
|
|
||||||
func GetRandomString() string {
|
func randipEndWith(num int) uint8 {
|
||||||
str := "0123456789abcdef"
|
return uint8(rand.Intn(num))
|
||||||
bytes := []byte(str)
|
}
|
||||||
result := []byte{}
|
|
||||||
r := rand.New(rand.NewSource(time.Now().UnixNano()))
|
func GetRandomString() string {
|
||||||
for i := 0; i < 4; i++ {
|
str := "0123456789abcdef"
|
||||||
result = append(result, bytes[r.Intn(len(bytes))])
|
bytes := []byte(str)
|
||||||
}
|
result := []byte{}
|
||||||
return string(result)
|
r := rand.New(rand.NewSource(time.Now().UnixNano()))
|
||||||
}
|
for i := 0; i < 4; i++ {
|
||||||
|
result = append(result, bytes[r.Intn(len(bytes))])
|
||||||
func ipPadding(ip string) string {
|
}
|
||||||
var ipLength int
|
return string(result)
|
||||||
var ipPrint string
|
}
|
||||||
ipPrint = ip
|
|
||||||
ipLength = len(ipPrint)
|
func ipPadding(ip string) string {
|
||||||
if ipLength < 15 {
|
var ipLength int
|
||||||
for i := 0; i <= 15-ipLength; i++ {
|
var ipPrint string
|
||||||
ipPrint += " "
|
ipPrint = ip
|
||||||
}
|
ipLength = len(ipPrint)
|
||||||
}
|
if ipLength < 15 {
|
||||||
return ipPrint
|
for i := 0; i <= 15-ipLength; i++ {
|
||||||
}
|
ipPrint += " "
|
||||||
|
}
|
||||||
func handleProgressGenerator(pb *pb.ProgressBar) func(e progressEvent) {
|
}
|
||||||
return func(e progressEvent) {
|
return ipPrint
|
||||||
switch e {
|
}
|
||||||
case NoAvailableIPFound:
|
|
||||||
pb.Add(pingTime)
|
func handleProgressGenerator(pb *pb.ProgressBar) func(e progressEvent) {
|
||||||
case AvailableIPFound:
|
return func(e progressEvent) {
|
||||||
pb.Add(failTime)
|
switch e {
|
||||||
case NormalPing:
|
case NoAvailableIPFound:
|
||||||
pb.Increment()
|
pb.Add(pingTime)
|
||||||
}
|
case AvailableIPFound:
|
||||||
}
|
pb.Add(failTime)
|
||||||
}
|
case NormalPing:
|
||||||
|
pb.Increment()
|
||||||
func (cfs CloudflareIPDataSet) Len() int {
|
}
|
||||||
return len(cfs)
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (cfs CloudflareIPDataSet) Less(i, j int) bool {
|
func (cfs CloudflareIPDataSet) Len() int {
|
||||||
if (cfs)[i].getRecvRate() != cfs[j].getRecvRate() {
|
return len(cfs)
|
||||||
return cfs[i].getRecvRate() < cfs[j].getRecvRate()
|
}
|
||||||
}
|
|
||||||
return cfs[i].pingTime < cfs[j].pingTime
|
func (cfs CloudflareIPDataSet) Less(i, j int) bool {
|
||||||
}
|
if (cfs)[i].getRecvRate() != cfs[j].getRecvRate() {
|
||||||
|
return cfs[i].getRecvRate() < cfs[j].getRecvRate()
|
||||||
func (cfs CloudflareIPDataSet) Swap(i, j int) {
|
}
|
||||||
cfs[i], cfs[j] = cfs[j], cfs[i]
|
return cfs[i].pingTime < cfs[j].pingTime
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (cfs CloudflareIPDataSet) Swap(i, j int) {
|
||||||
|
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]
|
||||||
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user