快捷導(dǎo)航

GoLang內(nèi)存泄漏原因排查詳解

更新時間：2022年12月15日 16:38:06 作者：上后左愛

內(nèi)存溢出是指程序在申請內(nèi)存時，沒有足夠的內(nèi)存空間供其使用，簡單點說就是你要求分配的內(nèi)存超出了系統(tǒng)能給你的，系統(tǒng)不能滿足需求，于是產(chǎn)生溢出出現(xiàn)out of memory異常

背景

Go 語言中有對應(yīng)的Go 內(nèi)存回收機制，在Go采用并發(fā)三色標(biāo)記清除算法, 但是由于實際的過程中發(fā)現(xiàn)會有一些內(nèi)存泄漏的常見，內(nèi)存泄漏分為：臨時性和永久性內(nèi)存泄漏。

初步排查過程中：發(fā)現(xiàn)Linux使用top 發(fā)現(xiàn)內(nèi)存隨著時間會持續(xù)的增加沒有穩(wěn)定在一個合理值中。

在使用 pprof ,BBC 等 Go的內(nèi)存泄漏工具進行排查

臨時性內(nèi)存泄漏

指的釋放內(nèi)存不及時，對應(yīng)的內(nèi)存在更晚時候釋放，這類問題主要是 string,slice 和底層的Buffer 錯誤共享，或者defer 函數(shù)資源沒有及時的釋放。

數(shù)組不正常使用導(dǎo)致內(nèi)存泄漏

數(shù)組作為形參遵守的是值拷貝，如果函數(shù)調(diào)用次數(shù)很多并且數(shù)組過大，導(dǎo)致內(nèi)存使用激增

func countTragetBigNum(nums [1000000]int, target int) int {
   num := 0
   for i :=0; i< len(nums) && nums[i] ==target ; i++ {
   	num += 1
   }
   return num
}
# 在短時間內(nèi) 創(chuàng)建100萬數(shù)組 內(nèi)存是8M，短時間內(nèi)調(diào)用 100 次，并且作為是形參 在Go進行是 值Copy ,800M, 所以在時間過程中：

大數(shù)組在形參的場景下，通常使用的是切片方式?；蛘呤褂弥羔樳M行傳遞，避免在短時間內(nèi)內(nèi)存激增

goroutine 沒有及時釋放

一個 goroutine 創(chuàng)建 2KB

1. 互斥鎖沒有釋放
func mutexTest() {
	mutex := sync.Mutex{}
	for i := 0; i < 10; i++ {
		go func () {
			mutex.Lock()
			fmt.Printf("%d goroutine get mutex", i)
			time.Sleep(100 * time.Microsecond)
		}()
	}
}
2. 死鎖情形
3. 空channel --聲明空channel但是沒有初始化 導(dǎo)致讀寫被阻塞
func channelTest(){
	// 聲明空 channel且不初始化導(dǎo)致阻塞
	var c chan int
	// 向通道中寫數(shù)據(jù)
	go func() {
		c <- 1
		fmt.Printf("g1 send message")
	}()
	// 從通道中讀數(shù)據(jù)
	go func(){
		<- c
		fmt.Printf("g2 receive message")
	}()
}
4. 能進不能出， 能出不能進 （寫和讀 通道量不一致）
導(dǎo)致大量的協(xié)程被阻塞
func channelTest() {
	// 聲明空 channel且不初始化導(dǎo)致阻塞
	var c chan int
	// 10 個向通道中寫數(shù)據(jù),導(dǎo)致 寫大于讀量
	// 10個通道讀數(shù)據(jù)，1個通道寫數(shù)據(jù)也是一樣的
	for i := 0; i < 10; i++ {
		go func() {
			c <- i
			fmt.Printf("g1 send message")
		}()
	}
	// 從通道中讀數(shù)據(jù)
	go func() {
		<-c
		fmt.Printf("g2 receive message")
	}()
}
5. Time 定時器使用 定時器沒有 手動Stop 會一直占有內(nèi)存
func tickerTest() {
	ticker := time.NewTicker(time.Second * 20)
	go func() {
		for t := range ticker.C {
			fmt.Printf("ticker trigger")
		}
	}()
	time.Sleep(time.Second * 20)
	ticker.Stop()
}