golang と mysql を組み合わせて最大接続数とアイドル接続の最大数を設定する方法

最大接続数と最大アイドル接続数は、golang 標準ライブラリの database/sql で定義されています。

この例で MySQL に接続するために使用されている SQL ドライバー パッケージは、github.com/go-sql-driver/mysql です。

最大接続数を設定するためのインターフェイスは、

です。

func (db *DB) SetMaxOpenConns(n int)

接続の設定MySQL が開くことができる接続の最大数。

n

デフォルトは 0 で、接続数に制限がないことを意味します。

接続数に関連するもう 1 つのパラメーターは MaxIdleConns で、アイドル状態の接続の最大数を表します。

MaxIdleConns が 0 より大きく、MaxOpenConns より大きい場合、MaxIdleConns は MaxOpenConns と等しくなるように調整され、過剰な接続がある場合は過剰な接続が閉じられます。

アイドル接続の最大数を設定するためのインターフェイスは次のとおりです:

func (db *DB) SetMaxIdleConns(n int)

n

アイドル接続のデフォルトの最大数は 2 です:
constdefaultMaxIdleConns = 2

オープン接続とアイドル接続の関係については、次の内容を追加してください:

開いた接続 = 使用中の接続 (inuse) アイドル状態の接続 (idle)

接続の最大数とアイドル状態の接続の最大数をテストして検証してみましょう。

1. 最大接続数テスト

最初に開いている接続の最大数を 1 に設定し、次に 20 個の goroutine を開き、各 goroutine が SQL ステートメントを実行して、接続の接続 ID を出力します。 SQL を実行するために使用されます。接続を占有する時間のかかる SQL ステートメントを実行するときに、SQL を実行する必要がある他の Goroutine の実行を観察します。

コード例は次のとおりです:

package main

import (
        "database/sql"
        "log"

        _ "github.com/go-sql-driver/mysql"
)

var DB *sql.DB
var dataBase = "root:Aa123456@tcp(127.0.0.1:3306)/?loc=Local&parseTime=true"

func Init() {
        var err error
        DB, err = sql.Open("mysql", dataBase)
        if err != nil {
                log.Fatalln("open db fail:", err)
        }

        DB.SetMaxOpenConns(1)

        err = DB.Ping()
        if err != nil {
                log.Fatalln("ping db fail:", err)
        }
}

func main() {
        Init()
        
        //开启20个goroutine
        for i:=0; i < 20; i++ {
                go one_worker(i)
        }
        
        select {
        }

}

func one_worker(i int) {
        var connection_id int
        err := DB.QueryRow("select CONNECTION_ID()").Scan(&connection_id)
        if err != nil {
                log.Println("query connection id failed:", err)
                return
        }

        log.Println("worker:", i, ", connection id:", connection_id)

        var result int
        err = DB.QueryRow("select sleep(10)").Scan(&result)
        if err != nil {
                log.Println("query sleep connection id faild:", err)
                return
        }

}

output

2019/10/02 18:14:25 ワーカー: 2、接続 ID: 55
2019/ 10/02 18:14:25 ワーカー: 17 、接続 ID: 55
2019/10/02 18:14:25 ワーカー: 11 、接続 ID: 55
2019/10/02 18: 14:35 ワーカー: 3 、接続 ID: 55
2019/10/02 18:14:45 ワーカー: 0 、接続 ID: 55
2019/10/02 18:14:45 ワーカー: 4 、接続id: 55
2019/10/02 18:14:45 ワーカー: 5 、接続 ID: 55
2019/10/02 18:15:05 ワーカー: 7 、接続 ID: 55
2019/ 10/02 18:15:25 ワーカー: 15 、接続 ID: 55
2019/10/02 18:15:25 ワーカー: 6 、接続 ID: 55
2019/10/02 18:15:35ワーカー: 13 、接続 ID: 55
2019/10/02 18:15:45 ワーカー: 19 、接続 ID: 55
2019/10/02 18:15:45 ワーカー: 10 、接続 ID: 55
2019/10/02 18:15:45 ワーカー: 12 、接続 ID: 55
2019/10/02 18:15:55 ワーカー: 14 、接続 ID: 55
2019/10/02 18:16 :15 ワーカー: 8 、接続 ID: 55
2019/10/02 18:16:35 ワーカー: 18 、接続 ID: 55
2019/10/02 18:16:35 ワーカー: 1 、接続 ID : 55
2019/10/02 18:17:05 ワーカー: 16 、接続 ID: 55
2019/10/02 18:17:35 ワーカー: 9 、接続 ID: 55

