Node.jsプログラムでMySQL接続を再接続するにはどうすればよいですか?

Node.js プログラムで MySQL 接続を再接続するにはどうすればよいですか?

MySQL は人気のあるリレーショナル データベースであり、Node.js は非常に人気のあるサーバーサイド プログラミング言語です。 Node.js プログラムで MySQL データベースに接続すると、データの操作、保存、取得が可能になります。ただし、さまざまな理由で MySQL 接続が切断される場合があるため、プログラムの安定性と信頼性を確保するために、プログラムに再接続メカニズムを実装する必要があります。この記事では、Node.jsプログラムでMySQLの接続再接続を実装する方法を紹介します。

1. MySQL モジュールのインストール

始める前に、Node.js プロジェクトに MySQL モジュールをインストールする必要があります。 npm コマンドを使用してインストールできます。

npm install mysql

2. MySQL 接続の作成

Node.js プログラムでは、MySQL モジュールを使用して接続を作成する必要があります。データベースに。次のコードを使用して MySQL 接続を作成できます:

const mysql = require('mysql');

const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'mydatabase'
});

connection.connect(function(err) {
  if (err) {
    console.error('Error connecting to MySQL database: ' + err.stack);
    return;
  }

  console.log('Connected to MySQL database as ID: ' + connection.threadId);
});

上記のコードでは、ホスト アドレス、ユーザー名、パスワード、データベースなどのデータベース関連情報を含む接続構成オブジェクトを渡します。名前。 connect メソッドを呼び出すことで、データベースへの接続を作成できます。接続が失敗した場合はエラー メッセージが出力され、接続が成功した場合は接続のスレッド ID が出力されます。

3. MySQL 接続エラーの監視

再接続メカニズムを実装するには、MySQL 接続エラーを監視する必要があります。接続エラーが発生した場合は再接続操作を行います。接続エラーは次のコードで監視できます:

connection.on('error', function(err) {
  console.error('MySQL connection error: ' + err.stack);

  // 重连
  connection.connect(function(err) {
    if (err) {
      console.error('Error reconnecting to MySQL database: ' + err.stack);
      return;
    }

    console.log('Reconnected to MySQL database as ID: ' + connection.threadId);
  });
});

上記のコードでは、connection.on メソッドを使用して error イベントをバインドします。エラーが発生した場合、コールバック関数が実行されます。コールバック関数では、エラー情報のスタックを出力し、connect メソッドを再度呼び出してデータベースへの再接続を試みることができます。

4. 再接続戦略の作成

実際のアプリケーションでは、単純に無制限に再接続を実行すると、接続試行が多すぎて、データベースやサーバーに悪影響を与える可能性があります。したがって、合理的な再接続戦略を実装する必要があります。次のコードは、接続が成功するまで時々再接続する単純な再接続戦略の例を示しています。

function reconnect() {
  // 尝试重新连接
  connection.connect(function(err) {
    if (err) {
      console.error('Error reconnecting to MySQL database: ' + err.stack);
      setTimeout(reconnect, 2000); // 2秒后再次尝试重连
      return;
    }

    console.log('Reconnected to MySQL database as ID: ' + connection.threadId);
  });
}

// 失败后尝试连接
connection.on('error', function(err) {
  console.error('MySQL connection error: ' + err.stack);
  reconnect();
});

上記のコードでは、reconnect という名前のメソッドを定義します。関数内の再接続操作。接続が失敗した場合は、エラー メッセージが出力され、2 秒後に接続が再試行されます。同時に、接続でエラーが発生したときに再接続するために、エラー イベントを reconnect 関数にバインドします。

5. 接続の開始

すべての準備が整ったら、適切なタイミングで MySQL 接続を開始するだけです。これは通常、プログラムの起動時、またはデータベースにアクセスする必要がある場合に発生します。接続は、次のコードを通じて開始できます。

connection.connect(function(err) {
  if (err) {
    console.error('Error connecting to MySQL database: ' + err.stack);
    return;
  }

  console.log('Connected to MySQL database as ID: ' + connection.threadId);
});

上記のコードでは、単に connect メソッドを呼び出して接続を確立しました。接続が失敗した場合はエラー メッセージが出力され、接続が成功した場合は接続のスレッド ID が出力されます。

概要:

再接続は、Node.js プログラムと MySQL データベース間の安定した信頼性の高い接続を確保するための非常に重要なメカニズムです。接続エラーをリッスンし、合理的な再接続戦略を実装することで、接続が切断されたときに、プログラムのクラッシュやデータ損失を回避するために時間内に再接続できることを保証できます。この記事が、Node.js プログラムで MySQL 接続の再接続を実装するのに役立つことを願っています。

以上がNode.jsプログラムでMySQL接続を再接続するにはどうすればよいですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。