当前位置:首页 > 文章列表 > Golang > Go问答 > go的连接资源释放问题、Mysql、Redis资源释放?

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

来源:SegmentFault 2023-01-07 12:02:13 0浏览 收藏

来到golang学习网的大家,相信都是编程学习爱好者,希望在这里学习Golang相关编程知识。下面本篇文章就来带大家聊聊《go的连接资源释放问题、Mysql、Redis资源释放?》,介绍一下MySQL、Redis、go,希望对大家的知识积累有所帮助,助力实战开发!

问题内容

背景:
新手学习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
}

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

正确答案

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

今天带大家了解了MySQL、Redis、go的相关知识,希望对你有所帮助;关于Golang的技术知识我们会一点点深入介绍,欢迎大家关注golang学习网公众号,一起学习编程~

版本声明
本文转载于:SegmentFault 如有侵犯,请联系study_golang@163.com删除
golang 切片裁剪后改变原切片,导致重新赋值?golang 切片裁剪后改变原切片,导致重新赋值?
上一篇
golang 切片裁剪后改变原切片,导致重新赋值?
请教一个go 使用redis的问题?
下一篇
请教一个go 使用redis的问题?
查看更多
最新文章
查看更多
课程推荐
  • 前端进阶之JavaScript设计模式
    前端进阶之JavaScript设计模式
    设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
    542次学习
  • GO语言核心编程课程
    GO语言核心编程课程
    本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
    508次学习
  • 简单聊聊mysql8与网络通信
    简单聊聊mysql8与网络通信
    如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
    497次学习
  • JavaScript正则表达式基础与实战
    JavaScript正则表达式基础与实战
    在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
    487次学习
  • 从零制作响应式网站—Grid布局
    从零制作响应式网站—Grid布局
    本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
    484次学习
查看更多
AI推荐
  • 茅茅虫AIGC检测:精准识别AI生成内容,保障学术诚信
    茅茅虫AIGC检测
    茅茅虫AIGC检测,湖南茅茅虫科技有限公司倾力打造,运用NLP技术精准识别AI生成文本,提供论文、专著等学术文本的AIGC检测服务。支持多种格式,生成可视化报告,保障您的学术诚信和内容质量。
    9次使用
  • 赛林匹克平台:科技赛事聚合,赋能AI、算力、量子计算创新
    赛林匹克平台(Challympics)
    探索赛林匹克平台Challympics,一个聚焦人工智能、算力算法、量子计算等前沿技术的赛事聚合平台。连接产学研用,助力科技创新与产业升级。
    46次使用
  • SEO  笔格AIPPT:AI智能PPT制作,免费生成,高效演示
    笔格AIPPT
    SEO 笔格AIPPT是135编辑器推出的AI智能PPT制作平台,依托DeepSeek大模型,实现智能大纲生成、一键PPT生成、AI文字优化、图像生成等功能。免费试用,提升PPT制作效率,适用于商务演示、教育培训等多种场景。
    53次使用
  • 稿定PPT:在线AI演示设计,高效PPT制作工具
    稿定PPT
    告别PPT制作难题!稿定PPT提供海量模板、AI智能生成、在线协作,助您轻松制作专业演示文稿。职场办公、教育学习、企业服务全覆盖,降本增效,释放创意!
    48次使用
  • Suno苏诺中文版:AI音乐创作平台,人人都是音乐家
    Suno苏诺中文版
    探索Suno苏诺中文版,一款颠覆传统音乐创作的AI平台。无需专业技能,轻松创作个性化音乐。智能词曲生成、风格迁移、海量音效,释放您的音乐灵感!
    54次使用
微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议隐私政策
返回登录
  • 重置密码