mirror of
https://github.com/XIU2/CloudflareSpeedTest.git
synced 2026-03-08 07:35:52 +08:00
Compare commits
42 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
2c4d115b83 | ||
|
|
bd16488cfb | ||
|
|
a1ae4f8e45 | ||
|
|
f4f1fdcd80 | ||
|
|
562789aa15 | ||
|
|
c54fb92537 | ||
|
|
07ef3fbb8f | ||
|
|
12066eec6c | ||
|
|
7079a6c7b7 | ||
|
|
a2fa9dadb3 | ||
|
|
f47ba5d06f | ||
|
|
93430a08ef | ||
|
|
295af17fc8 | ||
|
|
25e8ad170b | ||
|
|
b6e5438ec1 | ||
|
|
5b7791b892 | ||
|
|
0beea5df99 | ||
|
|
882678e1eb | ||
|
|
ffb2e54a7b | ||
|
|
154cf5564d | ||
|
|
c6449f6a4a | ||
|
|
021914f975 | ||
|
|
ce22f6b2a4 | ||
|
|
81c6a70a5c | ||
|
|
ce15d4741a | ||
|
|
32b5afaa88 | ||
|
|
73362a1d4c | ||
|
|
82cfd0123f | ||
|
|
a6f627f5fb | ||
|
|
12695563d7 | ||
|
|
d8316525ff | ||
|
|
3c8b51db36 | ||
|
|
1ed7fb7726 | ||
|
|
e8c847d2c9 | ||
|
|
eaaaa53c10 | ||
|
|
270dcab04b | ||
|
|
c1ba72b3a3 | ||
|
|
01b105d42d | ||
|
|
e3c0a3a742 | ||
|
|
7f6e374ae4 | ||
|
|
b22e7fd4af | ||
|
|
2e20a7c279 |
1
.gitattributes
vendored
Normal file
1
.gitattributes
vendored
Normal file
@@ -0,0 +1 @@
|
||||
script/*.* linguist-language=None
|
||||
232
README.md
232
README.md
@@ -6,25 +6,25 @@
|
||||
[](https://github.com/XIU2/CloudflareSpeedTest/)
|
||||
[](https://github.com/XIU2/CloudflareSpeedTest/)
|
||||
|
||||
## 前排提醒：[关于下载测速不可用 `0.00 MB/s` 的 情况说明 及 解决方法...](https://github.com/XIU2/CloudflareSpeedTest/issues/168)
|
||||
国外很多网站都在使用 Cloudflare CDN，但分配给中国内地访客的 IP 并不友好（延迟高、丢包多、速度慢）。
|
||||
虽然 Cloudflare 公开了所有 [IP 段](https://www.cloudflare.com/ips/) ，但想要在这么多 IP 中找到适合自己的，怕是要累死，于是就有了这个软件。
|
||||
|
||||
国外很多网站都在使用 Cloudflare CDN，但分配给中国内地访客的 IP 并不友好（延迟高、丢包多、速度慢）。
|
||||
虽然 Cloudflare 公开了所有 [IP 段](https://www.cloudflare.com/ips/) ，但想要在这么多 IP 中找到适合自己的，怕是要累死，于是就有了这个软件。
|
||||
**「自选优选 IP」测试 Cloudflare CDN 延迟和速度，获取最快 IP (IPv4+IPv6)**！好用的话**点个`⭐`鼓励一下叭~**
|
||||
|
||||
**「自选优选 IP」测试 Cloudflare CDN 延迟和速度，获取最快 IP (IPv4+IPv6)**！好用的话**点个`⭐`鼓励一下叭~**
|
||||
> _分享我其他开源项目：[**TrackersList.com** - 全网热门 BT Tracker 列表！有效提高 BT 下载速度~](https://github.com/XIU2/TrackersListCollection) <img src="https://img.shields.io/github/stars/XIU2/TrackersListCollection.svg?style=flat-square&label=Star&color=4285dd&logo=github" height="16px" />_
|
||||
> _[**UserScript** - 🐵 Github 高速下载、知乎增强、自动无缝翻页、护眼模式 等十几个**油猴脚本**！](https://github.com/XIU2/UserScript)<img src="https://img.shields.io/github/stars/XIU2/UserScript.svg?style=flat-square&label=Star&color=4285dd&logo=github" height="16px" />_
|
||||
|
||||
> _分享我其他开源项目：[**TrackersList.com** - 全网热门 BT Tracker 列表！有效提高 BT 下载速度~](https://github.com/XIU2/TrackersListCollection) <img src="https://img.shields.io/github/stars/XIU2/TrackersListCollection.svg?style=flat-square&label=Star&color=4285dd&logo=github" height="16px" />_
|
||||
> _[**UserScript** - 🐵 Github 高速下载、知乎增强、自动无缝翻页、护眼模式 等十几个**油猴脚本**！](https://github.com/XIU2/UserScript)<img src="https://img.shields.io/github/stars/XIU2/UserScript.svg?style=flat-square&label=Star&color=4285dd&logo=github" height="16px" />_
|
||||
> 本项目也支持对**其他 CDN / 网站 IP** 延迟测速（如：[CloudFront](https://github.com/XIU2/CloudflareSpeedTest/issues/180)、[Gcore](https://github.com/XIU2/CloudflareSpeedTest/issues/267) CDN），但下载测速需自行寻找地址
|
||||
|
||||
> 本项目也支持对**其他 CDN / 网站 IP** 延迟测速（如：[CloudFront IP 段](http://d7uri8nf7uskq.cloudfront.net/tools/list-cloudfront-ips)），但下载测速需自行寻找地址。
|
||||
> 对于**代理套 Cloudflare CDN** 的用户，须知这应为**备用方案**，而不应该是**唯一方案**，请勿过度依赖 [#217](https://github.com/XIU2/CloudflareSpeedTest/issues/217) [#188](https://github.com/XIU2/CloudflareSpeedTest/issues/188)
|
||||
|
||||
****
|
||||
## \# 快速使用
|
||||
|
||||
### 下载运行
|
||||
|
||||
1. 下载编译好的可执行文件 [蓝奏云](https://pan.lanzouo.com/b0742hkxe) / [Github](https://github.com/XIU2/CloudflareSpeedTest/releases) 并解压。
|
||||
2. 双击运行 `CloudflareST.exe` 文件（Windows 系统），等待测速完成...
|
||||
1. 下载编译好的可执行文件 [蓝奏云](https://pan.lanzouv.com/b0742hkxe) / [Github](https://github.com/XIU2/CloudflareSpeedTest/releases) 并解压。
|
||||
2. 双击运行 `CloudflareST.exe` 文件（Windows 系统），等待测速完成...
|
||||
|
||||
<details>
|
||||
<summary><code><strong>「 点击查看 Linux 系统下的使用示例 」</strong></code></summary>
|
||||
@@ -34,18 +34,18 @@
|
||||
以下命令仅为示例，版本号和文件名请前往 [**Releases**](https://github.com/XIU2/CloudflareSpeedTest/releases) 查看。
|
||||
|
||||
``` yaml
|
||||
# 如果是第一次使用，则建议创建新文件夹（后续更新请跳过该步骤）
|
||||
# 如果是第一次使用，则建议创建新文件夹（后续更新时，跳过该步骤）
|
||||
mkdir CloudflareST
|
||||
|
||||
# 进入文件夹（后续更新，只需要从这里重复下面的下载、解压命令即可）
|
||||
cd CloudflareST
|
||||
|
||||
# 下载 CloudflareST 压缩包（自行根据需求替换 URL 中 [版本号] 和 [文件名]）
|
||||
wget -N https://download.fastgit.org/XIU2/CloudflareSpeedTest/releases/download/v2.0.3/CloudflareST_linux_amd64.tar.gz
|
||||
# 考虑到国内直接从 Github 下载速度很慢，这里替换为镜像站了，如果还是下载很慢/无法下载，那就试试下面这几个镜像：
|
||||
# wget -N https://gh.xiu.workers.dev/https://github.com/XIU2/CloudflareSpeedTest/releases/download/v2.0.2/CloudflareST_linux_386.tar.gz
|
||||
# wget -N https://ghproxy.com/https://github.com/XIU2/CloudflareSpeedTest/releases/download/v2.0.2/CloudflareST_linux_386.tar.gz
|
||||
# 如果下载失败的话，尝试删除 -N 参数（如果是为了更新，则记得提前删除旧压缩包 rm CloudflareST_linux_386.tar.gz ）
|
||||
wget -N https://github.com/XIU2/CloudflareSpeedTest/releases/download/v2.1.0/CloudflareST_linux_amd64.tar.gz
|
||||
# 如果你是在国内服务器上下载，那么请使用下面这几个镜像加速：
|
||||
# wget -N https://download.fastgit.org/XIU2/CloudflareSpeedTest/releases/download/v2.1.0/CloudflareST_linux_amd64.tar.gz
|
||||
# wget -N https://ghproxy.com/https://github.com/XIU2/CloudflareSpeedTest/releases/download/v2.1.0/CloudflareST_linux_amd64.tar.gz
|
||||
# 如果下载失败的话，尝试删除 -N 参数（如果是为了更新，则记得提前删除旧压缩包 rm CloudflareST_linux_amd64.tar.gz ）
|
||||
|
||||
# 解压（不需要删除旧文件，会直接覆盖，自行根据需求替换 文件名）
|
||||
tar -zxf CloudflareST_linux_amd64.tar.gz
|
||||
@@ -60,19 +60,18 @@ chmod +x CloudflareST
|
||||
./CloudflareST -dd -tll 90
|
||||
```
|
||||
|
||||
> 如果平**均延迟非常低**（如 0.xx），则说明 CloudflareST **测速时走了代理**，请先关闭代理软件后再测速。
|
||||
> 如果在**路由器**上运行（如 OpenWrt），请先关闭路由器内的代理，否则测速结果会**不准确且无法使用**。
|
||||
> 如果平**均延迟非常低**（如 0.xx），则说明 CloudflareST **测速时走了代理**，请先关闭代理软件后再测速。
|
||||
> 如果在**路由器**上运行，建议先关闭路由器内的代理（或将其排除），否则测速结果可能会**不准确/无法使用**。
|
||||
|
||||
</details>
|
||||
|
||||
****
|
||||
|
||||
> _在**手机**上独立运行 CloudflareST 测速的简单教程：**[Android](https://github.com/XIU2/CloudflareSpeedTest/discussions/61)、[IOS](https://github.com/XIU2/CloudflareSpeedTest/issues/151)**_
|
||||
> _**建议测速时避开晚上高峰期（20:00~24:00）**，否则测速结果会与其他时间**相差很大...**_
|
||||
> _在**手机**上独立运行 CloudflareST 测速的简单教程：**[Android](https://github.com/XIU2/CloudflareSpeedTest/discussions/61)、[Android APP](https://github.com/xianshenglu/cloudflare-ip-tester-app)、[IOS](https://github.com/XIU2/CloudflareSpeedTest/issues/151)**_
|
||||
|
||||
### 结果示例
|
||||
|
||||
测速完毕后，默认会显示**最快的 10 个 IP**，示例（我联通白天测速结果）：
|
||||
测速完毕后，默认会显示**最快的 10 个 IP**，示例（我联通白天测速结果）：
|
||||
|
||||
``` bash
|
||||
IP 地址 已发送 已接收 丢包率 平均延迟 下载速度 (MB/s)
|
||||
@@ -89,17 +88,18 @@ IP 地址 已发送 已接收 丢包率 平均延迟 下载速度
|
||||
...
|
||||
|
||||
# 如果平均延迟非常低（如 0.xx），则说明 CloudflareST 测速时走了代理，请先关闭代理软件后再测速。
|
||||
# 如果延迟很低 (几十ms)，且你也不是移动 (香港直连)，那么你就是遇到假墙 IP 了，记得加上 -tll 参数。
|
||||
# 如果在路由器上运行（如 OpenWrt），请先关闭路由器内的代理，否则测速结果会不准确且无法使用。
|
||||
# 如果在路由器上运行，请先关闭路由器内的代理（或将其排除），否则测速结果可能会不准确/无法使用。
|
||||
|
||||
# 因为每次测速都是在每个 IP 段中随机 IP，所以每次的测速结果都不可能相同，这是正常的！
|
||||
|
||||
# 注意！我发现电脑开机后第一次测速延迟会明显偏高，后续测速都正常，建议大家开机后第一次随便测几个 IP 后再正式开始测速。
|
||||
|
||||
# 软件是先 延迟测速并按从低到高排序后，再从 最低延迟的 IP 开始下载测速的，所以：
|
||||
```
|
||||
|
||||
测速结果第一行就是**既下载速度最快、又平均延迟最低的最快 IP**！至于拿来干嘛？取决于你~
|
||||
测速结果第一行就是**既下载速度最快、又平均延迟最低的最快 IP**！至于拿来干嘛？取决于你~
|
||||
|
||||
完整结果保存在当前目录下的 `result.csv` 文件中，用**记事本/表格软件**打开，格式如下：
|
||||
完整结果保存在当前目录下的 `result.csv` 文件中，用**记事本/表格软件**打开，格式如下：
|
||||
|
||||
```
|
||||
IP 地址, 已发送, 已接收, 丢包率, 平均延迟, 下载速度 (MB/s)
|
||||
@@ -111,7 +111,7 @@ IP 地址, 已发送, 已接收, 丢包率, 平均延迟, 下载速度 (MB/s)
|
||||
****
|
||||
## \# 进阶使用
|
||||
|
||||
直接运行使用的是默认参数，如果想要测速结果更全面、更符合自己的要求，可以自定义参数。
|
||||
直接运行使用的是默认参数，如果想要测速结果更全面、更符合自己的要求，可以自定义参数。
|
||||
|
||||
``` cmd
|
||||
C:\>CloudflareST.exe -h
|
||||
@@ -122,47 +122,58 @@ https://github.com/XIU2/CloudflareSpeedTest
|
||||
|
||||
参数：
|
||||
-n 200
|
||||
测速线程数量；越多测速越快，性能弱的设备 (如路由器) 请勿太高；(默认 200 最多 1000)
|
||||
延迟测速线程；越多延迟测速越快，性能弱的设备 (如路由器) 请勿太高；(默认 200 最多 1000)
|
||||
-t 4
|
||||
延迟测速次数；单个 IP 延迟测速次数，为 1 时将过滤丢包的IP，TCP协议；(默认 4 次)
|
||||
-tp 443
|
||||
指定测速端口；延迟测速/下载测速时使用的端口；(默认 443 端口)
|
||||
延迟测速次数；单个 IP 延迟测速次数，为 1 时将过滤丢包的IP；(默认 4 次)
|
||||
-dn 10
|
||||
下载测速数量；延迟测速并排序后，从最低延迟起下载测速的数量；(默认 10 个)
|
||||
-dt 10
|
||||
下载测速时间；单个 IP 下载测速最长时间，不能太短；(默认 10 秒)
|
||||
-tp 443
|
||||
指定测速端口；延迟测速/下载测速时使用的端口；(默认 443 端口)
|
||||
-url https://cf.xiu2.xyz/url
|
||||
下载测速地址；用来下载测速的 Cloudflare CDN 文件地址，默认地址不保证可用性，建议自建；
|
||||
指定测速地址；延迟测速(HTTPing)/下载测速时使用的地址，默认地址不保证可用性，建议自建；
|
||||
|
||||
-httping
|
||||
切换测速模式；延迟测速模式改为 HTTP 协议，所用测试地址为 [-url] 参数；(默认 TCPing)
|
||||
-httping-code 200
|
||||
有效状态代码；HTTPing 延迟测速时网页返回的有效 HTTP 状态码，仅限一个；(默认 200 301 302)
|
||||
-cfcolo HKG,KHH,NRT,LAX,SEA,SJC,FRA,MAD
|
||||
匹配指定地区；地区名为当地机场三字码，英文逗号分隔，仅 HTTPing 模式可用；(默认 所有地区)
|
||||
|
||||
-tl 200
|
||||
平均延迟上限；只输出低于指定平均延迟的 IP，可与其他上限/下限搭配；(默认 9999 ms)
|
||||
-tll 40
|
||||
平均延迟下限；只输出高于指定平均延迟的 IP，可与其他上限/下限搭配、过滤假墙 IP；(默认 0 ms)
|
||||
平均延迟下限；只输出高于指定平均延迟的 IP，可与其他上限/下限搭配；(默认 0 ms)
|
||||
-sl 5
|
||||
下载速度下限；只输出高于指定下载速度的 IP，凑够指定数量 [-dn] 才会停止测速；(默认 0.00 MB/s)
|
||||
|
||||
-p 10
|
||||
显示结果数量；测速后直接显示指定数量的结果，为 0 时不显示结果直接退出；(默认 10 个)
|
||||
-f ip.txt
|
||||
IP段数据文件；如路径含有空格请加上引号；支持其他 CDN IP段；(默认 ip.txt)
|
||||
-ip 1.1.1.1,2.2.2.2/24,2606:4700::/32
|
||||
指定IP段数据；直接通过参数指定要测速的 IP 段数据，英文逗号分隔；(默认 空)
|
||||
-o result.csv
|
||||
写入结果文件；如路径含有空格请加上引号；值为空时不写入文件 [-o ""]；(默认 result.csv)
|
||||
|
||||
-dd
|
||||
禁用下载测速；禁用后测速结果会按延迟排序 (默认按下载速度排序)；(默认 启用)
|
||||
-ipv6
|
||||
IPv6测速模式；确保 IP 段数据文件内只包含 IPv6 IP段，软件不支持同时测速 IPv4+IPv6；(默认 IPv4)
|
||||
-allip
|
||||
测速全部的IP；对 IP 段中的每个 IP (仅支持 IPv4) 进行测速；(默认 每个 IP 段随机测速一个 IP)
|
||||
测速全部的IP；对 IP 段中的每个 IP (仅支持 IPv4) 进行测速；(默认 每个 /24 段随机测速一个 IP)
|
||||
|
||||
-v
|
||||
打印程序版本+检查版本更新
|
||||
打印程序版本 + 检查版本更新
|
||||
-h
|
||||
打印帮助说明
|
||||
```
|
||||
|
||||
### 使用示例
|
||||
|
||||
Windows 要指定参数需要在 CMD 中运行，或者把参数添加到快捷方式目标中。
|
||||
Windows 要指定参数需要在 CMD 中运行，或者把参数添加到快捷方式目标中。
|
||||
|
||||
> **注意**：各参数均有**默认值**，使用默认值的参数是可以省略的（**按需选择**），参数**不分前后顺序**。
|
||||
> **提示**：Linux 系统只需要把下面命令中的 `CloudflareST.exe` 改为 `./CloudflareST` 即可。
|
||||
> **注意**：各参数均有**默认值**，使用默认值的参数是可以省略的（**按需选择**），参数**不分前后顺序**。
|
||||
> **提示**：Linux 系统只需要把下面命令中的 `CloudflareST.exe` 改为 `./CloudflareST` 即可。
|
||||
|
||||
****
|
||||
|
||||
@@ -177,11 +188,17 @@ Windows 要指定参数需要在 CMD 中运行，或者把参数添加到快捷
|
||||
|
||||
很多人打开 CMD 以**绝对路径**运行 CloudflareST 会报错，这是因为默认的 `-f ip.txt` 参数是相对路径，需要指定绝对路径的 ip.txt 才行，但这样毕竟太麻烦了，因此还是建议进入 CloudflareST 程序目录下，以**相对路径**方式运行：
|
||||
|
||||
**方式 一**：
|
||||
1. 打开 CloudflareST 程序所在目录
|
||||
2. 空白处按下 <kbd>Shift + 鼠标右键</kbd> 显示右键菜单
|
||||
3. 选择 **\[在此处打开命令窗口\]** 来打开 CMD 窗口，此时默认就位于当前目录下
|
||||
4. 输入带参数的命令，如：`CloudflareST.exe -tll 50 -tl 200`即可运行
|
||||
|
||||
**方式 二**：
|
||||
1. 打开 CloudflareST 程序所在目录
|
||||
2. 直接在文件夹地址栏中全选并输入 `cmd` 回车来打开 CMD 窗口，此时默认就位于当前目录下
|
||||
4. 输入带参数的命令，如：`CloudflareST.exe -tll 50 -tl 200`即可运行
|
||||
|
||||
> 当然你也可以随便打开一个 CMD 窗口，然后输入如 `cd /d "D:\Program Files\CloudflareST"` 来进入程序目录
|
||||
|
||||
</details>
|
||||
@@ -220,11 +237,64 @@ D:\ABC\CloudflareST\CloudflareST.exe -n 500 -t 4 -dn 20 -dt 5 -o " "
|
||||
|
||||
****
|
||||
``` bash
|
||||
# 测速 IPv4 时，需要指定 IPv4 数据文件（-f 默认值就是 ip.txt，所以该参数可以省略）
|
||||
# 测速 IPv4 时，需要指定 IPv4 数据文件（-f 默认值就是 ip.txt，所以该参数可省略）
|
||||
CloudflareST.exe -f ip.txt
|
||||
|
||||
# 测速 IPv6 时，需要指定 IPv6 数据文件( ipv6.txt ) 的同时再加上 -ipv6 参数
|
||||
CloudflareST.exe -f ipv6.txt -ipv6
|
||||
# 测速 IPv6 时，需要指定 IPv6 数据文件（v2.1.0 版本后支持 IPv4+IPv6 混合测速并移除了 -ipv6 参数）
|
||||
CloudflareST.exe -f ipv6.txt
|
||||
|
||||
# 当然你也可以将 IPv4 IPv6 混合在一起测速，也可以直接通过参数指定要测速的 IP
|
||||
CloudflareST.exe -ip 1.1.1.1,2606:4700::/32
|
||||
```
|
||||
|
||||
> 测速 IPv6 时，可能会注意到每次测速数量都不一样，了解原因： [#120](https://github.com/XIU2/CloudflareSpeedTest/issues/120)
|
||||
> 因为 IPv6 太多（以亿为单位），且绝大部分 IP 段压根未启用，所以我只扫了一部分可用的 IPv6 段写到 `ipv6.txt` 文件中，有兴趣的可以自行扫描增删，ASN 数据源来自：[bgp.he.net](https://bgp.he.net/AS13335#_prefixes6)
|
||||
|
||||
</details>
|
||||
|
||||
****
|
||||
|
||||
#### \# HTTPing
|
||||
|
||||
<details>
|
||||
<summary><code><strong>「 点击展开 查看内容 」</strong></code></summary>
|
||||
|
||||
****
|
||||
|
||||
目前有两种延迟测速模式，分别为 **TCP 协议、HTTP 协议**。
|
||||
TCP 协议耗时更短、消耗资源更少，超时时间为 1 秒，该协议为默认模式。
|
||||
HTTP 协议适用于快速测试某域名指向某 IP 时是否可以访问，超时时间为 2 秒。
|
||||
|
||||
``` bash
|
||||
# 只需加上 -httping 参数即可切换到 HTTP 协议延迟测速模式
|
||||
CloudflareST.exe -httping
|
||||
|
||||
# 软件会根据访问时网页返回的有效 HTTP 状态码来判断可用性（当然超时也算），默认对返回 200 301 302 这三个 HTTP 状态码的视为有效，可以手动指定认为有效的 HTTP 状态码，但只能指定一个（你需要提前确定测试地址正常情况下会返回哪个状态码）
|
||||
CloudflareST.exe -httping -httping-code 200
|
||||
|
||||
# 通过 -url 参数来指定 HTTPing 测试地址（可以是任意网页 URL，不局限于具体文件地址）
|
||||
CloudflareST.exe -httping -url https://cf.xiu2.xyz/url
|
||||
|
||||
# 注意：如果测速地址为 HTTP 协议，记得加上 -tp 80（这个参数会影响 延迟测速/下载测速 时使用的端口）
|
||||
CloudflareST.exe -httping -tp 80 -url http://xxx/xxx
|
||||
```
|
||||
|
||||
</details>
|
||||
|
||||
****
|
||||
|
||||
#### \# 匹配指定地区(colo 机场三字码)
|
||||
|
||||
<details>
|
||||
<summary><code><strong>「 点击展开 查看内容 」</strong></code></summary>
|
||||
|
||||
****
|
||||
|
||||
``` bash
|
||||
# 指定地区名后，延迟测速后得到的结果就都是指定地区的 IP 了
|
||||
# 节点地区名为当地机场三字码，指定多个时用英文逗号分隔
|
||||
# 注意，该参数只有在 HTTPing 延迟测速模式下才可用（因为要访问网页来获得）
|
||||
CloudflareST.exe -cfcolo HKG,KHH,NRT,LAX,SEA,SJC,FRA,MAD
|
||||
```
|
||||
|
||||
</details>
|
||||
@@ -276,24 +346,20 @@ C:\abc\CloudflareST.exe -f C:\abc\4.txt -o C:\abc\result.csv -dd
|
||||
|
||||
****
|
||||
|
||||
#### \# 自定义下载测速地址
|
||||
#### \# 自定义测速地址
|
||||
|
||||
<details>
|
||||
<summary><code><strong>「 点击展开 查看内容 」</strong></code></summary>
|
||||
|
||||
****
|
||||
|
||||
因为目前默认下载测速地址流量太大被 Cloudflare 限速，因此建议大家**改用其他**下载测速地址（如下面的 Cloudflare 官方下载测速地址），更多请见： [#168](https://github.com/XIU2/CloudflareSpeedTest/issues/168)
|
||||
|
||||
``` bash
|
||||
# 该参数适用于下载测速 及 HTTP 协议的延迟测速，对于后者该地址可以是任意网页 URL（不局限于具体文件地址）
|
||||
|
||||
# 地址要求：可以直接下载、文件大小超过 200MB、用的是 Cloudflare CDN
|
||||
CloudflareST.exe -url https://cf.xiu2.xyz/url
|
||||
|
||||
# 因为默认下载测速地址的文件大小只有 300MB，如果你速度太快的话，测速结果可能会低于实际速度。
|
||||
# 因此推荐使用 Cloudflare CDN 官方下载测速地址（300MB 且可自定义大小，即末尾数字）：
|
||||
CloudflareST.exe -url https://speed.cloudflare.com/__down?bytes=300000000
|
||||
|
||||
# 注意：如果下载测速地址为 HTTP 协议，记得加上 -tp 80（这个参数会影响 延迟测速/下载测速 时使用的端口）
|
||||
# 注意：如果测速地址为 HTTP 协议，记得加上 -tp 80（这个参数会影响 延迟测速/下载测速 时使用的端口）
|
||||
CloudflareST.exe -tp 80 -url http://xxx/xxx
|
||||
```
|
||||
|
||||
@@ -301,14 +367,14 @@ CloudflareST.exe -tp 80 -url http://xxx/xxx
|
||||
|
||||
****
|
||||
|
||||
#### \# 自定义测速条件
|
||||
#### \# 自定义测速条件（指定 延迟/下载速度 的目标范围）
|
||||
|
||||
<details>
|
||||
<summary><code><strong>「 点击展开 查看内容 」</strong></code></summary>
|
||||
|
||||
****
|
||||
|
||||
- 指定 **[平均延迟下限]** 条件（用于过滤**被假蔷的 IP**，这类 IP 都被 TCP 劫持，因此延迟很低只有几十ms）
|
||||
- 指定 **[平均延迟下限]** 条件
|
||||
|
||||
``` bash
|
||||
# 平均延迟下限：40 ms （一般除了移动直连香港外，几乎不存在低于 100ms 的，自行测试适合的下限延迟）
|
||||
@@ -324,7 +390,7 @@ CloudflareST.exe -tll 40
|
||||
CloudflareST.exe -tl 200 -dn 10
|
||||
```
|
||||
|
||||
> 如果没有一个 IP **平均延迟低于 200ms**，那么不会输出任何内容。
|
||||
> 如果没有一个 IP **平均延迟低于 200ms**，那么不会输出任何内容。
|
||||
|
||||
****
|
||||
|
||||
@@ -346,7 +412,7 @@ CloudflareST.exe -tl 200 -dd
|
||||
CloudflareST.exe -sl 5 -dn 10
|
||||
```
|
||||
|
||||
> 没有指定平均延迟上限时，如果一直**凑不够**满足条件的 IP 数量，就会**一直测速**下去。
|
||||
> 没有指定平均延迟上限时，如果一直**凑不够**满足条件的 IP 数量，就会**一直测速**下去。
|
||||
> 所以建议**同时指定 [下载速度下限] + [平均延迟上限]**，这样测速到指定延迟上限还没凑够数量，就会终止测速。
|
||||
|
||||
****
|
||||
@@ -360,11 +426,11 @@ CloudflareST.exe -sl 5 -dn 10
|
||||
CloudflareST.exe -tl 200 -sl 5.6 -dn 10
|
||||
```
|
||||
|
||||
> 如果没有一个 IP **平均延迟低于 200ms**，那么不会输出任何内容。
|
||||
> 如果没有一个 IP **下载速度高于 5.6 MB/s**，那么就会**和不指定 [下载速度下限] 条件一样**输出结果。
|
||||
> 如果没有一个 IP **平均延迟低于 200ms**，那么不会输出任何内容。
|
||||
> 如果没有一个 IP **下载速度高于 5.6 MB/s**，那么就会**和不指定 [下载速度下限] 条件一样**输出结果。
|
||||
> 所以建议先不指定条件测速一遍，看看平均延迟和下载速度大概在什么范围，避免指定条件**过低/过高**！
|
||||
|
||||
> 因为Cloudflare 公开的 IP 段是**回源 IP+任播 IP**，而**回源 IP**是无法使用的，所以下载测速是 0.00。
|
||||
> 因为Cloudflare 公开的 IP 段是**回源 IP+任播 IP**，而**回源 IP**是无法使用的，所以下载测速是 0.00。
|
||||
> 运行时可以加上 `-sl 0.01`（下载速度下限），过滤掉**回源 IP**（下载测速低于 0.01MB/s 的结果）。
|
||||
|
||||
</details>
|
||||
@@ -378,7 +444,21 @@ CloudflareST.exe -tl 200 -sl 5.6 -dn 10
|
||||
|
||||
****
|
||||
|
||||
如果要单独**对一个或多个 IP 进行测速**，只需要把这些 IP 按如下格式写入到任意文本文件中，例如：`1.txt`
|
||||
**方式 一**：
|
||||
直接通过参数指定要测速的 IP 段数据。
|
||||
``` bash
|
||||
# 先进入 CloudflareST 所在目录，然后运行：
|
||||
# Windows 系统（在 CMD 中运行）
|
||||
CloudflareST.exe -ip 1.1.1.1,2.2.2.2/24,2606:4700::/32
|
||||
|
||||
# Linux 系统
|
||||
./CloudflareST -ip 1.1.1.1,2.2.2.2/24,2606:4700::/32
|
||||
```
|
||||
|
||||
****
|
||||
|
||||
**方式 二**：
|
||||
或者把这些 IP 按如下格式写入到任意文本文件中，例如：`1.txt`
|
||||
|
||||
```
|
||||
1.1.1.1
|
||||
@@ -386,11 +466,11 @@ CloudflareST.exe -tl 200 -sl 5.6 -dn 10
|
||||
1.0.0.1/24
|
||||
```
|
||||
|
||||
> 单个 IP 的话可以省略 `/32` 子网掩码了（即 `1.1.1.1`等同于 `1.1.1.1/32`）。
|
||||
> 单个 IP 的话可以省略 `/32` 子网掩码了（即 `1.1.1.1`等同于 `1.1.1.1/32`）。
|
||||
> 子网掩码 `/24` 指的是这个 IP 最后一段，即 `1.0.0.1~1.0.0.255`。
|
||||
|
||||
|
||||
然后运行 CloudflareST 时加上启动参数 `-f 1.txt` 即可。
|
||||
然后运行 CloudflareST 时加上启动参数 `-f 1.txt` 来指定 IP 段数据文件。
|
||||
|
||||
``` bash
|
||||
# 先进入 CloudflareST 所在目录，然后运行：
|
||||
@@ -413,7 +493,7 @@ CloudflareST.exe -f 1.txt
|
||||
|
||||
但就如 [**#8**](https://github.com/XIU2/CloudflareSpeedTest/issues/8) 所说，一个个添加域名到 Hosts 实在**太麻烦**了，于是我就找到了个**一劳永逸**的办法！
|
||||
|
||||
可以看这个 [**还在一个个添加 Hosts？完美本地加速所有使用 Cloudflare CDN 的网站方法来了！**](https://github.com/XIU2/CloudflareSpeedTest/discussions/71)
|
||||
可以看这个 [**还在一个个添加 Hosts？完美本地加速所有使用 Cloudflare CDN 的网站方法来了！**](https://github.com/XIU2/CloudflareSpeedTest/discussions/71) 和另一个[依靠本地 DNS 服务来修改域名解析 IP 为自选 IP](https://github.com/XIU2/CloudflareSpeedTest/issues/115) 的教程。
|
||||
|
||||
****
|
||||
|
||||
@@ -427,21 +507,43 @@ CloudflareST.exe -f 1.txt
|
||||
|
||||
## 问题反馈
|
||||
|
||||
如果你遇到什么问题，可以先去 [**Issues**](https://github.com/XIU2/CloudflareSpeedTest/issues) 里看看是否有别人问过了（记得去看下 [**Closed**](https://github.com/XIU2/CloudflareSpeedTest/issues?q=is%3Aissue+is%3Aclosed) 的）。
|
||||
如果你遇到什么问题，可以先去 [**Issues**](https://github.com/XIU2/CloudflareSpeedTest/issues) 里看看是否有别人问过了（记得去看下 [**Closed**](https://github.com/XIU2/CloudflareSpeedTest/issues?q=is%3Aissue+is%3Aclosed) 的）。
|
||||
如果没找到类似问题，请新开个 [**Issues**](https://github.com/XIU2/CloudflareSpeedTest/issues/new) 来告诉我！
|
||||
|
||||
> _有问题请**大胆告诉我**，描述越详细越好（必要时可远程协助），如果不说那我怎么去完善功能或~~修复 BUG~~ 呢？！_
|
||||
> _有问题请**大胆告诉我**，描述越详细越好（随时可远程协助），如果不说那我怎么去完善功能或~~修复 BUG~~ 呢？！_
|
||||
|
||||
****
|
||||
|
||||
## 赞赏支持
|
||||
|
||||
|
||||
|
||||
****
|
||||
|
||||
## 衍生项目
|
||||
|
||||
- _https://github.com/xianshenglu/cloudflare-ip-tester-app_
|
||||
_**CloudflareST 安卓版 APP [#202](https://github.com/XIU2/CloudflareSpeedTest/issues/202)**_
|
||||
|
||||
- _https://github.com/mingxiaoyu/luci-app-cloudflarespeedtest_
|
||||
_**CloudflareST OpenWrt 路由器插件版 [#174](https://github.com/XIU2/CloudflareSpeedTest/issues/174)**_
|
||||
|
||||
- _https://github.com/immortalwrt-collections/openwrt-cdnspeedtest_
|
||||
_**CloudflareST OpenWrt 原生编译版本 [#64](https://github.com/XIU2/CloudflareSpeedTest/discussions/64)**_
|
||||
|
||||
> _此处仅收集了在本项目 Issues 中宣传过的部分 CloudflareST 相关衍生项目，如果有遗漏可以告诉我~_
|
||||
|
||||
****
|
||||
|
||||
## 感谢项目
|
||||
|
||||
* https://github.com/Spedoske/CloudflareScanner
|
||||
- _https://github.com/Spedoske/CloudflareScanner_
|
||||
|
||||
> _因为该项目已经很长时间没更新了，而我又产生了很多功能需求，所以我临时学了下 Go 语言就上手了（菜）..._
|
||||
> _因为该项目已经很长时间没更新了，而我又产生了很多功能需求，所以我临时学了下 Go 语言就上手了（菜）..._
|
||||
> _本软件基于该项目制作，但**已添加大量功能及修复 BUG**，并根据大家的使用反馈积极添加、优化功能（闲）..._
|
||||
|
||||
****
|
||||
|
||||
## License
|
||||
The GPL-3.0 License.
|
||||
|
||||
The GPL-3.0 License.
|
||||
3
ip.txt
3
ip.txt
@@ -9,8 +9,7 @@
|
||||
197.234.240.0/22
|
||||
198.41.128.0/17
|
||||
162.158.0.0/15
|
||||
104.16.0.0/13
|
||||
104.24.0.0/14
|
||||
104.16.0.0/12
|
||||
172.64.0.0/17
|
||||
172.64.128.0/18
|
||||
172.64.192.0/19
|
||||
|
||||
103
ipv6.txt
103
ipv6.txt
@@ -1,13 +1,8 @@
|
||||
2400:cb00:2049::/48
|
||||
2400:cb00:f00e::/48
|
||||
2606:4700::/32
|
||||
2606:4700::6810:0/112
|
||||
2606:4700:10::/96
|
||||
2606:4700:10::6814:0/112
|
||||
2606:4700:10::ac43:0/112
|
||||
2606:4700:10::/48
|
||||
2606:4700:130::/48
|
||||
2606:4700:130:436c::/64
|
||||
2606:4700:130:436c:6f75::/80
|
||||
2606:4700:130:436c:6f75:6466::/96
|
||||
2606:4700:130:436c:6f75:6466:6c61:0/112
|
||||
2606:4700:3000::/48
|
||||
2606:4700:3001::/48
|
||||
2606:4700:3002::/48
|
||||
@@ -48,43 +43,55 @@
|
||||
2606:4700:3037::/48
|
||||
2606:4700:3038::/48
|
||||
2606:4700:3039::/48
|
||||
2606:4700:3000::/96
|
||||
2606:4700:3001::/96
|
||||
2606:4700:3002::/96
|
||||
2606:4700:3003::/96
|
||||
2606:4700:3004::/96
|
||||
2606:4700:3005::/96
|
||||
2606:4700:3006::/96
|
||||
2606:4700:3007::/96
|
||||
2606:4700:3008::/96
|
||||
2606:4700:3009::/96
|
||||
2606:4700:3010::/96
|
||||
2606:4700:3011::/96
|
||||
2606:4700:3012::/96
|
||||
2606:4700:3013::/96
|
||||
2606:4700:3014::/96
|
||||
2606:4700:3015::/96
|
||||
2606:4700:3016::/96
|
||||
2606:4700:3017::/96
|
||||
2606:4700:3018::/96
|
||||
2606:4700:3019::/96
|
||||
2606:4700:3020::/96
|
||||
2606:4700:3021::/96
|
||||
2606:4700:3022::/96
|
||||
2606:4700:3023::/96
|
||||
2606:4700:3024::/96
|
||||
2606:4700:3025::/96
|
||||
2606:4700:3026::/96
|
||||
2606:4700:3027::/96
|
||||
2606:4700:3028::/96
|
||||
2606:4700:3029::/96
|
||||
2606:4700:3030::/96
|
||||
2606:4700:3031::/96
|
||||
2606:4700:3032::/96
|
||||
2606:4700:3033::/96
|
||||
2606:4700:3034::/96
|
||||
2606:4700:3035::/96
|
||||
2606:4700:3036::/96
|
||||
2606:4700:3037::/96
|
||||
2606:4700:3038::/96
|
||||
2606:4700:3039::/96
|
||||
2606:4700:a0::/48
|
||||
2606:4700:a1::/48
|
||||
2606:4700:a8::/48
|
||||
2606:4700:a9::/48
|
||||
2606:4700:a::/48
|
||||
2606:4700:b::/48
|
||||
2606:4700:c::/48
|
||||
2606:4700:d0::/48
|
||||
2606:4700:d1::/48
|
||||
2606:4700:d::/48
|
||||
2606:4700:e0::/48
|
||||
2606:4700:e1::/48
|
||||
2606:4700:e2::/48
|
||||
2606:4700:e3::/48
|
||||
2606:4700:e4::/48
|
||||
2606:4700:e5::/48
|
||||
2606:4700:e6::/48
|
||||
2606:4700:e7::/48
|
||||
2606:4700:e::/48
|
||||
2606:4700:f1::/48
|
||||
2606:4700:f2::/48
|
||||
2606:4700:f3::/48
|
||||
2606:4700:f4::/48
|
||||
2606:4700:f5::/48
|
||||
2606:4700:f::/48
|
||||
2803:f800:50::/48
|
||||
2803:f800:51::/48
|
||||
2a06:98c1:3100::/48
|
||||
2a06:98c1:3101::/48
|
||||
2a06:98c1:3102::/48
|
||||
2a06:98c1:3103::/48
|
||||
2a06:98c1:3104::/48
|
||||
2a06:98c1:3105::/48
|
||||
2a06:98c1:3106::/48
|
||||
2a06:98c1:3107::/48
|
||||
2a06:98c1:3108::/48
|
||||
2a06:98c1:3109::/48
|
||||
2a06:98c1:310a::/48
|
||||
2a06:98c1:310b::/48
|
||||
2a06:98c1:310c::/48
|
||||
2a06:98c1:310d::/48
|
||||
2a06:98c1:310e::/48
|
||||
2a06:98c1:310f::/48
|
||||
2a06:98c1:3120::/48
|
||||
2a06:98c1:3121::/48
|
||||
2a06:98c1:3122::/48
|
||||
2a06:98c1:3123::/48
|
||||
2a06:98c1:3200::/48
|
||||
2a06:98c1:50::/48
|
||||
2a06:98c1:51::/48
|
||||
2a06:98c1:54::/48
|
||||
2a06:98c1:58::/48
|
||||
320
main.go
320
main.go
@@ -1,151 +1,169 @@
|
||||
package main
|
||||
|
||||
import (
|
||||
"flag"
|
||||
"fmt"
|
||||
"io/ioutil"
|
||||
"net/http"
|
||||
"os"
|
||||
"runtime"
|
||||
"time"
|
||||
|
||||
"CloudflareSpeedTest/task"
|
||||
"CloudflareSpeedTest/utils"
|
||||
)
|
||||
|
||||
var (
|
||||
version, versionNew string
|
||||
)
|
||||
|
||||
func init() {
|
||||
var printVersion bool
|
||||
var help = `
|
||||
CloudflareSpeedTest ` + version + `
|
||||
测试 Cloudflare CDN 所有 IP 的延迟和速度，获取最快 IP (IPv4+IPv6)！
|
||||
https://github.com/XIU2/CloudflareSpeedTest
|
||||
|
||||
参数：
|
||||
-n 200
|
||||
测速线程数量；越多测速越快，性能弱的设备 (如路由器) 请勿太高；(默认 200 最多 1000)
|
||||
-t 4
|
||||
延迟测速次数；单个 IP 延迟测速次数，为 1 时将过滤丢包的IP，TCP协议；(默认 4 次)
|
||||
-tp 443
|
||||
指定测速端口；延迟测速/下载测速时使用的端口；(默认 443 端口)
|
||||
-dn 10
|
||||
下载测速数量；延迟测速并排序后，从最低延迟起下载测速的数量；(默认 10 个)
|
||||
-dt 10
|
||||
下载测速时间；单个 IP 下载测速最长时间，不能太短；(默认 10 秒)
|
||||
-url https://cf.xiu2.xyz/url
|
||||
下载测速地址；用来下载测速的 Cloudflare CDN 文件地址，默认地址不保证可用性，建议自建；
|
||||
-tl 200
|
||||
平均延迟上限；只输出低于指定平均延迟的 IP，可与其他上限/下限搭配；(默认 9999 ms)
|
||||
-tll 40
|
||||
平均延迟下限；只输出高于指定平均延迟的 IP，可与其他上限/下限搭配、过滤假墙 IP；(默认 0 ms)
|
||||
-sl 5
|
||||
下载速度下限；只输出高于指定下载速度的 IP，凑够指定数量 [-dn] 才会停止测速；(默认 0.00 MB/s)
|
||||
-p 10
|
||||
显示结果数量；测速后直接显示指定数量的结果，为 0 时不显示结果直接退出；(默认 10 个)
|
||||
-f ip.txt
|
||||
IP段数据文件；如路径含有空格请加上引号；支持其他 CDN IP段；(默认 ip.txt)
|
||||
-o result.csv
|
||||
写入结果文件；如路径含有空格请加上引号；值为空时不写入文件 [-o ""]；(默认 result.csv)
|
||||
-dd
|
||||
禁用下载测速；禁用后测速结果会按延迟排序 (默认按下载速度排序)；(默认 启用)
|
||||
-ipv6
|
||||
IPv6测速模式；确保 IP 段数据文件内只包含 IPv6 IP段，软件不支持同时测速 IPv4+IPv6；(默认 IPv4)
|
||||
-allip
|
||||
测速全部的IP；对 IP 段中的每个 IP (仅支持 IPv4) 进行测速；(默认 每个 IP 段随机测速一个 IP)
|
||||
-v
|
||||
打印程序版本+检查版本更新
|
||||
-h
|
||||
打印帮助说明
|
||||
`
|
||||
var minDelay, maxDelay, downloadTime int
|
||||
flag.IntVar(&task.Routines, "n", 200, "测速线程数量")
|
||||
flag.IntVar(&task.PingTimes, "t", 4, "延迟测速次数")
|
||||
flag.IntVar(&task.TCPPort, "tp", 443, "指定测速端口")
|
||||
flag.IntVar(&maxDelay, "tl", 9999, "平均延迟上限")
|
||||
flag.IntVar(&minDelay, "tll", 0, "平均延迟下限")
|
||||
flag.IntVar(&downloadTime, "dt", 10, "下载测速时间")
|
||||
flag.IntVar(&task.TestCount, "dn", 10, "下载测速数量")
|
||||
flag.StringVar(&task.URL, "url", "https://cf.xiu2.xyz/url", "下载测速地址")
|
||||
flag.BoolVar(&task.Disable, "dd", false, "禁用下载测速")
|
||||
flag.BoolVar(&task.IPv6, "ipv6", false, "启用IPv6")
|
||||
flag.BoolVar(&task.TestAll, "allip", false, "测速全部 IP")
|
||||
flag.StringVar(&task.IPFile, "f", "ip.txt", "IP 数据文件")
|
||||
flag.Float64Var(&task.MinSpeed, "sl", 0, "下载速度下限")
|
||||
flag.IntVar(&utils.PrintNum, "p", 10, "显示结果数量")
|
||||
flag.StringVar(&utils.Output, "o", "result.csv", "输出结果文件")
|
||||
flag.BoolVar(&printVersion, "v", false, "打印程序版本")
|
||||
flag.Usage = func() { fmt.Print(help) }
|
||||
flag.Parse()
|
||||
|
||||
if task.MinSpeed > 0 && time.Duration(maxDelay)*time.Millisecond == utils.InputMaxDelay {
|
||||
fmt.Println("[小提示] 在使用 [-sl] 参数时，建议搭配 [-tl] 参数，以避免因凑不够 [-dn] 数量而一直测速...")
|
||||
}
|
||||
utils.InputMaxDelay = time.Duration(maxDelay) * time.Millisecond
|
||||
utils.InputMinDelay = time.Duration(minDelay) * time.Millisecond
|
||||
task.Timeout = time.Duration(downloadTime) * time.Second
|
||||
|
||||
if printVersion {
|
||||
println(version)
|
||||
fmt.Println("检查版本更新中...")
|
||||
checkUpdate()
|
||||
if versionNew != "" {
|
||||
fmt.Printf("*** 发现新版本 [%s]！请前往 [https://github.com/XIU2/CloudflareSpeedTest] 更新！ ***", versionNew)
|
||||
} else {
|
||||
fmt.Println("当前为最新版本 [" + version + "]！")
|
||||
}
|
||||
os.Exit(0)
|
||||
}
|
||||
}
|
||||
|
||||
func main() {
|
||||
go checkUpdate() // 检查版本更新
|
||||
task.InitRandSeed() // 置随机数种子
|
||||
|
||||
fmt.Printf("# XIU2/CloudflareSpeedTest %s \n\n", version)
|
||||
|
||||
// 开始延迟测速
|
||||
pingData := task.NewPing().Run().FilterDelay()
|
||||
// 开始下载测速
|
||||
speedData := task.TestDownloadSpeed(pingData)
|
||||
utils.ExportCsv(speedData)
|
||||
speedData.Print(task.IPv6)
|
||||
|
||||
if versionNew != "" {
|
||||
fmt.Printf("\n*** 发现新版本 [%s]！请前往 [https://github.com/XIU2/CloudflareSpeedTest] 更新！ ***\n", versionNew)
|
||||
}
|
||||
endPrint()
|
||||
}
|
||||
|
||||
func endPrint() {
|
||||
if utils.NoPrintResult() {
|
||||
return
|
||||
}
|
||||
if runtime.GOOS == "windows" { // 如果是 Windows 系统，则需要按下 回车键 或 Ctrl+C 退出（避免通过双击运行时，测速完毕后直接关闭）
|
||||
fmt.Printf("按下 回车键 或 Ctrl+C 退出。")
|
||||
var pause int
|
||||
fmt.Scanln(&pause)
|
||||
}
|
||||
}
|
||||
|
||||
// 检查更新
|
||||
func checkUpdate() {
|
||||
timeout := 10 * time.Second
|
||||
client := http.Client{Timeout: timeout}
|
||||
res, err := client.Get("https://api.xiu2.xyz/ver/cloudflarespeedtest.txt")
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
// 读取资源数据 body: []byte
|
||||
body, err := ioutil.ReadAll(res.Body)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
// 关闭资源流
|
||||
defer res.Body.Close()
|
||||
if string(body) != version {
|
||||
versionNew = string(body)
|
||||
}
|
||||
}
|
||||
package main
|
||||
|
||||
import (
|
||||
"flag"
|
||||
"fmt"
|
||||
"io/ioutil"
|
||||
"net/http"
|
||||
"os"
|
||||
"runtime"
|
||||
"time"
|
||||
|
||||
"CloudflareSpeedTest/task"
|
||||
"CloudflareSpeedTest/utils"
|
||||
)
|
||||
|
||||
var (
|
||||
version, versionNew string
|
||||
)
|
||||
|
||||
func init() {
|
||||
var printVersion bool
|
||||
var help = `
|
||||
CloudflareSpeedTest ` + version + `
|
||||
测试 Cloudflare CDN 所有 IP 的延迟和速度，获取最快 IP (IPv4+IPv6)！
|
||||
https://github.com/XIU2/CloudflareSpeedTest
|
||||
|
||||
参数：
|
||||
-n 200
|
||||
延迟测速线程；越多延迟测速越快，性能弱的设备 (如路由器) 请勿太高；(默认 200 最多 1000)
|
||||
-t 4
|
||||
延迟测速次数；单个 IP 延迟测速次数，为 1 时将过滤丢包的IP；(默认 4 次)
|
||||
-dn 10
|
||||
下载测速数量；延迟测速并排序后，从最低延迟起下载测速的数量；(默认 10 个)
|
||||
-dt 10
|
||||
下载测速时间；单个 IP 下载测速最长时间，不能太短；(默认 10 秒)
|
||||
-tp 443
|
||||
指定测速端口；延迟测速/下载测速时使用的端口；(默认 443 端口)
|
||||
-url https://cf.xiu2.xyz/url
|
||||
指定测速地址；延迟测速(HTTPing)/下载测速时使用的地址，默认地址不保证可用性，建议自建；
|
||||
|
||||
-httping
|
||||
切换测速模式；延迟测速模式改为 HTTP 协议，所用测试地址为 [-url] 参数；(默认 TCPing)
|
||||
-httping-code 200
|
||||
有效状态代码；HTTPing 延迟测速时网页返回的有效 HTTP 状态码，仅限一个；(默认 200 301 302)
|
||||
-cfcolo HKG,KHH,NRT,LAX,SEA,SJC,FRA,MAD
|
||||
匹配指定地区；地区名为当地机场三字码，英文逗号分隔，仅 HTTPing 模式可用；(默认 所有地区)
|
||||
|
||||
-tl 200
|
||||
平均延迟上限；只输出低于指定平均延迟的 IP，可与其他上限/下限搭配；(默认 9999 ms)
|
||||
-tll 40
|
||||
平均延迟下限；只输出高于指定平均延迟的 IP，可与其他上限/下限搭配；(默认 0 ms)
|
||||
-sl 5
|
||||
下载速度下限；只输出高于指定下载速度的 IP，凑够指定数量 [-dn] 才会停止测速；(默认 0.00 MB/s)
|
||||
|
||||
-p 10
|
||||
显示结果数量；测速后直接显示指定数量的结果，为 0 时不显示结果直接退出；(默认 10 个)
|
||||
-f ip.txt
|
||||
IP段数据文件；如路径含有空格请加上引号；支持其他 CDN IP段；(默认 ip.txt)
|
||||
-ip 1.1.1.1,2.2.2.2/24,2606:4700::/32
|
||||
指定IP段数据；直接通过参数指定要测速的 IP 段数据，英文逗号分隔；(默认 空)
|
||||
-o result.csv
|
||||
写入结果文件；如路径含有空格请加上引号；值为空时不写入文件 [-o ""]；(默认 result.csv)
|
||||
|
||||
-dd
|
||||
禁用下载测速；禁用后测速结果会按延迟排序 (默认按下载速度排序)；(默认 启用)
|
||||
-allip
|
||||
测速全部的IP；对 IP 段中的每个 IP (仅支持 IPv4) 进行测速；(默认 每个 /24 段随机测速一个 IP)
|
||||
|
||||
-v
|
||||
打印程序版本 + 检查版本更新
|
||||
-h
|
||||
打印帮助说明
|
||||
`
|
||||
var minDelay, maxDelay, downloadTime int
|
||||
flag.IntVar(&task.Routines, "n", 200, "延迟测速线程")
|
||||
flag.IntVar(&task.PingTimes, "t", 4, "延迟测速次数")
|
||||
flag.IntVar(&task.TestCount, "dn", 10, "下载测速数量")
|
||||
flag.IntVar(&downloadTime, "dt", 10, "下载测速时间")
|
||||
flag.IntVar(&task.TCPPort, "tp", 443, "指定测速端口")
|
||||
flag.StringVar(&task.URL, "url", "https://cf.xiu2.xyz/url", "指定测速地址")
|
||||
|
||||
flag.BoolVar(&task.Httping, "httping", false, "切换测速模式")
|
||||
flag.IntVar(&task.HttpingStatusCode, "httping-code", 0, "有效状态代码")
|
||||
flag.StringVar(&task.HttpingCFColo, "cfcolo", "", "匹配指定地区")
|
||||
|
||||
flag.IntVar(&maxDelay, "tl", 9999, "平均延迟上限")
|
||||
flag.IntVar(&minDelay, "tll", 0, "平均延迟下限")
|
||||
flag.Float64Var(&task.MinSpeed, "sl", 0, "下载速度下限")
|
||||
|
||||
flag.IntVar(&utils.PrintNum, "p", 10, "显示结果数量")
|
||||
flag.StringVar(&task.IPFile, "f", "ip.txt", "IP段数据文件")
|
||||
flag.StringVar(&task.IPText, "ip", "", "指定IP段数据")
|
||||
flag.StringVar(&utils.Output, "o", "result.csv", "输出结果文件")
|
||||
|
||||
flag.BoolVar(&task.Disable, "dd", false, "禁用下载测速")
|
||||
flag.BoolVar(&task.TestAll, "allip", false, "测速全部 IP")
|
||||
|
||||
flag.BoolVar(&printVersion, "v", false, "打印程序版本")
|
||||
flag.Usage = func() { fmt.Print(help) }
|
||||
flag.Parse()
|
||||
|
||||
if task.MinSpeed > 0 && time.Duration(maxDelay)*time.Millisecond == utils.InputMaxDelay {
|
||||
fmt.Println("[小提示] 在使用 [-sl] 参数时，建议搭配 [-tl] 参数，以避免因凑不够 [-dn] 数量而一直测速...")
|
||||
}
|
||||
utils.InputMaxDelay = time.Duration(maxDelay) * time.Millisecond
|
||||
utils.InputMinDelay = time.Duration(minDelay) * time.Millisecond
|
||||
task.Timeout = time.Duration(downloadTime) * time.Second
|
||||
task.HttpingCFColomap = task.MapColoMap()
|
||||
|
||||
if printVersion {
|
||||
println(version)
|
||||
fmt.Println("检查版本更新中...")
|
||||
checkUpdate()
|
||||
if versionNew != "" {
|
||||
fmt.Printf("*** 发现新版本 [%s]！请前往 [https://github.com/XIU2/CloudflareSpeedTest] 更新！ ***", versionNew)
|
||||
} else {
|
||||
fmt.Println("当前为最新版本 [" + version + "]！")
|
||||
}
|
||||
os.Exit(0)
|
||||
}
|
||||
}
|
||||
|
||||
func main() {
|
||||
task.InitRandSeed() // 置随机数种子
|
||||
|
||||
fmt.Printf("# XIU2/CloudflareSpeedTest %s \n\n", version)
|
||||
|
||||
// 开始延迟测速
|
||||
pingData := task.NewPing().Run().FilterDelay()
|
||||
// 开始下载测速
|
||||
speedData := task.TestDownloadSpeed(pingData)
|
||||
utils.ExportCsv(speedData) // 输出文件
|
||||
speedData.Print() // 打印结果
|
||||
|
||||
if versionNew != "" {
|
||||
fmt.Printf("\n*** 发现新版本 [%s]！请前往 [https://github.com/XIU2/CloudflareSpeedTest] 更新！ ***\n", versionNew)
|
||||
}
|
||||
endPrint()
|
||||
}
|
||||
|
||||
func endPrint() {
|
||||
if utils.NoPrintResult() {
|
||||
return
|
||||
}
|
||||
if runtime.GOOS == "windows" { // 如果是 Windows 系统，则需要按下 回车键 或 Ctrl+C 退出（避免通过双击运行时，测速完毕后直接关闭）
|
||||
fmt.Printf("按下 回车键 或 Ctrl+C 退出。")
|
||||
fmt.Scanln()
|
||||
}
|
||||
}
|
||||
|
||||
// 检查更新
|
||||
func checkUpdate() {
|
||||
timeout := 10 * time.Second
|
||||
client := http.Client{Timeout: timeout}
|
||||
res, err := client.Get("https://api.xiu2.xyz/ver/cloudflarespeedtest.txt")
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
// 读取资源数据 body: []byte
|
||||
body, err := ioutil.ReadAll(res.Body)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
// 关闭资源流
|
||||
defer res.Body.Close()
|
||||
if string(body) != version {
|
||||
versionNew = string(body)
|
||||
}
|
||||
}
|
||||
|
||||
@@ -7,6 +7,7 @@ import (
|
||||
"net"
|
||||
"net/http"
|
||||
"sort"
|
||||
"strconv"
|
||||
"time"
|
||||
|
||||
"CloudflareSpeedTest/utils"
|
||||
@@ -24,11 +25,8 @@ const (
|
||||
)
|
||||
|
||||
var (
|
||||
// download test url
|
||||
URL = defaultURL
|
||||
// download timeout
|
||||
URL = defaultURL
|
||||
Timeout = defaultTimeout
|
||||
// disable download
|
||||
Disable = defaultDisableDownload
|
||||
|
||||
TestCount = defaultTestNum
|
||||
@@ -68,13 +66,19 @@ func TestDownloadSpeed(ipSet utils.PingDelaySet) (speedSet utils.DownloadSpeedSe
|
||||
}
|
||||
|
||||
fmt.Printf("开始下载测速（下载速度下限：%.2f MB/s，下载测速数量：%d，下载测速队列：%d）：\n", MinSpeed, TestCount, testNum)
|
||||
bar := utils.NewBar(TestCount)
|
||||
// 控制 下载测速进度条 与 延迟测速进度条 长度一致（强迫症）
|
||||
bar_a := len(strconv.Itoa(len(ipSet)))
|
||||
bar_b := " "
|
||||
for i := 0; i < bar_a; i++ {
|
||||
bar_b += " "
|
||||
}
|
||||
bar := utils.NewBar(TestCount, bar_b, "")
|
||||
for i := 0; i < testNum; i++ {
|
||||
speed := downloadHandler(ipSet[i].IP)
|
||||
ipSet[i].DownloadSpeed = speed
|
||||
// 在每个 IP 下载测速后，以 [下载速度下限] 条件过滤结果
|
||||
if speed >= MinSpeed*1024*1024 {
|
||||
bar.Grow(1)
|
||||
bar.Grow(1, "")
|
||||
speedSet = append(speedSet, ipSet[i]) // 高于下载速度下限时，添加到新数组中
|
||||
if len(speedSet) == TestCount { // 凑够满足条件的 IP 时（下载测速数量 -dn），就跳出循环
|
||||
break
|
||||
@@ -91,9 +95,11 @@ func TestDownloadSpeed(ipSet utils.PingDelaySet) (speedSet utils.DownloadSpeedSe
|
||||
}
|
||||
|
||||
func getDialContext(ip *net.IPAddr) func(ctx context.Context, network, address string) (net.Conn, error) {
|
||||
fakeSourceAddr := ip.String() + ":" + fmt.Sprintf("%d", TCPPort)
|
||||
if IPv6 { // IPv6 需要加上 []
|
||||
fakeSourceAddr = "[" + ip.String() + "]:" + fmt.Sprintf("%d", TCPPort)
|
||||
var fakeSourceAddr string
|
||||
if isIPv4(ip.String()) {
|
||||
fakeSourceAddr = fmt.Sprintf("%s:%d", ip.String(), TCPPort)
|
||||
} else {
|
||||
fakeSourceAddr = fmt.Sprintf("[%s]:%d", ip.String(), TCPPort)
|
||||
}
|
||||
return func(ctx context.Context, network, address string) (net.Conn, error) {
|
||||
return (&net.Dialer{}).DialContext(ctx, network, fakeSourceAddr)
|
||||
|
||||
132
task/httping.go
Normal file
132
task/httping.go
Normal file
@@ -0,0 +1,132 @@
|
||||
package task
|
||||
|
||||
import (
|
||||
//"crypto/tls"
|
||||
//"fmt"
|
||||
"io"
|
||||
"log"
|
||||
"net"
|
||||
"net/http"
|
||||
"strings"
|
||||
"sync"
|
||||
"time"
|
||||
)
|
||||
|
||||
var (
|
||||
Httping bool
|
||||
HttpingStatusCode int
|
||||
HttpingCFColo string
|
||||
HttpingCFColomap *sync.Map
|
||||
)
|
||||
|
||||
// pingReceived pingTotalTime
|
||||
func (p *Ping) httping(ip *net.IPAddr) (int, time.Duration) {
|
||||
hc := http.Client{
|
||||
Timeout: time.Second * 2,
|
||||
Transport: &http.Transport{
|
||||
DialContext: getDialContext(ip),
|
||||
//TLSClientConfig: &tls.Config{InsecureSkipVerify: true}, // 跳过证书验证
|
||||
},
|
||||
CheckRedirect: func(req *http.Request, via []*http.Request) error {
|
||||
return http.ErrUseLastResponse // 阻止重定向
|
||||
},
|
||||
}
|
||||
|
||||
// 先访问一次获得 HTTP 状态码 及 Cloudflare Colo
|
||||
{
|
||||
requ, err := http.NewRequest(http.MethodHead, URL, nil)
|
||||
if err != nil {
|
||||
return 0, 0
|
||||
}
|
||||
requ.Header.Set("User-Agent", "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/98.0.4758.80 Safari/537.36")
|
||||
resp, err := hc.Do(requ)
|
||||
if err != nil {
|
||||
return 0, 0
|
||||
}
|
||||
defer resp.Body.Close()
|
||||
|
||||
//fmt.Println("IP:", ip, "StatusCode:", resp.StatusCode, resp.Request.URL)
|
||||
if HttpingStatusCode == 0 || HttpingStatusCode < 100 && HttpingStatusCode > 599 {
|
||||
if resp.StatusCode != 200 && resp.StatusCode != 301 && resp.StatusCode != 302 {
|
||||
return 0, 0
|
||||
}
|
||||
} else {
|
||||
if resp.StatusCode != HttpingStatusCode {
|
||||
return 0, 0
|
||||
}
|
||||
}
|
||||
|
||||
io.Copy(io.Discard, resp.Body)
|
||||
|
||||
if HttpingCFColo != "" {
|
||||
cfRay := resp.Header.Get("CF-RAY")
|
||||
colo := p.getColo(cfRay)
|
||||
if colo == "" {
|
||||
return 0, 0
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
// 循环测速计算延迟
|
||||
success := 0
|
||||
var delay time.Duration
|
||||
for i := 0; i < PingTimes; i++ {
|
||||
requ, err := http.NewRequest(http.MethodHead, URL, nil)
|
||||
if err != nil {
|
||||
log.Fatal("意外的错误，情报告：", err)
|
||||
return 0, 0
|
||||
}
|
||||
requ.Header.Set("User-Agent", "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_12_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/98.0.4758.80 Safari/537.36")
|
||||
if i == PingTimes-1 {
|
||||
requ.Header.Set("Connection", "close")
|
||||
}
|
||||
startTime := time.Now()
|
||||
resp, err := hc.Do(requ)
|
||||
if err != nil {
|
||||
continue
|
||||
}
|
||||
success++
|
||||
io.Copy(io.Discard, resp.Body)
|
||||
_ = resp.Body.Close()
|
||||
duration := time.Since(startTime)
|
||||
delay += duration
|
||||
|
||||
}
|
||||
|
||||
return success, delay
|
||||
|
||||
}
|
||||
|
||||
func MapColoMap() *sync.Map {
|
||||
if HttpingCFColo == "" {
|
||||
return nil
|
||||
}
|
||||
|
||||
colos := strings.Split(HttpingCFColo, ",")
|
||||
colomap := &sync.Map{}
|
||||
for _, colo := range colos {
|
||||
colomap.Store(colo, colo)
|
||||
}
|
||||
return colomap
|
||||
}
|
||||
|
||||
func (p *Ping) getColo(b string) string {
|
||||
if b == "" {
|
||||
return ""
|
||||
}
|
||||
idColo := strings.Split(b, "-")
|
||||
|
||||
out := idColo[1]
|
||||
|
||||
if HttpingCFColomap == nil {
|
||||
return out
|
||||
}
|
||||
|
||||
_, ok := HttpingCFColomap.Load(out)
|
||||
if ok {
|
||||
return out
|
||||
}
|
||||
|
||||
return ""
|
||||
}
|
||||
63
task/ip.go
63
task/ip.go
@@ -14,19 +14,25 @@ import (
|
||||
const defaultInputFile = "ip.txt"
|
||||
|
||||
var (
|
||||
// IPv6 IP version is 6
|
||||
IPv6 = false
|
||||
// TestAll test all ip
|
||||
TestAll = false
|
||||
// IPFile is the filename of IP Rangs
|
||||
IPFile = defaultInputFile
|
||||
IPText string
|
||||
)
|
||||
|
||||
func InitRandSeed() {
|
||||
rand.Seed(time.Now().UnixNano())
|
||||
}
|
||||
|
||||
func isIPv4(ip string) bool {
|
||||
return strings.Contains(ip, ".")
|
||||
}
|
||||
|
||||
func randIPEndWith(num byte) byte {
|
||||
if num == 0 { // 对于 /32 这种单独的 IP
|
||||
return byte(0)
|
||||
}
|
||||
return byte(rand.Intn(int(num)))
|
||||
}
|
||||
|
||||
@@ -46,8 +52,9 @@ func newIPRanges() *IPRanges {
|
||||
func (r *IPRanges) fixIP(ip string) string {
|
||||
// 如果不含有 '/' 则代表不是 IP 段，而是一个单独的 IP，因此需要加上 /32 /128 子网掩码
|
||||
if i := strings.IndexByte(ip, '/'); i < 0 {
|
||||
r.mask = "/32"
|
||||
if IPv6 {
|
||||
if isIPv4(ip) {
|
||||
r.mask = "/32"
|
||||
} else {
|
||||
r.mask = "/128"
|
||||
}
|
||||
ip += r.mask
|
||||
@@ -86,10 +93,6 @@ func (r *IPRanges) getIPRange() (minIP, hosts byte) {
|
||||
hosts = 255
|
||||
return
|
||||
}
|
||||
if total == 0 {
|
||||
hosts = 1
|
||||
return
|
||||
}
|
||||
hosts = byte(total)
|
||||
return
|
||||
}
|
||||
@@ -117,8 +120,6 @@ func (r *IPRanges) chooseIPv4() {
|
||||
func (r *IPRanges) chooseIPv6() {
|
||||
var tempIP uint8
|
||||
for r.ipNet.Contains(r.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])
|
||||
if r.mask != "/128" {
|
||||
r.firstIP[15] = randIPEndWith(255) // 随机 IP 的最后一段
|
||||
r.firstIP[14] = randIPEndWith(255) // 随机 IP 的最后一段
|
||||
@@ -137,23 +138,35 @@ func (r *IPRanges) chooseIPv6() {
|
||||
}
|
||||
|
||||
func loadIPRanges() []*net.IPAddr {
|
||||
if IPFile == "" {
|
||||
IPFile = defaultInputFile
|
||||
}
|
||||
file, err := os.Open(IPFile)
|
||||
if err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
defer file.Close()
|
||||
ranges := newIPRanges()
|
||||
scanner := bufio.NewScanner(file)
|
||||
for scanner.Scan() {
|
||||
ranges.parseCIDR(scanner.Text())
|
||||
if IPv6 {
|
||||
ranges.chooseIPv6()
|
||||
continue
|
||||
if IPText != "" { // 从参数中获取 IP 段数据
|
||||
IPs := strings.Split(IPText, ",")
|
||||
for _, IP := range IPs {
|
||||
ranges.parseCIDR(IP)
|
||||
if isIPv4(IP) {
|
||||
ranges.chooseIPv4()
|
||||
} else {
|
||||
ranges.chooseIPv6()
|
||||
}
|
||||
}
|
||||
} else { // 从文件中获取 IP 段数据
|
||||
if IPFile == "" {
|
||||
IPFile = defaultInputFile
|
||||
}
|
||||
file, err := os.Open(IPFile)
|
||||
if err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
defer file.Close()
|
||||
scanner := bufio.NewScanner(file)
|
||||
for scanner.Scan() {
|
||||
ranges.parseCIDR(scanner.Text())
|
||||
if isIPv4(scanner.Text()) {
|
||||
ranges.chooseIPv4()
|
||||
} else {
|
||||
ranges.chooseIPv6()
|
||||
}
|
||||
}
|
||||
ranges.chooseIPv4()
|
||||
}
|
||||
return ranges.ips
|
||||
}
|
||||
|
||||
@@ -4,6 +4,7 @@ import (
|
||||
"fmt"
|
||||
"net"
|
||||
"sort"
|
||||
"strconv"
|
||||
"sync"
|
||||
"time"
|
||||
|
||||
@@ -54,7 +55,7 @@ func NewPing() *Ping {
|
||||
ips: ips,
|
||||
csv: make(utils.PingDelaySet, 0),
|
||||
control: make(chan bool, Routines),
|
||||
bar: utils.NewBar(len(ips)),
|
||||
bar: utils.NewBar(len(ips), "可用:", ""),
|
||||
}
|
||||
}
|
||||
|
||||
@@ -62,11 +63,11 @@ func (p *Ping) Run() utils.PingDelaySet {
|
||||
if len(p.ips) == 0 {
|
||||
return p.csv
|
||||
}
|
||||
ipVersion := "IPv4"
|
||||
if IPv6 { // IPv6 模式判断
|
||||
ipVersion = "IPv6"
|
||||
if Httping {
|
||||
fmt.Printf("开始延迟测速（模式：HTTP，端口：%d，平均延迟上限：%v ms，平均延迟下限：%v ms)\n", TCPPort, utils.InputMaxDelay.Milliseconds(), utils.InputMinDelay.Milliseconds())
|
||||
} else {
|
||||
fmt.Printf("开始延迟测速（模式：TCP，端口：%d，平均延迟上限：%v ms，平均延迟下限：%v ms)\n", TCPPort, utils.InputMaxDelay.Milliseconds(), utils.InputMinDelay.Milliseconds())
|
||||
}
|
||||
fmt.Printf("开始延迟测速（模式：TCP %s，端口：%d，平均延迟上限：%v ms，平均延迟下限：%v ms)\n", ipVersion, TCPPort, utils.InputMaxDelay.Milliseconds(), utils.InputMinDelay.Milliseconds())
|
||||
for _, ip := range p.ips {
|
||||
p.wg.Add(1)
|
||||
p.control <- false
|
||||
@@ -84,12 +85,13 @@ func (p *Ping) start(ip *net.IPAddr) {
|
||||
<-p.control
|
||||
}
|
||||
|
||||
//bool connectionSucceed float32 time
|
||||
// bool connectionSucceed float32 time
|
||||
func (p *Ping) tcping(ip *net.IPAddr) (bool, time.Duration) {
|
||||
startTime := time.Now()
|
||||
fullAddress := fmt.Sprintf("%s:%d", ip.String(), TCPPort)
|
||||
//fmt.Println(ip.String())
|
||||
if IPv6 { // IPv6 需要加上 []
|
||||
var fullAddress string
|
||||
if isIPv4(ip.String()) {
|
||||
fullAddress = fmt.Sprintf("%s:%d", ip.String(), TCPPort)
|
||||
} else {
|
||||
fullAddress = fmt.Sprintf("[%s]:%d", ip.String(), TCPPort)
|
||||
}
|
||||
conn, err := net.DialTimeout("tcp", fullAddress, tcpConnectTimeout)
|
||||
@@ -101,8 +103,12 @@ func (p *Ping) tcping(ip *net.IPAddr) (bool, time.Duration) {
|
||||
return true, duration
|
||||
}
|
||||
|
||||
//pingReceived pingTotalTime
|
||||
// pingReceived pingTotalTime
|
||||
func (p *Ping) checkConnection(ip *net.IPAddr) (recv int, totalDelay time.Duration) {
|
||||
if Httping {
|
||||
recv, totalDelay = p.httping(ip)
|
||||
return
|
||||
}
|
||||
for i := 0; i < PingTimes; i++ {
|
||||
if ok, delay := p.tcping(ip); ok {
|
||||
recv++
|
||||
@@ -123,7 +129,11 @@ func (p *Ping) appendIPData(data *utils.PingData) {
|
||||
// handle tcping
|
||||
func (p *Ping) tcpingHandler(ip *net.IPAddr) {
|
||||
recv, totalDlay := p.checkConnection(ip)
|
||||
p.bar.Grow(1)
|
||||
nowAble := len(p.csv)
|
||||
if recv != 0 {
|
||||
nowAble++
|
||||
}
|
||||
p.bar.Grow(1, strconv.Itoa(nowAble))
|
||||
if recv == 0 {
|
||||
return
|
||||
}
|
||||
|
||||
11
utils/csv.go
11
utils/csv.go
@@ -138,7 +138,7 @@ func (s DownloadSpeedSet) Swap(i, j int) {
|
||||
s[i], s[j] = s[j], s[i]
|
||||
}
|
||||
|
||||
func (s DownloadSpeedSet) Print(ipv6 bool) {
|
||||
func (s DownloadSpeedSet) Print() {
|
||||
if NoPrintResult() {
|
||||
return
|
||||
}
|
||||
@@ -152,9 +152,12 @@ func (s DownloadSpeedSet) Print(ipv6 bool) {
|
||||
}
|
||||
headFormat := "%-16s%-5s%-5s%-5s%-6s%-11s\n"
|
||||
dataFormat := "%-18s%-8s%-8s%-8s%-10s%-15s\n"
|
||||
if ipv6 { // IPv6 太长了，所以需要调整一下间隔
|
||||
headFormat = "%-40s%-5s%-5s%-5s%-6s%-11s\n"
|
||||
dataFormat = "%-42s%-8s%-8s%-8s%-10s%-15s\n"
|
||||
for i := 0; i < PrintNum; i++ { // 如果要输出的 IP 中包含 IPv6，那么就需要调整一下间隔
|
||||
if len(dateString[i][0]) > 15 {
|
||||
headFormat = "%-40s%-5s%-5s%-5s%-6s%-11s\n"
|
||||
dataFormat = "%-42s%-8s%-8s%-8s%-10s%-15s\n"
|
||||
break
|
||||
}
|
||||
}
|
||||
fmt.Printf(headFormat, "IP 地址", "已发送", "已接收", "丢包率", "平均延迟", "下载速度 (MB/s)")
|
||||
for i := 0; i < PrintNum; i++ {
|
||||
|
||||
@@ -1,19 +1,25 @@
|
||||
package utils
|
||||
|
||||
import "github.com/cheggaaa/pb/v3"
|
||||
import (
|
||||
"fmt"
|
||||
|
||||
"github.com/cheggaaa/pb/v3"
|
||||
)
|
||||
|
||||
type Bar struct {
|
||||
pb *pb.ProgressBar
|
||||
}
|
||||
|
||||
func NewBar(count int) *Bar {
|
||||
return &Bar{pb.Simple.Start(count)}
|
||||
func NewBar(count int, MyStrStart, MyStrEnd string) *Bar {
|
||||
tmpl := fmt.Sprintf(`{{counters . }} {{ bar . "[" "-" (cycle . "↖" "↗" "↘" "↙" ) "_" "]"}} %s {{string . "MyStr" | green}} %s `, MyStrStart, MyStrEnd)
|
||||
bar := pb.ProgressBarTemplate(tmpl).Start(count)
|
||||
return &Bar{pb: bar}
|
||||
}
|
||||
|
||||
func (b *Bar) Grow(num int) {
|
||||
b.pb.Add(num)
|
||||
func (b *Bar) Grow(num int, MyStrVal string) {
|
||||
b.pb.Set("MyStr", MyStrVal).Add(num)
|
||||
}
|
||||
|
||||
func (b *Bar) Done() {
|
||||
b.pb.Finish()
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user