数据库连接丢失需主动检测与处理，首先使用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，并识别是否为连接类错误。
立即学习“go语言免费学习笔记（深入）”；
MySQL8 CRM Schema Design Expert
下载
面向 CRM 系统的 MySQL 8 数据库模式设计。当用户需要为客户关系管理（CRM）系统设计、评审、优化或生成数据库模式时，应使用此项技能。
- 捕获 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分钟则关闭
这样即使数据库重启或防火墙断开旧连接，新请求也能建立新连接。
基本上就这些。Golang 不会自动“感知”连接丢失，关键在于主动检测 + 错误重试 + 合理连接池配置。只要做好这三点，大多数连接异常都能被妥善处理。
