先来看一个示例:
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)。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)