快捷導(dǎo)航

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

更新時(shí)間：2022年12月15日 16:38:06 作者：上后左愛(ài)

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

背景

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

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

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

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

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

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

數(shù)組作為形參遵守的是值拷貝，如果函數(shù)調(diào)用次數(shù)很多并且數(shù)組過(guò)大，導(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
}
# 在短時(shí)間內(nèi) 創(chuàng)建100萬(wàn)數(shù)組 內(nèi)存是8M，短時(shí)間內(nèi)調(diào)用 100 次，并且作為是形參 在Go進(jìn)行是 值Copy ,800M, 所以在時(shí)間過(guò)程中：

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

goroutine 沒(méi)有及時(shí)釋放

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

1. 互斥鎖沒(méi)有釋放
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但是沒(méi)有初始化 導(dǎo)致讀寫(xiě)被阻塞
func channelTest(){
	// 聲明空 channel且不初始化導(dǎo)致阻塞
	var c chan int
	// 向通道中寫(xiě)數(shù)據(jù)
	go func() {
		c <- 1
		fmt.Printf("g1 send message")
	}()
	// 從通道中讀數(shù)據(jù)
	go func(){
		<- c
		fmt.Printf("g2 receive message")
	}()
}
4. 能進(jìn)不能出， 能出不能進(jìn) （寫(xiě)和讀 通道量不一致）
導(dǎo)致大量的協(xié)程被阻塞
func channelTest() {
	// 聲明空 channel且不初始化導(dǎo)致阻塞
	var c chan int
	// 10 個(gè)向通道中寫(xiě)數(shù)據(jù),導(dǎo)致 寫(xiě)大于讀量
	// 10個(gè)通道讀數(shù)據(jù)，1個(gè)通道寫(xiě)數(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 定時(shí)器使用 定時(shí)器沒(méi)有 手動(dòng)Stop 會(huì)一直占有內(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()
}