去verison 1.9.2

go-sql-driver/mysql git commit hash cd4cb90

mysql服务器版本:5.6.15-log MySQL Community Server

操作系统版本:CentOS release 6.7 (Final)

数据库打开配置

最大空闲连接数 = 5

max_open_conns = 30

max_life_time=600

超时=600

mysql配置

+-----------------------------+----------+
| Variable_name               | Value    |
+-----------------------------+----------+
| connect_timeout             | 60       |
| delayed_insert_timeout      | 300      |
| interactive_timeout         | 600      |
| lock_wait_timeout           | 31536000 |
| log_output                  | FILE     |
| net_read_timeout            | 30       |
| net_write_timeout           | 60       |
| wait_timeout                | 600      |
+-----------------------------+----------+

lsof 输出

srv_promo 12672 root 10u sock 0,6 0t0 63382668 无法识别协议(protocol)

srv_promo 12672 root 11u sock 0,6 0t0 63366850 无法识别协议(protocol)

srv_promo 12672 root 12u sock 0,6 0t0 63366688 无法识别协议(protocol)

srv_promo 12672 root 13u sock 0,6 0t0 63366690 无法识别协议(protocol)

mysql config

lsof output

代码如下:

打包数据库测试

import (
    "database/sql"
    "fmt"
    "github.com/golang/glog"
    "gopkg.in/gorp.v2"
    "log"
    "os"
    "sync"
    "time"
)

type DatabaseConfig struct {
    DBName               string `toml:"dbname"`
    Host                 string `toml:"host"`
    Port                 int    `toml:"port"`
    User                 string `toml:"user"`
    Password             string `toml:"password"`
    Sslmode              string `toml:"sslmode"`
    ShowLog              bool
    DataSaveDir          string
    DataFileSaveLoopSize int
    MaxIdleConns         int `toml:"max_idle_conns"`
    MaxOpenConns         int `toml:"max_open_conns"`
    MaxLifeTime          int `toml:"max_life_time"`
    Timeout              int `toml:"timeout"`
    RTimeout             int `toml:"rtimeout"`
    WTimeout             int `toml:"wtimeout"`
}

func (c DatabaseConfig) MySQLSource() string {
    params := make(map[string]string, 0)
    params["charset"] = "utf8mb4"
    cfg := mysql.Config{}
    cfg.User = c.User
    cfg.Passwd = c.Password
    cfg.DBName = c.DBName
    cfg.ParseTime = true
    cfg.Collation = "utf8mb4_unicode_ci"
    cfg.Params = params
    cfg.Loc, _ = time.LoadLocation("Asia/Chongqing")
    cfg.Timeout = time.Duration(c.Timeout) * time.Second
    cfg.MultiStatements = true
    cfg.ReadTimeout = time.Duration(c.RTimeout) * time.Second
    cfg.WriteTimeout = time.Duration(c.WTimeout) * time.Second
    return cfg.FormatDSN()
}

var (
    dbmap     *gorp.DbMap
    Dbm       *gorp.DbMap
    config    DatabaseConfig
    opened    bool
    openMutex sync.RWMutex
    DB        *sql.DB
)

//Open open the database for passport with config
func Open(cfg DatabaseConfig) {
    if !opened {
        config = cfg
        db, err := sql.Open("mysql", config.MySQLSource())
        glog.Infof("open err %v ", err)
        if err != nil {
            panic(fmt.Errorf("sql.Open failed: %v", err))
        }
        if config.MaxLifeTime > 0 {
            db.SetConnMaxLifetime(time.Duration(config.MaxLifeTime) * time.Second)
        }
        db.SetMaxIdleConns(config.MaxIdleConns)
        db.SetMaxOpenConns(config.MaxOpenConns)
        db.Ping()
        DB = db
        // construct a gorp DbMap
        dbmap = &gorp.DbMap{Db: db, Dialect: gorp.MySQLDialect{"InnoDB", "utf8mb4"}}
        Dbm = dbmap

        err = dbmap.CreateTablesIfNotExists()
        if err != nil {
            panic("create table failed " + err.Error())
        }
        openMutex.Lock()
        opened = true
        openMutex.Unlock()
        if config.ShowLog {
            dbmap.TraceOn("[gorp]", log.New(os.Stdout, schemaName+" ", log.Lmicroseconds))
        }
    }
}

//Close close the database for passport
func Close() {
    if dbmap != nil && opened {
        glog.Infof("close database %s for %s", config.DBName, schemaName)
        dbmap.Db.Close()
        openMutex.Lock()
        opened = false
        openMutex.Unlock()
    }
}

最佳答案

(不是答案，但评论太多了。)

两件事:

1. 请尝试想出一个 MCVE —首先是为了您自己，其次(如果仅此一项不能帮助您解决问题)—为了我们。

   我的意思是，您的示例中发生了太多事情:您正在使用 gorp ，它不是 Go 标准库的一部分，而这个包——据说包装了 database/sql 机器——在使用数据库时绝对可以做任何事情。

   这不是处理此类问题的方式。 相反，您应该从头开始并首先使用 纯 database/sql 层，看看它是否有效。 如果是，则问题出在 gorp 上。

   还有一个细节是你不应该使用 3rd 方包在你的 MCVE 中做一些琐碎的事情； 在这里，我说的是日志记录:在一个精简的例子中， 标准的 fmt.Print* 函数就可以了，或者， 如果您觉得不可能全面开展企业业务， 标准的 log 包将满足要求。

2. Go 中的 SQL 数据库层明确设计用于 具有与 SQL 数据库层完全不同的语义 由其他流行语言/框架实现。

   Go 的不同之处在于它旨在处理大量 通常在服务器软件上生成的工作负载。 除其他外，这意味着

   • 数据库连接默认合并。
   • 它们根据需要重复使用，当您执行查询或 不在交易中的陈述，你不知道是否 这将创建一个新连接或重用现有连接， 如果是，那么具体是哪一个。
   • 新连接实际上并不连接，除非有什么 对它们执行(或调用它们的 Ping() 方法)。

关于mysql - 去使用连接池连接mysql发生socket leak，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/47384458/