PHPとデータベースキューの統合

最新の Web アプリケーションの開発に伴い、Web サイトのパフォーマンスとユーザー エクスペリエンスを向上させるために、非同期で処理する必要のあるタスクがますます増えています。一般的な方法の 1 つは、キュー システムを使用して、処理する必要のあるタスクをキューに入れ、バックグラウンド プロセスによって非同期に処理することです。 PHP とデータベースはどちらも Web 開発で広く使用されているツールであるため、これらを併用すると、シンプルで保守が容易なキュー システムを実現できます。

この記事では、PHP とデータベースを使用して、キューにタスクを追加する方法、タスクを非同期で処理する方法、タスクの信頼性を確保する方法など、簡単なキュー システムを実装する方法を紹介します。

1. データベース キューの基本原理

データベース キューの基本原理は、データベース内にタスク リストを作成し、データベースのトランザクション メカニズムを使用してタスクの安定性を確保することです。同時アクセス。タスクを追加する必要がある場合、まずタスク情報がタスク リストに挿入され、データベース トランザクションが開始されます。トランザクションでは、まずタスク リストに処理中のタスクがあるかどうかを問い合わせ、ない場合はキューの最初のタスクが現在のタスクとして処理されます。処理中のタスクがある場合は、トランザクションをコミットし、次のポーリング サイクルを待ちます。

2. タスク テーブルの作成

まず、タスク ID、タスク タイプ、タスク パラメーター、タスク ステータスなどのフィールドを含むタスク テーブルを作成する必要があります。このうち、タスクのステータスは、処理待ち、処理中、処理済み、失敗などがあります。サンプル コードは次のとおりです。

CREATE TABLE queue (
id int(11) NOT NULL AUTO_INCREMENT,
type varchar( 50) NOT NULL,
params text NOT NULL,
status tinyint(4) NOT NULL DEFAULT '0',
created_at datetime NOT NULL DEFAULT CURRENT_TIMESTAMP,
updated_at datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
主キー (id),
KEY status (status)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;

3. タスクをキューに追加します

次を使用できます。次のコードを使用してタスクをキューに追加します キューに追加します:

<?php
function addToQueue($type, $params) {
    $dbh = new PDO('mysql:host=localhost;dbname=dbname', 'username', 'password');
    $sql = "INSERT INTO `queue` (`type`, `params`, `status`) VALUES (:type, :params, 0)";
    $stmt = $dbh->prepare($sql);
    $stmt->bindParam(':type', $type, PDO::PARAM_STR);
    $stmt->bindParam(':params', $params, PDO::PARAM_STR);
    $stmt->execute();
}

4. キュー内のタスクを処理します

別のスクリプトでは、キュー内のタスクを定期的にポーリングする必要があります。処理待ちのタスクを処理します。

<?php
function processQueue() {
    $dbh = new PDO('mysql:host=localhost;dbname=dbname', 'username', 'password');
    $dbh->beginTransaction();

    // 查询是否正在处理任务
    $sql = "SELECT * FROM `queue` WHERE `status` = 1 FOR UPDATE";
    $stmt = $dbh->prepare($sql);
    $stmt->execute();
    $currentTask = $stmt->fetch(PDO::FETCH_ASSOC);

    if (!$currentTask) {
        // 如果没有正在处理的任务，从队列中取出第一个任务
        $sql = "SELECT * FROM `queue` WHERE `status` = 0 ORDER BY `id` ASC LIMIT 1 FOR UPDATE";
        $stmt = $dbh->prepare($sql);
        $stmt->execute();
        $currentTask = $stmt->fetch(PDO::FETCH_ASSOC);
        if ($currentTask) {
            // 标记任务为正在处理
            $sql = "UPDATE `queue` SET `status` = 1 WHERE `id` = :id";
            $stmt = $dbh->prepare($sql);
            $stmt->bindParam(':id', $currentTask['id'], PDO::PARAM_INT);
            $stmt->execute();
        }
    }

    if ($currentTask) {
        // 处理当前任务
        try {
            if ($currentTask['type'] == 'example') {
                // 异步处理任务
                // ...
                // 标记任务为已完成
                $sql = "UPDATE `queue` SET `status` = 2 WHERE `id` = :id";
                $stmt = $dbh->prepare($sql);
                $stmt->bindParam(':id', $currentTask['id'], PDO::PARAM_INT);
                $stmt->execute();
            }
        } catch(Exception $e) {
            // 标记任务为失败
            $sql = "UPDATE `queue` SET `status` = 3 WHERE `id` = :id";
            $stmt = $dbh->prepare($sql);
            $stmt->bindParam(':id', $currentTask['id'], PDO::PARAM_INT);
            $stmt->execute();
        }
    }

    $dbh->commit();
}

5. タスクの信頼性を確保する

タスクの信頼性を確保するために、トランザクションを使用してタスクを処理し、タスクのステータス更新操作をタスクと組み合わせることができます。タスク処理が失敗した場合、トランザクションがロールバックされて不完全なタスク処理が回避されることを保証するためのトランザクション内のビジネス操作。

6. 結論

PHP とデータベースを使用してキュー システムを実装することは、Web アプリケーションのパフォーマンスとユーザー エクスペリエンスを効果的に向上させることができるシンプルで信頼性の高い方法です。 PHP とデータベースはどちらも広く使用されているツールであるため、簡単に併用して非同期タスク処理を実装できます。ただし、実際のアプリケーションでは、Redis キュー、メッセージ キューなど、他にも多くの高度なキュー テクノロジを使用できます。開発者は、特定のニーズに基づいて、適切なキュー ソリューションを選択できます。

以上がPHPとデータベースキューの統合の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。