Go语言定时任务子例程的MySQL连接开闭处理方案咨询

这是用Go做定时任务+MySQL场景下非常典型的问题，我来帮你拆解下根源，再给出具体的解决方案：

问题根源分析 #

1. 全局连接池失效：你一开始用的全局sqlx.DB其实是连接池，不是单个连接。当MySQL重启后，连接池里的旧连接已经失效，但默认配置下，连接池不会主动检测这些失效连接，导致后续任务用旧连接报错（invalid connection、EOF这些）。
2. 每次任务新建连接导致连接爆炸：改成每次任务里sql.Open+defer Close()相当于每次都创建一个新的连接池，而Go标准库的sql.DB默认对打开连接数没有严格限制，加上定时任务频繁执行，很快就会超过MySQL的max_connections限制，触发连接数过多错误。

正确的处理方案 #

核心思路是复用全局连接池+配置连接池健康参数+必要的错误重试，具体步骤如下：

1. 初始化全局连接池时配置健康检查参数 #

sqlx.DB的连接池有几个关键参数，必须合理配置才能自动清理失效连接、控制连接数：

import (
    "time"
    "log"
    "github.com/jmoiron/sqlx"
    _ "github.com/go-sql-driver/mysql"
)

var globalDB *sqlx.DB

func initDB() error {
    var err error
    globalDB, err = sqlx.Open("mysql", "user:password@tcp(127.0.0.1:3306)/dbname?parseTime=true")
    if err != nil {
        return err
    }

    // 配置连接池核心参数
    globalDB.SetMaxOpenConns(15)       // 最大打开的连接数，根据MySQL的max_connections和任务量调整，比如MySQL默认是151，这里设15足够大部分定时任务场景
    globalDB.SetMaxIdleConns(5)        // 最大空闲连接数，保持少量空闲连接避免频繁创建销毁
    globalDB.SetConnMaxLifetime(25 * time.Minute) // 连接最大存活时间，必须小于MySQL的wait_timeout（默认8小时），比如设25分钟，确保连接在失效前被回收
    globalDB.SetConnMaxIdleTime(10 * time.Minute) // 空闲连接最大存活时间，清理太久没用到的空闲连接

    // 初始化时Ping验证连接有效性
    if err := globalDB.Ping(); err != nil {
        return err
    }

    log.Println("DB connection pool initialized successfully")
    return nil
}

这些参数的作用：

• SetConnMaxLifetime：强制连接在指定时间后被回收，避免连接池里留存MySQL重启后的失效连接
• SetMaxOpenConns：严格限制同时打开的连接数，防止连接数爆炸
• SetConnMaxIdleTime：避免空闲连接太久导致失效

2. 定时任务复用全局连接池，执行前可选Ping验证 #

不要每次任务新建连接，直接把全局globalDB传给任务函数。如果担心连接池里的连接失效，可以在任务执行前先Ping一下（不过配置好上面的参数后，连接池会自动处理，Ping是额外的保险）：

func scheduledTask() {
    ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    defer cancel()

    // 可选：Ping验证连接有效性，快速发现失效连接
    if err := globalDB.PingContext(ctx); err != nil {
        log.Printf("DB ping failed: %v", err)
        // 这里不需要重新初始化连接池，下一次任务执行时连接池会自动创建新连接
        return
    }

    // 执行具体数据库操作，用Context控制超时
    var result string
    err := globalDB.GetContext(ctx, &result, "SELECT column FROM table LIMIT 1")
    if err != nil {
        log.Printf("Query failed: %v", err)
        // 添加重试逻辑，处理临时连接问题
        for retry := 0; retry < 2; retry++ {
            time.Sleep(1 * time.Second)
            err := globalDB.GetContext(ctx, &result, "SELECT column FROM table LIMIT 1")
            if err == nil {
                log.Printf("Retry succeeded, got result: %s", result)
                return
            }
            log.Printf("Retry %d failed: %v", retry+1, err)
        }
        return
    }

    log.Printf("Got result: %s", result)
}

3. 关键注意事项 #

• 永远不要在定时任务里每次创建新的sqlx.DB实例：每个sqlx.DB都是独立的连接池，频繁创建会导致连接数失控。
• 必须用Context控制数据库操作超时：避免慢查询或者连接挂起导致连接被占用。
• 确保查询后正确关闭Rows：如果你用Query/QueryContext，一定要defer rows.Close()，防止连接泄漏（你说已经检查过这点，保持就好）。

为什么这个方案能解决你的问题 #

• 连接池会自动回收失效连接，MySQL重启后，旧连接超过ConnMaxLifetime会被清理，新任务会自动创建新连接。
• 严格限制了最大打开连接数，不会出现连接数过多的错误。
• 重试机制可以处理偶尔的临时连接问题，提升任务稳定性。

内容的提问来源于stack exchange，提问作者user1050134