Golang避坑——方法接收者&&内存泄露

Golang避坑——方法接收者&&内存泄露,第1张

先来看一个示例:

type Person struct {
	Name string
	Age int
}

func (p Person)setAge(age int)  {
	fmt.Println("传递的值为:",age)
	p.Age=age
}
func (p Person)getAge()  int{
	return p.Age
}
func main()  {
	p:=Person{}
	p.setAge(23)
	fmt.Println("结构值为:",p.getAge())
}

思考一下:这里输出的是23还是0???

以上代码:(p Person) 属于拷贝副本,复制 *** 作。

如果要对值进行改变,方法的接受者一般采用指针形式,即:(p *Person)

看了以上代码,可能没有感觉,我们再来看看实际项目中遇到的一个内存泄露问题:

package main

import (
	"fmt"
	redis "github.com/go-redis/redis"
	"runtime"
	"sync"
	"time"
)

type RedisCon struct {
	Client *redis.Client
}

func (r RedisCon) getClient() *redis.Client {
	if r.Client != nil {
		return r.Client
	}
	r.Client = redis.NewClient(&redis.Options{
		Addr:     "127.0.0.1",
		Password: "pwd",
		DB:       0,
	})
	return r.Client
}
func main() {
	waitGroup := sync.WaitGroup{}
	redisCon:=RedisCon{}
	for i := 0; i < 100; i++ {
		go func() {
			 redisCon.getClient()
			//模拟业务逻辑
		}()
		waitGroup.Add(1)
		time.Sleep(time.Millisecond*10) //多个Goroutine之间存在先后顺序,即一个执行完延迟10ms之后再启用另外一个
	}
	fmt.Println("goroutine数量:", runtime.NumGoroutine())
	time.Sleep(time.Second * 5)
	fmt.Println("5s之后:goroutine数量:", runtime.NumGoroutine())
	time.Sleep(time.Second * 30)
	fmt.Println("30s之后:goroutine数量:", runtime.NumGoroutine())
	time.Sleep(time.Second * 50)
	fmt.Println("50s之后:goroutine数量:", runtime.NumGoroutine())
	for i := 0; i < 100; i++ {
		waitGroup.Done()
	}
	waitGroup.Wait()

}

以上代码的核心思想是:新建一个redis连接client共用。结果是:func (r RedisCon) getClient() 这里的接受者为值拷贝,每次请求过来都是

r.Client==nil,所以会再次创建redis客户端连接。由于redis的配置项
maxclients一般采用默认,即不做限制,因此会有越来越多的连接,同时由于client连接到server(TCP连接),Go语言底层不会对该client进行释放,因此最终导致内存爆满。

如果将以上代码的

func (r RedisCon) getClient() *redis.Client {...}改为:
func (r *RedisCon) getClient() *redis.Client {...},运行效果如下:

 2个goroutine分别是:主进程(占用一个goroutine)、redis-client(占用一个goroutine)。

欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/langs/995988.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-05-21
下一篇 2022-05-21

发表评论

登录后才能评论

评论列表(0条)

保存