当前位置:首页 > 文章列表 > 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互联网时代的弄潮儿。
    511次学习
  • 简单聊聊mysql8与网络通信
    简单聊聊mysql8与网络通信
    如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
    498次学习
  • JavaScript正则表达式基础与实战
    JavaScript正则表达式基础与实战
    在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
    487次学习
  • 从零制作响应式网站—Grid布局
    从零制作响应式网站—Grid布局
    本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
    484次学习
查看更多
AI推荐
  • 千音漫语:智能声音创作助手,AI配音、音视频翻译一站搞定!
    千音漫语
    千音漫语,北京熠声科技倾力打造的智能声音创作助手,提供AI配音、音视频翻译、语音识别、声音克隆等强大功能,助力有声书制作、视频创作、教育培训等领域,官网:https://qianyin123.com
    94次使用
  • MiniWork:智能高效AI工具平台,一站式工作学习效率解决方案
    MiniWork
    MiniWork是一款智能高效的AI工具平台,专为提升工作与学习效率而设计。整合文本处理、图像生成、营销策划及运营管理等多元AI工具,提供精准智能解决方案,让复杂工作简单高效。
    89次使用
  • NoCode (nocode.cn):零代码构建应用、网站、管理系统,降低开发门槛
    NoCode
    NoCode (nocode.cn)是领先的无代码开发平台,通过拖放、AI对话等简单操作,助您快速创建各类应用、网站与管理系统。无需编程知识,轻松实现个人生活、商业经营、企业管理多场景需求,大幅降低开发门槛,高效低成本。
    104次使用
  • 达医智影:阿里巴巴达摩院医疗AI影像早筛平台,CT一扫多筛癌症急慢病
    达医智影
    达医智影,阿里巴巴达摩院医疗AI创新力作。全球率先利用平扫CT实现“一扫多筛”,仅一次CT扫描即可高效识别多种癌症、急症及慢病,为疾病早期发现提供智能、精准的AI影像早筛解决方案。
    98次使用
  • 智慧芽Eureka:更懂技术创新的AI Agent平台,助力研发效率飞跃
    智慧芽Eureka
    智慧芽Eureka,专为技术创新打造的AI Agent平台。深度理解专利、研发、生物医药、材料、科创等复杂场景,通过专家级AI Agent精准执行任务,智能化工作流解放70%生产力,让您专注核心创新。
    95次使用
微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议隐私政策
返回登录
  • 重置密码