go的连接资源释放问题、Mysql、Redis资源释放?

背景:
新手学习Go做了一个API接口,然后用到了Mysql、Redis,这个资源释放问题有很大的疑惑

求各位高手指点,在线等,谢谢各位大佬,具体代码如下:

Redis

使用的这个包:"github.com/go-redis/redis"
Redis 初始化文件:

import (
    "dot/pkg/logging"
    "dot/pkg/setting"
    "fmt"
    "github.com/go-redis/redis"
    "net"
    "time"
)

var RedisClient *redis.Client

// ServiceInit init Redis
func ServiceInit() {
    RedisClient = redis.NewClient(&redis.Options{
        // 连接信息
        DB:       0,                             // redis数据库index
        Network:  "tcp",                         // 网络类型,tcp or unix,默认tcp
        Addr:     setting.RedisSetting.Host,     // 主机名+冒号+端口,默认localhost:6379
        Password: setting.RedisSetting.Password, // 密码

        // 连接池容量及闲置连接数量
        PoolSize:     15, // 连接池最大socket连接数,默认为4倍CPU数, 4 * runtime.NumCPU
        MinIdleConns: 10, // 在启动阶段创建指定数量的Idle连接,并长期维持idle状态的连接数不少于指定数量;。

        // 超时
        DialTimeout:  5 * time.Second, // 连接建立超时时间,默认5秒。
        ReadTimeout:  3 * time.Second, // 读超时,默认3秒, -1表示取消读超时
        WriteTimeout: 3 * time.Second, // 写超时,默认等于读超时
        PoolTimeout:  4 * time.Second, // 当所有连接都处在繁忙状态时,客户端等待可用连接的最大等待时长,默认为读超时+1秒。

        //闲置连接检查包括IdleTimeout,MaxConnAge
        IdleCheckFrequency: setting.RedisSetting.IdleCheckFrequency * time.Second, // 闲置连接检查的周期,默认为1分钟,-1表示不做周期性检查,只在客户端获取连接时对闲置连接进行处理。
        IdleTimeout:        setting.RedisSetting.IdleTimeout * time.Minute,        // 闲置超时,默认5分钟,-1表示取消闲置超时检查
        MaxConnAge:         setting.RedisSetting.MaxConnAge * time.Second,         // 连接存活时长,从创建开始计时,超过指定时长则关闭连接,默认为0,即不关闭存活时长较长的连接

        //命令执行失败时的重试策略
        MaxRetries:      0,                      // 命令执行失败时,最多重试多少次,默认为0即不重试
        MinRetryBackoff: 8 * time.Millisecond,   // 每次计算重试间隔时间的下限,默认8毫秒,-1表示取消间隔
        MaxRetryBackoff: 512 * time.Millisecond, // 每次计算重试间隔时间的上限,默认512毫秒,-1表示取消间隔

        //可自定义连接函数
        Dialer: func() (net.Conn, error) {
            netDialer := &net.Dialer{
                Timeout:   5 * time.Second,
                KeepAlive: 5 * time.Minute,
            }
            return netDialer.Dial("tcp", setting.RedisSetting.Host)
        },

        //钩子函数
        OnConnect: func(conn *redis.Conn) error { //仅当客户端执行命令时需要从连接池获取连接时,如果连接池需要新建连接时则会调用此钩子函数
            return nil
        },
    })
    return
}

// Set 设置Key
func Set(key string, data interface{}, time time.Duration) error {
    RedisClient.Set(key,data,time)
    return nil
}

基本使用的时候都是这么使用,没有进行关闭

// 直接调用封装的方法
pkgname.Set(key , data, time)

Mysql

使用的Gorm
Mysql 初始化文件:


import (
    "dot/pkg/setting"
    "fmt"
    "gorm.io/driver/mysql"
    "gorm.io/gorm"
    "gorm.io/gorm/logger"
    "gorm.io/gorm/schema"
    "log"
    "os"
    "strings"
    "time"
)

var Db *gorm.DB

// ServiceInit initializes the database instance
func ServiceInit() {
    var err error
    Logger := logger.New(
        log.New(os.Stdout, "\r\n", log.LstdFlags), // io writer
        logger.Config{
            Colorful:                  true,                   // 彩色打印
            LogLevel:                  logger.Info,            // 日志级别
            SlowThreshold:             200 * time.Millisecond, // 慢 SQL 阈值, 200ms
            IgnoreRecordNotFoundError: true,                   // 忽略ErrRecordNotFound(记录未找到)错误
        },
    )
    dsn := fmt.Sprintf("%s:%s@tcp(%s)/%s?charset=utf8&parseTime=True&loc=Local&timeout=%s",
        setting.DatabaseSetting.User,
        setting.DatabaseSetting.Password,
        setting.DatabaseSetting.Host,
        setting.DatabaseSetting.Name,
        setting.DatabaseSetting.Timeout)

    Db, err = gorm.Open(mysql.Open(dsn), &gorm.Config{
        SkipDefaultTransaction:                   true,
        Logger:                                   Logger,
        DisableForeignKeyConstraintWhenMigrating: true,
        NamingStrategy: schema.NamingStrategy{
            SingularTable: true,                                   // 使用单数表名,启用该选项后,`Student` 表将是`student`, 禁用则为`students`
            TablePrefix:   setting.DatabaseSetting.TablePrefix,    // 表名前缀,`User`表为`pre_users`
            NameReplacer:  strings.NewReplacer("AbcID", "abc_id"), // 在转为数据库名称之前,使用NameReplacer更改结构/字段名称。
        },
    })

    if err != nil {
        panic("连接数据库失败, error=" + err.Error())
    }
}

调用的时候就直接使用了,也没有进行关闭:


// 写入数据库中,数据落地
func InsertBatchDB(login []PlayerLogin) (bool, error) {
    loginModSlice := []PlayerLogin{}
    for _, param := range login {
        loginMod := PlayerLogin{}
        _ = deepcopier.Copy(param).To(&loginMod)
        loginModSlice = append(loginModSlice, loginMod)
    }
    err := models.Db.Create(&loginModSlice).Error
    if err != nil {
        return false, err
    }
    return true, nil
}

到底啥时候关闭资源啊?应用不用关闭资源啊,求各位大佬辛苦解答一下,祝各位大佬顺风顺水、升职加薪

阅读 1.9k
1 个回答
✓ 已被采纳

这种写法是单例模式,init会在项目启动的时候就实例化,使用的时候复用不做关闭。
如果需要关闭连接那就需要有重新连接的方式

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题
宣传栏