目次
1. 最大接続数テスト
2. アイドル接続の最大数テスト
ホームページ データベース mysql チュートリアル golang と mysql を組み合わせて最大接続数とアイドル接続の最大数を設定する方法

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

Jun 03, 2023 pm 02:15 PM
mysql golang

最大接続数と最大アイドル接続数は、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: 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 サイトの他の関連記事を参照してください。

このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。

ホットAIツール

Undresser.AI Undress

Undresser.AI Undress

リアルなヌード写真を作成する AI 搭載アプリ

AI Clothes Remover

AI Clothes Remover

写真から衣服を削除するオンライン AI ツール。

Undress AI Tool

Undress AI Tool

脱衣画像を無料で

Clothoff.io

Clothoff.io

AI衣類リムーバー

AI Hentai Generator

AI Hentai Generator

AIヘンタイを無料で生成します。

ホットツール

メモ帳++7.3.1

メモ帳++7.3.1

使いやすく無料のコードエディター

SublimeText3 中国語版

SublimeText3 中国語版

中国語版、とても使いやすい

ゼンドスタジオ 13.0.1

ゼンドスタジオ 13.0.1

強力な PHP 統合開発環境

ドリームウィーバー CS6

ドリームウィーバー CS6

ビジュアル Web 開発ツール

SublimeText3 Mac版

SublimeText3 Mac版

神レベルのコード編集ソフト(SublimeText3)

MySQL:初心者向けのデータ管理の容易さ MySQL:初心者向けのデータ管理の容易さ Apr 09, 2025 am 12:07 AM

MySQLは、インストールが簡単で、強力で管理しやすいため、初心者に適しています。 1.さまざまなオペレーティングシステムに適した、単純なインストールと構成。 2。データベースとテーブルの作成、挿入、クエリ、更新、削除などの基本操作をサポートします。 3.参加オペレーションやサブクエリなどの高度な機能を提供します。 4.インデックス、クエリの最適化、テーブルパーティション化により、パフォーマンスを改善できます。 5。データのセキュリティと一貫性を確保するために、バックアップ、リカバリ、セキュリティ対策をサポートします。

NAVICATでデータベースパスワードを取得できますか? NAVICATでデータベースパスワードを取得できますか? Apr 08, 2025 pm 09:51 PM

NAVICAT自体はデータベースパスワードを保存せず、暗号化されたパスワードのみを取得できます。解決策:1。パスワードマネージャーを確認します。 2。NAVICATの「パスワードを記憶する」機能を確認します。 3.データベースパスワードをリセットします。 4.データベース管理者に連絡してください。

mysqlを表示する方法 mysqlを表示する方法 Apr 08, 2025 pm 07:21 PM

次のコマンドでmysqlデータベースを表示します。サーバーに接続します:mysql -u username -pパスワードrun showデータベース。すべての既存のデータベースを取得するコマンド[データベース]を選択します。データベース名を使用します。テーブルを表示:表を表示します。テーブル構造を表示:テーブル名を説明してください。データを表示:[テーブル名]から[ *]を選択します。

Navicatプレミアムの作成方法 Navicatプレミアムの作成方法 Apr 09, 2025 am 07:09 AM

NAVICATプレミアムを使用してデータベースを作成します。データベースサーバーに接続し、接続パラメーターを入力します。サーバーを右クリックして、[データベースの作成]を選択します。新しいデータベースの名前と指定された文字セットと照合を入力します。新しいデータベースに接続し、オブジェクトブラウザにテーブルを作成します。テーブルを右クリックして、データを挿入してデータを挿入します。

MySQLでテーブルをコピーする方法 MySQLでテーブルをコピーする方法 Apr 08, 2025 pm 07:24 PM

MySQLでテーブルをコピーするには、新しいテーブルの作成、データの挿入、外部キーの設定、インデックスのコピー、トリガー、ストアドプロシージャ、および機能が必要です。特定の手順には、同じ構造を持つ新しいテーブルの作成が含まれます。元のテーブルからデータを新しいテーブルに挿入します。同じ外部キーの制約を設定します(元のテーブルに1つがある場合)。同じインデックスを作成します。同じトリガーを作成します(元のテーブルに1つがある場合)。同じストアドプロシージャまたは関数を作成します(元のテーブルが使用されている場合)。

MariadBのNAVICATでデータベースパスワードを表示する方法は? MariadBのNAVICATでデータベースパスワードを表示する方法は? Apr 08, 2025 pm 09:18 PM

Passwordが暗号化された形式で保存されているため、MariadbのNavicatはデータベースパスワードを直接表示できません。データベースのセキュリティを確保するには、パスワードをリセットするには3つの方法があります。NAVICATを介してパスワードをリセットし、複雑なパスワードを設定します。構成ファイルを表示します(推奨されていない、高リスク)。システムコマンドラインツールを使用します(推奨されません。コマンドラインツールに習熟する必要があります)。

Golangの目的:効率的でスケーラブルなシステムの構築 Golangの目的:効率的でスケーラブルなシステムの構築 Apr 09, 2025 pm 05:17 PM

GO言語は、効率的でスケーラブルなシステムの構築においてうまく機能します。その利点には次のものがあります。1。高性能:マシンコードにコンパイルされ、速度速度が速い。 2。同時プログラミング:ゴルチンとチャネルを介してマルチタスクを簡素化します。 3。シンプルさ:簡潔な構文、学習コストとメンテナンスコストの削減。 4。クロスプラットフォーム:クロスプラットフォームのコンパイル、簡単な展開をサポートします。

mysqlをコピーして貼り付ける方法 mysqlをコピーして貼り付ける方法 Apr 08, 2025 pm 07:18 PM

MySQLのコピーと貼り付けには、次の手順が含まれています。データを選択し、Ctrl C(Windows)またはCMD C(MAC)でコピーします。ターゲットの場所を右クリックして、貼り付けまたはCTRL V(Windows)またはCMD V(MAC)を使用します。コピーされたデータは、ターゲットの場所に挿入されるか、既存のデータを置き換えます(データが既にターゲットの場所に存在するかどうかに応じて)。

See all articles