golang mysql データベース接続プールを理解します。
以下は、golang チュートリアル コラムからの golang mysql データベース接続プールの紹介です。困っている友人の役に立てば幸いです。
最近、Go 言語の ORM を使用してデータベース操作を行っていましたが、最終的に無効な接続と呼ばれるバグを見つけたので、接続プールと mysql のタイムアウトについて学習しました。 go ORM.mysql を使用して説明します (言語はすべて接続されており、原則は同じである必要があることを理解しています)。
データベースを追加、削除、変更、確認する場合、最初のステップはデータベースに接続することです
//conn the database func ConnDb(dbConnString string, dbName string) error { maxIdle := 50 maxConn := 50 err := orm.RegisterDataBase(dbName, "mysql", dbConnString+"?charset=utf8&loc=Asia%2FShanghai", maxIdle, maxConn) if err != nil { util.GLogger.Errorw("in Connect DB", "err", err) } return err }
ここでの接続は mysql データベースです。設定される最大接続プールは次のとおりです。 50. アイドル接続の最大数は 50 です。
この接続プールは主に何をするのですか?簡単に言うと、データベースからデータを取得してデータを変更したい場合は、データベースとのパイプラインを確立する必要があります。これは、ネットワーク接続を確立することです。TCP 接続には時間がかかることは誰もが知っています。このパイプラインを構築するのにある程度の時間がかかりました。どうすればそれを捨てずに取り出して使用できますか?接続プールは、これらの確立されたパイプが保存される場所です。値 50 は、単純に最大 50 パイプとして理解できます。大きすぎると、より多くのメモリを占有するため、大きいほど良いことに注意してください。もちろん、メモリを多く消費し、小さすぎるとブロック待ちが発生します。
これらのパイプは接続プールに配置されているため、アイドル接続はこれらのアイドル パイプを参照し、アイドル接続の値設定が接続プールのサイズより大きくないことは明らかです。接続が大きくなると、プールはアイドル状態の接続パイプをあまり節約できなくなるためです。
これらの簡単な概念を理解した後、データベースにアクセスするときのワークフローはどのようなものになるでしょうか?
#この図を通して、接続アクセス プロセス全体を明確に見ることができます。
step1 (利用可能な接続を取得する) 接続プールに移動して、利用可能なアイドル状態の接続を見つけます。アイドル状態の接続がない場合は、接続プールがいっぱいかどうかを確認します。そうでない場合は、新しい接続を作成します。接続がいっぱいである場合は、接続が解放されるのを待ちます。もちろん、アイドル状態の接続がある場合は、接続の有効期限が切れているかどうかを直接判断します。有効期限が切れていない場合は、直接使用されます。有効期限が切れた場合は、接続が期限切れになります。接続プールが満杯かどうかを再判断します。いいえ、満杯の場合は、新しい接続を作成し、満杯になるまで待ちます。
step2 (操作データベース) この接続を取得した後、追加、削除、変更、およびクエリの操作を実行します。
step3 (接続の解放) データベースの操作後、接続を解放する必要がありますが、解放された接続はアイドル状態になります。アイドル状態の接続数を超えた場合は、直接接続が切断されます。そうでない場合は、接続が切断されます。待機に使用されます。
次に、この接続が失敗することに気づくでしょう:
mysql データベースのタイムアウト、データベースとの接続を確立するとき、データベースは常にあなたを信頼できるわけではなく、データベースはタイムアウト、つまり、この時間が経過すると、あなたの接続は信頼されません。もう一度接続する必要があります。次のように、データベースによって設定されているさまざまなタイムアウト ステートメントを確認してください:
show variables like '%timeout%';
その中には 2 つあります。タイムアウト: インタラクティブ接続タイムアウト (interactive_timeout) および非インタラクティブ接続タイムアウト (wait_timeout)
インタラクティブ接続: コマンド ラインを介して mysql に接続します
非インタラクティブ接続: に接続します。プログラム内の mysql
そして、この非対話型タイムアウトは、接続プール内のアイドル接続のアイドル時間が wait_timeout 設定を超えた場合に発生します。このとき、プログラムがアイドル状態の接続を取得してクエリを実行すると、無効な接続という元の問題が発生します。
基本原則を理解した後、無効な接続に対する解決策は非常に簡単です:
1. データベースの wait_timeout 時間を延長します。
2. プログラムは定期的にこれらの失敗した接続をチェックし、適時に破棄しますが、ここでのプログラムのチェック時間は、mysql によって設定された wait_timeout 値よりも短い必要があることに注意してください。
上記は接続プールに関する私の理解です。間違いがあればご指摘ください。ありがとうございます~
以上がgolang mysql データベース接続プールを理解します。の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

