本文介绍如何使用 go 语言解析带间隔配置的 url 列表，通过 ticker 定时发起 http 请求，并安全并发地测量响应时间与状态码，避免常见闭包捕获、nil 指针和资源泄漏问题。
本文介绍如何使用 go 语言解析带间隔配置的 url 列表，通过 ticker 定时发起 http 请求，并安全并发地测量响应时间与状态码，避免常见闭包捕获、nil 指针和资源泄漏问题。
在构建服务健康监测系统时，定时轮询多个目标站点并统计其响应性能（如耗时、HTTP 状态码）是一项典型需求。Go 语言凭借其轻量级 goroutine 和原生 net/http、time/ticker 支持，非常适合此类任务。但初学者常因文件解析错误、goroutine 闭包变量捕获、未关闭响应体等问题导致 panic 或逻辑错乱。
✅ 正确解析 URL 配置文件
原始代码中 strings.Split(string(content), "\t") 直接按 Tab 分割整个文件内容，忽略了换行符结构，导致 lines 数组实际为 [url1, "5\nhttp://nike.com", "10"] 这类畸形切片 —— 这正是后续 lines[i] 访问越界或解析失败的根源。
正确做法是先按行分割（\n），再对每行按 Tab 分割（\t），并过滤空行：
content, err := os.ReadFile("url_list.txt")
if err != nil {
log.Fatal("读取文件失败:", err)
}
lines := strings.Fields(string(content)) // 或 strings.Split(strings.TrimSpace(string(content)), "\n")
urls := make([]struct{ URL string; Interval int }, 0)
for _, line := range lines {
line = strings.TrimSpace(line)
if line == "" {
continue
}
parts := strings.Split(line, "\t")
if len(parts) <blockquote><p>⚠️ 注意：确保 .txt 文件中确实使用 <strong>Tab 字符（\t）</strong> 分隔 URL 与秒数，而非空格（可用 cat -A url_list.txt 验证）。若用空格，请改用 strings.Fields()。</p><div class="aritcle_card flexRow artxards">
<div class="artcardd flexRow">
<a class="aritcle_card_img" rel="nofollow" href="/ai/1755" title="CAPTURELAB"><img
src="https://img.php.cn/upload/ai_manual/000/969/633/68b6cf9ecd3a4215.png" alt="CAPTURELAB" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
<div class="aritcle_card_info flexColumn">
<a rel="nofollow" href="/ai/1755" title="CAPTURELAB" class="overflowclass">CAPTURELAB</a>
<p class="overflowclass">一款面向游戏玩家的AI游戏视频工具，可以自动识别和整理游戏精彩片段，帮助玩家更快制作游戏集锦视频。</p>
</div>
<a rel="nofollow" href="/ai/1755" title="CAPTURELAB" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span>
</a>
</div>
</div></blockquote><h3>✅ 安全并发请求与资源管理</h3><p>原代码存在两个严重隐患：</p>
- defer resp.Body.Close() 写在 goroutine 内部但 resp 可能为 nil（请求失败时），导致 panic；
- for i := 0; i
修正方案：显式传参 + 错误检查 + 确保 Close 只在 resp 非 nil 时调用：
func getRespTime(url string) {
start := time.Now()
fmt.Printf("[START] %s at %s\n", url, start.Format(time.TimeOnly))
resp, err := http.Get(url)
if err != nil {
dur := time.Since(start)
fmt.Printf("[FAIL] %s | %v | %.3fs\n", url, err, dur.Seconds())
return // 不调用 Close，resp 为 nil
}
defer resp.Body.Close() // 此处 resp 必非 nil
dur := time.Since(start)
fmt.Printf("[OK] %s | %s | %.3fs\n", url, resp.Status, dur.Seconds())
}
✅ 构建健壮的定时轮询主逻辑
不再依赖全局 ticker 与复杂 channel 控制，而是为每个 URL 启动独立 ticker（更灵活、易维护）：
func main() {
urls := parseURLs("url_list.txt") // 上述解析函数
var wg sync.WaitGroup
for _, u := range urls {
wg.Add(1)
go func(u struct{ URL string; Interval int }) {
defer wg.Done()
ticker := time.NewTicker(time.Duration(u.Interval) * time.Second)
defer ticker.Stop()
for range ticker.C {
getRespTime(u.URL)
}
}(u) // 立即传值，避免闭包捕获
}
// 模拟运行 60 秒后退出（生产环境建议用信号控制）
time.Sleep(60 * time.Second)
fmt.Println("监控结束。")
}
? 补充建议与最佳实践
-
超时控制：http.Get 默认无超时，建议使用 http.Client 配置 Timeout，防止单个请求阻塞：
client := &http.Client{Timeout: 10 * time.Second} resp, err := client.Get(url) - 重试机制：对临时性失败（如 5xx、连接超时）可添加指数退避重试。
- 结果聚合：将每次结果写入日志文件或发送至 Prometheus / Grafana。
- 并发限制：若 URL 数量极大，可引入 semaphore 或 worker pool 控制并发请求数，避免端口耗尽。
通过以上重构，你的监控程序将稳定运行、准确计时、清晰输出，并具备良好的可扩展性与可维护性。
