Golang如何检测数据库连接丢失_Golang DB connection error解决方案_技术教程

数据库连接丢失需主动检测与处理，首先使用DB.Ping()检查连接，其次在Query、Exec等操作中捕获如"connection refused"等网络错误并进行重试。

数据库连接丢失是 Golang 应用在长时间运行或网络不稳定环境下常见的问题。Go 的 database/sql 包本身不主动监控连接状态，而是依赖连接池和懒加载机制，因此需要开发者主动处理连接异常。以下是检测和应对数据库连接丢失的实用方案。

1. 使用 DB.Ping() 检测连接可用性

最直接的方式是调用 DB.Ping() 方法，它会从连接池中取出一个连接并发送一个轻量的心跳请求到数据库。如果返回 error，说明当前连接不可用。

示例：

if err := db.Ping(); err != nil {
    log.Fatal("数据库连接失败:", err)
}

可以在程序启动时使用，也可以定期执行健康检查（如配合定时任务）。

2. 在查询时捕获连接错误

实际业务中，连接可能在调用 Query、Exec 等方法时才暴露问题。应始终检查返回的 error，并识别是否为连接类错误。

常见处理方式：

捕获 error 并判断是否包含 "connection refused"、"network error"、"broken pipe" 等关键词
对临时性错误进行重试（如网络抖动）

var rows *sql.Rows
var err error
for i := 0; i < 3; i++ {
    rows, err = db.Query("SELECT name FROM users")
    if err == nil {
        break
    }
    if !isConnectionError(err) {
        break // 非连接错误，无需重试
    }
    time.Sleep(1 * time.Second)
}
if err != nil {
    log.Fatal("查询失败:", err)
}

3. 定义连接错误判断函数

通过 error 字符串判断是否为连接问题，虽然不够优雅但实用。

func isConnectionError(err error) bool {
    errMsg := err.Error()
    connectionErrors := []string{
        "connection refused",
        "network error",
        "dial tcp",
        "broken pipe",
        "connection reset by peer",
    }
    for _, prefix := range connectionErrors {
        if strings.Contains(errMsg, prefix) {
            return true
        }
    }
    return false
}

注意：不同数据库驱动（如 mysql、postgres）的错误信息略有差异，需根据实际情况调整。

4. 设置连接池参数以自动恢复

合理配置 sql.DB 的连接池行为，有助于自动处理失效连接。

SetMaxLifetime：设置连接的最大存活时间，避免长期空闲连接被中间件关闭
SetMaxIdleConns 和 SetConnMaxIdleTime：控制空闲连接回收

建议配置：

db.SetMaxOpenConns(20)
db.SetMaxIdleConns(10)
db.SetConnMaxLifetime(5 * time.Minute)   // 连接最多使用5分钟
db.SetConnMaxIdleTime(2 * time.Minute)   // 空闲超过2分钟则关闭