show processlist を使用して接続を表示します

mysql> show processlist;
+----+------+-----------------+------+---------+------+------------+------------------+
| Id | User | Host            | db   | Command | Time | State      | Info             |
+----+------+-----------------+------+---------+------+------------+------------------+
| 20 | root | localhost       | NULL | Query   |    0 | starting   | show processlist |
| 55 | root | localhost:59518 | NULL | Query   |    5 | User sleep | select sleep(10) |
+----+------+-----------------+------+---------+------+------------+------------------+
2 rows in set (0.00 sec)

netstat を使用して接続を表示します

netstat -an | grep 3306
tcp4       0      0  127.0.0.1.3306         127.0.0.1.59518        ESTABLISHED
tcp4       0      0  127.0.0.1.59518        127.0.0.1.3306         ESTABLISHED
tcp46      0      0  *.3306                 *.*                    LISTEN

結果からわかるように、20 個のゴルーチンが同じ接続を順番に使用しています (接続 ID は 55) で SQL ステートメントを実行します。

接続が占有されている場合、他の goroutine はブロッキング状態になります。接続が使い果たされるまで、他の goroutine はその接続を使用できません。

複数のゴルーチンが SQL を実行している場合でも、複数の接続は作成されません。

したがって、最大接続数の設定が有効になります。

読者の中には、アイドル接続の最大数が設定されているのを見たことがなければ、現時点でのスペース接続の最大数はどれくらいなのかと尋ねる人もいるかもしれません。

前に述べたように、アイドル接続のデフォルトの最大数は 2 です。

スペース接続の最大数をテストしてみましょう。

2. アイドル接続の最大数テスト

次の例では、最大接続数を 1 に、アイドル接続の最大数を 0 に設定します。 3 秒ごとに SQL ステートメントを実行します。

コードは次のとおりです:

package main

import (
        "database/sql"
        "log"
        "time"

        _ "github.com/go-sql-driver/mysql"

)

var DB *sql.DB
var dataBase = "root:Aa123456@tcp(127.0.0.1:3306)/?loc=Local&parseTime=true"

func mysqlInit() {
        var err error
        DB, err = sql.Open("mysql", dataBase)
        if err != nil {
                log.Fatalln("open db fail:", err)
        }

        DB.SetMaxOpenConns(1)
        DB.SetMaxIdleConns(0)

        err = DB.Ping()
        if err != nil {
                log.Fatalln("ping db fail:", err)
        }
}

func main() {
        mysqlInit()

        for {
                execSql()
                time.Sleep(3*time.Second)
        }
}


func execSql() {
        var connection_id int
        err := DB.QueryRow("select CONNECTION_ID()").Scan(&connection_id)
        if err != nil {
                log.Println("query connection id failed:", err)
                return
        }

        log.Println("connection id:", connection_id)
}

出力:

2019/10/13 23:06:00 接続ID: 26

2019/10 /13 23 :06:03 接続 ID: 27

2019/10/13 23:06:06 接続 ID: 28
2019/10/13 23:06:09 接続 ID: 29
2019/ 10/13 23:06:12 接続 ID: 30
2019/10/13 23:06:15 接続 ID: 31
2019/10/13 23:06:18 接続 ID: 32
2019 /10/ 13 23:06:21 接続 ID: 33
2019/10/13 23:06:24 接続 ID: 34
2019/10/13 23:06:27 接続 ID: 35
2019/10/13 23:06:30 接続 ID: 36
2019/10/13 23:06:33 接続 ID: 37
2019/10/13 23:06:36 接続 ID: 38

結果からわかるように、使用される接続 ID は SQL が実行されるたびに異なります。

アイドル接続の最大数を 0 に設定します。SQL を実行するたびに、接続はアイドル接続プールに入れられず、閉じられます。次回 SQL が実行されると、新しい接続が作成されます。再確立される。

以上がgolang と mysql を組み合わせて最大接続数とアイドル接続の最大数を設定する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。