如何在Golang中实现并发数据写入数据库

技术教程
2025-11-03 23:52:02

使用goroutine配合连接池和worker模式控制并发写入数据库，设置MaxOpenConns、MaxIdleConns和ConnMaxLifetime优化连接管理，通过channel限制协程数量，避免资源竞争与连接耗尽，结合错误重试机制保障写入稳定性。

如何在golang中实现并发数据写入数据库

在Golang中实现并发数据写入数据库，关键在于合理使用goroutine、连接池和锁机制，同时避免资源竞争和数据库连接耗尽。下面是一些实用的方法和注意事项。

使用数据库连接池

Golang的database/sql包自带连接池功能，正确配置能有效支持并发写入。

建议设置：

SetMaxOpenConns(n)：控制最大并发连接数，避免数据库压力过大
SetMaxIdleConns(n)：设置空闲连接数，提升重复利用效率
SetConnMaxLifetime(t)：防止长时间运行后连接失效

例如：

db.SetMaxOpenConns(50)
db.SetMaxIdleConns(10)
db.SetConnMaxLifetime(time.Hour)

通过goroutine并发写入

启动多个goroutine处理数据写入，每个goroutine使用独立的语句或事务。

示例：

for _, data := range dataList {
  go func(d Data) {
    _, err := db.Exec("INSERT INTO table VALUES (?, ?)", d.A, d.B)
    if err != nil {
      log.Printf("写入失败: %v", err)
    }
  } (data)
}

注意：直接这样写可能创建太多goroutine，应使用限制机制。

新快购物系统

新快购物系统是集合目前网络所有购物系统为参考而开发，不管从速度还是安全我们都努力做到最好，此版虽为免费版但是功能齐全，无任何错误，特点有：专业的、全面的电子商务解决方案，使您可以轻松实现网上销售；自助式开放性的数据平台，为您提供充满个性化的设计空间；功能全面、操作简单的远程管理系统，让您在家中也可实现正常销售管理；严谨实用的全新商品数据库，便于查询搜索您的商品。