ホットAIツール

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

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

Undress AI Tool
脱衣画像を無料で

Clothoff.io
AI衣類リムーバー

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

人気の記事

ホットツール

メモ帳++7.3.1
使いやすく無料のコードエディター

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

ゼンドスタジオ 13.0.1
強力な PHP 統合開発環境

ドリームウィーバー CS6
ビジュアル Web 開発ツール

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

ホットトピック









Go データベース接続の接続プーリングを構成するにはどうすればよいですか?データベース接続を作成するには、database/sql パッケージの DB タイプを使用します。同時接続の最大数を制御するには、MaxOpenConns を設定します。アイドル状態の接続の最大数を設定するには、ConnMaxLifetime を設定します。

Go では、関数のライフ サイクルには定義、ロード、リンク、初期化、呼び出し、戻り値が含まれます。変数のスコープは関数レベルとブロック レベルに分割されますが、ブロック内の変数はブロック内でのみ表示されます。 。

Go では、正規表現を使用してタイムスタンプを照合できます。ISO8601 タイムスタンプの照合に使用されるような正規表現文字列をコンパイルします。 ^\d{4}-\d{2}-\d{2}T \d{ 2}:\d{2}:\d{2}(\.\d+)?(Z|[+-][0-9]{2}:[0-9]{2})$ 。 regexp.MatchString 関数を使用して、文字列が正規表現と一致するかどうかを確認します。

Go では、gorilla/websocket パッケージを使用して WebSocket メッセージを送信できます。具体的な手順: WebSocket 接続を確立します。テキスト メッセージを送信します。 WriteMessage(websocket.TextMessage,[]byte("message")) を呼び出します。バイナリ メッセージを送信します。WriteMessage(websocket.BinaryMessage,[]byte{1,2,3}) を呼び出します。

Go と Go 言語は、異なる特性を持つ別個の存在です。 Go (Golang とも呼ばれます) は、同時実行性、高速なコンパイル速度、メモリ管理、およびクロスプラットフォームの利点で知られています。 Go 言語の欠点としては、他の言語に比べてエコシステムが充実していないこと、構文が厳格であること、動的型付けが欠如していることが挙げられます。

メモリ リークは、ファイル、ネットワーク接続、データベース接続などの使用されなくなったリソースを閉じることによって、Go プログラムのメモリを継続的に増加させる可能性があります。弱参照を使用してメモリ リークを防ぎ、強参照されなくなったオブジェクトをガベージ コレクションの対象にします。 go coroutine を使用すると、メモリ リークを避けるために、終了時にコルーチンのスタック メモリが自動的に解放されます。

Golang では、エラー ラッパーを使用して、元のエラーにコンテキスト情報を追加することで新しいエラーを作成できます。これを使用すると、さまざまなライブラリまたはコンポーネントによってスローされるエラーの種類を統一し、デバッグとエラー処理を簡素化できます。手順は次のとおりです。errors.Wrap 関数を使用して、元のエラーを新しいエラーにラップします。新しいエラーには、元のエラーのコンテキスト情報が含まれています。 fmt.Printf を使用してラップされたエラーを出力し、より多くのコンテキストとアクション性を提供します。異なる種類のエラーを処理する場合は、errors.Wrap 関数を使用してエラーの種類を統一します。

並行関数の単体テストは、同時環境での正しい動作を確認するのに役立つため、非常に重要です。同時実行機能をテストするときは、相互排他、同期、分離などの基本原則を考慮する必要があります。並行機能は、シミュレーション、競合状態のテスト、および結果の検証によって単体テストできます。
