背景
写个后台程序,定时抓取服务器指标,代码逻辑如下,使用一段时间后内存不断增加
func CollectInfo() {
for {
// 获取服务器信息代码
// ...............
resp, err := http.Post("http://server", "application/json", strings.NewReader(`{"info1": "xxxx", "info2": "yyyy"}`))
if err != nil {
// 错误处理
}
defer resp.Body.Close()
// 处理其他逻辑
time.Sleep(time.Minute)
}
}
排查
一开始感觉是哪里文件或者网络忘记Close了,看下进程打开的文件.
如下图类似情况, 看到很多http ESTABLISHED状态,估计就是哪个http忘记Close.
排查代码,问题应该出现在上面一段代码,for循环中defer不会执行,在函数返回时执行
# 查看进程打开的文件
lsof -p `pgrep defer`
验证
写个例子测试一下
package main
import (
"log"
"time"
)
func main() {
log.Println("program started")
for i := 0; i < 3; i++ {
defer func(i int) {
log.Println("defer executed: ", i)
}(i)
}
time.Sleep(time.Minute)
log.Println("program exited")
}
根据打印的时间,可以得出以下两条结论
defer只在函数返回时才执行
defer执行顺序是先进后出,先调用的后执行
文章来源:https://www.toymoban.com/news/detail-704292.html
优化
写defer写习惯了,这里不能用defer, 用完直接调用关闭文章来源地址https://www.toymoban.com/news/detail-704292.html
func CollectInfo() {
for {
// 获取服务器信息代码
// ...............
resp, err := http.Post("http://server", "application/json", strings.NewReader(`{"info1": "xxxx", "info2": "yyyy"}`))
if err != nil {
// 错误处理
} else{
resp.Body.Close()
}
// 处理其他逻辑
time.Sleep(time.Minute)
}
}
到了这里,关于Go for循环中的defer的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!