refirio.org

エントリー

タグ「MySQL」の検索結果は以下のとおりです。

Webアプリケーションへの同時アクセス対策メモ

2015/05/10 19:04
カテゴリー：制作, プログラム, データベース, サーバー
タグ：PHP, MySQL

Webアプリケーションへの同時アクセス対策メモ

XAMPPの Apache Bench で同時アクセスを再現するメモ。テストした環境はWindows7。Apache Bench の使い方は以下を参考に。

Apache Benchを使った負荷テストのやり方

XAMPPをCドライブ直下にインストールした場合、以下の手順で Apache Bench を使える。

> cd C:\xampp\apache\bin
> ab -n 15 -c 15 http://localhost/~test/ab/

「-n 15 -c 15」で「15人が同時にアクセスする（合計15回アクセス）」状況がテストできる。（「-n 15 -c 1」なら「1人が合計15回アクセスする」状況になるので、同時アクセスにはならない。）

以下で同時アクセスのテストとその対策を行う。

ファイルを使った例

<?php

/*
 * No.2をカウントアップ（最大値100）
 */

if ($fp = fopen('logs/count.log', 'r+')) {
  $data = '';
  while ($line = fgets($fp)) {
    list($id, $count) = explode("\t", rtrim($line));

    if ($id == 2) {
      if ($count < 100) {
        $data .= "$id\t" . ++$count . "\n";
      } else {
        exit('Limit');
      }
    } else {
      $data .= $line;
    }
  }

  rewind($fp);
  fwrite($fp, $data);
  ftruncate($fp, ftell($fp));

  fclose($fp);
} else {
  exit('Error');
}

exit('Complete');

logs/count.log の内容は以下のとおり。

これで上のPHPプログラムにアクセスすると、2の行が1カウントアップされる。何度もリロードすると、その回数だけカウントアップされる。

> ab -n 30 -c 30 http://localhost/~test/ab/count.php

30人の同時アクセスを発生させてみると、正しくカウントできないのが確認できる。

<?php

/*
 * No.2をカウントアップ（最大値100）
 */

if ($fp = fopen('logs/count.log', 'r+')) {
  flock($fp, LOCK_EX);  //ファイルロック

  $data = '';
  while ($line = fgets($fp)) {
    list($id, $count) = explode("\t", rtrim($line));

    if ($id == 2) {
      if ($count < 100) {
        $data .= "$id\t" . ++$count . "\n";
      } else {
        exit('Limit');
      }
    } else {
      $data .= $line;
    }
  }

  rewind($fp);
  fwrite($fp, $data);
  ftruncate($fp, ftell($fp));

  fclose($fp);
} else {
  exit('Error');
}

exit('Complete');

ファイルロックを行えば、正しくカウントされるようになる。

データベースを使った例

<?php

/*
 * No.2をカウントアップ（最大値100）
 */

try {
  $pdo = new PDO('mysql:dbname=test;host=localhost', 'root', '1234', array(PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION));
  $pdo->query('SET NAMES utf8');

  $stmt = $pdo->prepare('SELECT count FROM count_test WHERE id = :id');
  $stmt->bindValue(':id', 2, PDO::PARAM_INT);
  $stmt->execute();

  $data = $stmt->fetch(PDO::FETCH_ASSOC);

  if ($data['count'] < 100) {
    $stmt = $pdo->prepare('UPDATE count_test SET count = count + 1 WHERE id = :id');
    $stmt->bindValue(':id', 2, PDO::PARAM_INT);
    $stmt->execute();
  }
} catch (PDOException $e) {
  exit($e->getMessage());
}

exit('Complete');

count_test の定義は以下のとおり。

CREATE TABLE count_test(
  id    INT UNSIGNED NOT NULL,
  count INT UNSIGNED,
  PRIMARY KEY(id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

これで上のPHPプログラムにアクセスすると、2の行が1カウントアップされる。何度もリロードすると、その回数だけカウントアップされる。

ab -n 200 -c 200 http://localhost/~test/ab/count.php

200人の同時アクセスを発生させてみると、正しくカウントできないのが確認できる。

<?php

/*
 * No.2をカウントアップ（最大値100）
 */

try {
  $pdo = new PDO('mysql:dbname=test;host=localhost', 'root', '1234', array(PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION));
  $pdo->query('SET NAMES utf8');

  $pdo->beginTransaction();  //トランザクション開始

  $stmt = $pdo->prepare('SELECT count FROM count_test WHERE id = :id FOR UPDATE');  //行ロック
  $stmt->bindValue(':id', 2, PDO::PARAM_INT);
  $stmt->execute();

  $data = $stmt->fetch(PDO::FETCH_ASSOC);

  if ($data['count'] < 100) {
    $stmt = $pdo->prepare('UPDATE count_test SET count = count + 1 WHERE id = :id');
    $stmt->bindValue(':id', 2, PDO::PARAM_INT);
    $stmt->execute();
  }

  $pdo->commit();  //コミット
} catch (PDOException $e) {
  $pdo->rollBack();  //ロールバック

  exit($e->getMessage());
}

exit('Complete');

トランザクションと行ロックを行えば、正しくカウントされるようになる。

この記事のURL

MySQLのテーブル仕様変更メモ

2009/03/14 20:37
カテゴリー：制作, データベース
タグ：MySQL

個人的にはテーブルの仕様変更コマンドはほとんど使わないのですが、たまにどうしても必要になることがあります。
そして先日、既存のテーブルに手を加える必要が出ました…。これまでその都度調べていたけど、自分が使いそうなものだけメモしておきます。

#「番号」「氏名」「電話番号」を格納できるテーブルを作成
CREATE TABLE address(
  no   INT         NOT NULL,
  name VARCHAR(80) NOT NULL,
  tel  VARCHAR(80) NOT NULL
);

#「読み仮名」を格納する列を追加
ALTER TABLE address ADD kana VARCHAR(80) NOT NULL; #末尾に追加
ALTER TABLE address ADD kana VARCHAR(80) NOT NULL FIRST; #先頭に追加
ALTER TABLE address ADD kana VARCHAR(80) NOT NULL AFTER name; #「名前」の直後に追加

#「年齢」を格納する列を追加
ALTER TABLE address ADD age INT NOT NULL; #末尾に追加
ALTER TABLE address ADD age INT NOT NULL FIRST; #先頭に追加
ALTER TABLE address ADD age INT NOT NULL AFTER name; #「名前」の直後に追加

#「読み仮名」を格納する列を削除
ALTER TABLE address DROP kana;

#「年齢」を格納する列をVARCHAR型に変更
ALTER TABLE address CHANGE age age VARCHAR(80) NOT NULL;

#「年齢」を格納する列の名前を変更
ALTER TABLE address CHANGE age toshi INT NOT NULL;

もちろん、データベース管理ツールを使うのも有効です。