PHP および MySQL でキューのメッセージ保証とメッセージ永続性を実装する方法-PHPチュートリアル-php.cn

PHP および MySQL でキューのメッセージ保証とメッセージ永続性を実装する方法

PHP と MySQL でキューのメッセージ保証とメッセージ永続性を実装する方法

[はじめに]
インターネット時代、ユーザー数の増加に伴い, システムの複雑化に伴い、メッセージキューは重要なコンポーネントの 1 つになりました。メッセージキューはデカップリング、非同期処理、山取り・谷埋めなどの機能を実現し、システムの安定性や拡張性を向上させます。実際のアプリケーションでは、多くの場合、メッセージの信頼性と永続的な保存を考慮する必要があります。この記事では、PHP と MySQL でキューのメッセージ保証とメッセージ永続性を実装する方法を紹介します。

[メッセージキューの概念]
メッセージキューは、システム間の時間結合および空間結合の問題を解決するためによく使用される非同期通信モードです。メッセージキューは、送信者、受信者、メッセージキューの 3 つの部分で構成されます。送信者はメッセージを作成してメッセージキューに送信し、受信者はメッセージキューからメッセージを取得して消費します。メッセージキューにより、メッセージの順序性、信頼性、耐久性のあるストレージが保証されます。

[メッセージ保証の実装]
メッセージ保証とは、主にメッセージの紛失や重複配信を防ぐためのメッセージ配信プロセスにおける信頼性の保証を指します。

トランザクションモード
PHP では、データベーストランザクションを使用して、メッセージの信頼性の高い配信を実現できます。メッセージを送信すると、メッセージがデータベースに挿入され、データベーストランザクションが開始されます。メッセージ受信後、確認処理完了後にトランザクションを送信します。受信に失敗した場合、トランザクションはロールバックされ、メッセージはメッセージキューに再度入ります。

サンプルコードは次のとおりです。

beginTransaction(); $stmt = $pdo->prepare("INSERT INTO message_queue(content) VALUES(:content)"); $content = "Hello, Message Queue!"; $stmt->bindParam(':content', $content); $stmt->execute(); $pdo->commit(); // 接收消息 $pdo->beginTransaction(); $stmt = $pdo->prepare("SELECT * FROM message_queue LIMIT 1"); $stmt->execute(); $message = $stmt->fetch(PDO::FETCH_ASSOC); echo $message['content']; $stmt = $pdo->prepare("DELETE FROM message_queue WHERE id=:id"); $stmt->bindParam(':id', $message['id']); $stmt->execute(); $pdo->commit(); ?>

ログイン後にコピー

メッセージ確認メカニズム
メッセージ確認メカニズムとは、受信者がメッセージを処理した後、確認メッセージを送信することを意味します。メッセージキューに送信して、メッセージが正常に処理されたことを通知します。メッセージ処理が失敗した場合は、確認メッセージを送信しないことを選択できます。メッセージはメッセージキューに再配信されます。

サンプルコードは次のとおりです。

setName('test_queue'); $queue->setFlags(AMQP_DURABLE); $queue->declare(); $queue->publish($message, '', AMQP_DURABLE); // 接收消息 $channel = new AMQPChannel(new AMQPConnection()); $queue = new AMQPQueue($channel); $queue->setName('test_queue'); $queue->setFlags(AMQP_DURABLE); $queue->declare(); $message = $queue->get(); if ($message !== false) { echo $message->getBody(); $queue->ack($message->getDeliveryTag()); } ?>

ログイン後にコピー

[メッセージ永続性の実装]
メッセージ永続性とは、送信時またはメッセージキューに格納されるときのメッセージの信頼性を指します。性的保証。

データベースストレージ
メッセージを MySQL データベースに保存し、データベースの永続化機能を使用してメッセージの信頼性を確保します。データベーステーブルを使用してメッセージキューを表し、メッセージのステータスと内容を記録できます。

サンプルコードは次のとおりです。

prepare("INSERT INTO message_queue(content, status) VALUES(:content, :status)"); $content = "Hello, Message Queue!"; $status = 0; // 0：未处理，1：已处理 $stmt->bindParam(':content', $content); $stmt->bindParam(':status', $status); $stmt->execute(); // 接收消息 $pdo = new PDO("mysql:host=127.0.0.1;dbname=test", "username", "password"); $stmt = $pdo->prepare("SELECT * FROM message_queue WHERE status=0 LIMIT 1"); $stmt->execute(); $message = $stmt->fetch(PDO::FETCH_ASSOC); echo $message['content']; $stmt = $pdo->prepare("UPDATE message_queue SET status=1 WHERE id=:id"); $stmt->bindParam(':id', $message['id']); $stmt->execute(); ?>

ログイン後にコピー

メッセージキューの永続性
メッセージキューがメッセージを保存する前に、メッセージの永続性フラグを設定し、メッセージキューを永続モードに設定すると、サービスの再起動後にメッセージが失われることがなくなります。

サンプルコードは以下のとおりです。

setName('test_queue'); $queue->setFlags(AMQP_DURABLE); $queue->declare(); $queue->publish($message, '', AMQP_DURABLE); // 接收消息 $channel = new AMQPChannel(new AMQPConnection()); $queue = new AMQPQueue($channel); $queue->setName('test_queue'); $queue->setFlags(AMQP_DURABLE); $queue->declare(); $message = $queue->get(); if ($message !== false) { echo $message->getBody(); $queue->ack($message->getDeliveryTag()); } ?>

ログイン後にコピー

[概要]
この記事では、PHP と MySQL でキューのメッセージ保証とメッセージの永続化を実装する方法を紹介します。トランザクションモードとメッセージ確認メカニズムにより、メッセージの信頼性の高い配信が保証されます。データベースストレージとメッセージキューの永続化を通じて、メッセージの永続的なストレージを実現できます。これらの方法は、開発者が安定した信頼性の高いメッセージキューシステムを構築し、システムの信頼性と拡張性を向上させるのに役立ちます。

以上がPHP および MySQL でキューのメッセージ保証とメッセージ永続性を実装する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。