最大接続数と最大アイドル接続数は、golang 標準ライブラリの database/sql で定義されています。
この例で MySQL に接続するために使用されている SQL ドライバー パッケージは、github.com/go-sql-driver/mysql です。
最大接続数を設定するためのインターフェイスは、
です。
func (db *DB) SetMaxOpenConns(n int)
ログイン後にコピー
接続の設定MySQL が開くことができる接続の最大数。
n <= 0 の場合、開いている接続の数に制限がないことを意味します。
デフォルトは 0 で、接続数に制限がないことを意味します。
接続数に関連するもう 1 つのパラメーターは MaxIdleConns で、アイドル状態の接続の最大数を表します。
MaxIdleConns が 0 より大きく、MaxOpenConns より大きい場合、MaxIdleConns は MaxOpenConns と等しくなるように調整され、過剰な接続がある場合は過剰な接続が閉じられます。
アイドル接続の最大数を設定するためのインターフェイスは次のとおりです:
func (db *DB) SetMaxIdleConns(n int)
ログイン後にコピー
n<=0 の場合、アイドル接続プールは使用されません。つまり、アイドル接続プールが使用されない場合です。使用すると、未使用の接続は保存されません。したがって、この方法では接続が再利用されず、SQL ステートメントが実行されるたびに新しい接続を再確立する必要があります。 <=0时，空闲连接池不会被使用，即不使用空闲连接池时，未使用的连接将不会被存入其中。因此，这种方法不会重复利用连接，每次执行SQL语句都需要重新建立新的连接。
アイドル接続のデフォルトの最大数は 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: 272019/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 サイトの他の関連記事を参照してください。
![[Web フロントエンド] Node.js クイック スタート](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
