PHP および MySQL でのキュー メッセージの永続化とメッセージの重複排除のアプリケーション シナリオ

PHP および MySQL でのキュー メッセージの永続化とメッセージの重複排除のアプリケーション シナリオ

キューは、ソフトウェア開発で広く使用されている一般的なデータ構造であり、非同期メッセージ処理に適用されます。タスクのスケジュール設定、ログ収集、その他のシナリオ。そのうち、メッセージの永続性とメッセージの重複排除はキューの 2 つの重要な機能であり、メッセージの信頼性とデータの一貫性を確保できます。 PHP および MySQL では、キュー アプリケーションはメッセージ ミドルウェアとして Redis を使用し、キューのメタデータを保存および管理するために MySQL を使用できます。具体的な例は次のとおりです。

まず、キュー操作をサポートするように Redis と MySQL をインストールして構成する必要があります。 Redis と MySQL のインストールと構成が完了し、Redis と MySQL 拡張機能が PHP にインストールされていることを前提としています。

以下は、PHP と Redis を使用してキューを実装するコード例です。

<?php

// 链接Redis
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 将消息插入队列
$redis->rpush('queue', 'message1');
$redis->rpush('queue', 'message2');
$redis->rpush('queue', 'message3');

// 从队列中读取消息
$message = $redis->lpop('queue');
while ($message) {
    echo $message . PHP_EOL;
    $message = $redis->lpop('queue');
}
?>

上記のコードでは、Redis の rpush メソッドを使用してメッセージをメッセージの末尾に挿入します。 lpop メソッドを使用してキューからメッセージを削除します。キューの先頭にあるメッセージを読み取り、キューが空になるまでループを読み取ります。

次に、MySQL を使用してメッセージの永続化と重複排除を実現する必要があります。まず、メッセージ ID や処理ステータスなどのフィールドを含む、メッセージのメタデータを保存するテーブルを作成します。

CREATE TABLE `queue` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `message` varchar(255) DEFAULT NULL,
  `status` tinyint(1) DEFAULT '0',
  PRIMARY KEY (`id`),
  UNIQUE KEY `message` (`message`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

次に、メッセージを MySQL に永続化する PHP コードを記述し、挿入前に重複排除の判定を実行して、同じメッセージが繰り返し挿入されるのを防ぎます。

<?php

// 链接MySQL
$mysqli = new mysqli('localhost', 'root', 'password', 'database');

// 将消息插入队列
$message = 'message1';
$exists = $mysqli->query("SELECT * FROM queue WHERE message = '$message'");
if ($exists->num_rows == 0) {
    $mysqli->query("INSERT INTO queue (message) VALUES ('$message')");
}

// 从队列中读取消息
$result = $mysqli->query("SELECT * FROM queue WHERE status = 0");
while ($row = $result->fetch_assoc()) {
    echo $row['message'] . PHP_EOL;
    
    // 标记消息为已处理
    $id = $row['id'];
    $mysqli->query("UPDATE queue SET status = 1 WHERE id = $id");
}

// 关闭连接
$mysqli->close();
?>

上記のコードでは、mysqli 拡張機能を使用して MySQL データベースに接続し、クエリを通じてメッセージがキューにすでに存在するかどうかを判断します。存在しない場合、メッセージはキューに挿入されます。メッセージを読み取るときは、未処理のメッセージをクエリし、ループを通じて各メッセージを読み取り、そのステータスを処理済みとしてマークします。

要約すると、キュー メッセージの永続化とメッセージの重複排除は、開発において一般的に使用されるテクノロジであり、メッセージの信頼性とデータの一貫性を確保できます。この記事では、PHP と Redis を使用してキューを実装し、それらを MySQL と組み合わせてメッセージの永続化と重複排除を実現するコード例を紹介します。この記事がキューの適用シナリオと実装方法を理解するのに役立つことを願っています。

以上がPHP および MySQL でのキュー メッセージの永続化とメッセージの重複排除のアプリケーション シナリオの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。