メッセージ フィルタリングおよび PHP および MySQL のメッセージ ミドルウェアにおけるキュー テクノロジの応用
はじめに:
インターネットの急速な発展により、私たちのアプリケーションはもはやこれは単純な Web ページですが、多くの非同期タスクとメッセージングが含まれます。アプリケーションをより堅牢かつ効率的にするには、キューイング テクノロジーが不可欠なツールになります。この記事では、PHP および MySQL のメッセージ フィルタリングおよびメッセージ ミドルウェアにおけるキュー テクノロジのアプリケーションを紹介し、具体的なコード例を示します。
1. メッセージ フィルタリングの概念:
メッセージ フィルタリングとは、アプリケーションが条件を満たすメッセージのみを処理できるように、指定された条件に従ってメッセージを選別およびフィルタリングすることを指し、処理効率が向上します。 PHP では、MySQL データベースを使用してメッセージ フィルタリングを実装できます。
まず、保留中のメッセージを保存するためのメッセージ テーブルを MySQL データベースに作成する必要があります。メッセージ テーブルの構造は次のとおりです。
CREATE TABLE `messages` ( `id` INT(11) NOT NULL AUTO_INCREMENT, `message` VARCHAR(255) NOT NULL, `status` TINYINT(1) NOT NULL DEFAULT '0', `created_at` TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
メッセージ テーブルには次のフィールドが含まれます。
次に、保留中のメッセージをメッセージ テーブルに挿入する必要があります。次のコード例を使用できます。
<?php
// 连接数据库
$mysqli = new mysqli("localhost", "username", "password", "database");
// 插入消息
$query = "INSERT INTO messages (message) VALUES ('Message 1'), ('Message 2'), ('Message 3')";
$mysqli->query($query);
// 关闭数据库连接
$mysqli->close();
?>上記のコードは、3 つの保留中のメッセージをメッセージ テーブルに挿入します。
次に、メッセージをフィルターして処理するための PHP スクリプトを作成する必要があります。具体的なコード例は次のとおりです。
<?php
// 连接数据库
$mysqli = new mysqli("localhost", "username", "password", "database");
// 获取未处理的消息
$query = "SELECT * FROM messages WHERE status = 0";
$result = $mysqli->query($query);
// 处理消息
while ($row = $result->fetch_assoc()) {
$message = $row['message'];
// 处理消息的代码
// ...
// 标记为已处理
$query = "UPDATE messages SET status = 1 WHERE id = {$row['id']}";
$mysqli->query($query);
}
// 关闭数据库连接
$mysqli->close();
?>上記のコードは、まず未処理のメッセージを取得し、次にメッセージを 1 つずつ処理して、処理済みとしてマークします。メッセージ処理ロジックは、実際のニーズに応じて作成できます。
2. メッセージ ミドルウェアの概念:
メッセージ ミドルウェアとは、分散システムでメッセージを配信し、非同期通信を実行するために使用されるメカニズムを指します。 PHP では、サードパーティのライブラリを使用してメッセージ ミドルウェアの機能を実装できます。以下ではRabbitMQを例として紹介します。
まず、RabbitMQ PHP 拡張機能をインストールする必要があります。次のコマンドを使用してインストールできます:
$ pecl install amqp
次に、メッセージを送信するための PHP スクリプトを作成する必要があります。具体的なコード例は次のとおりです。
<?php
// 创建连接
$connection = new AMQPConnection([
'host' => 'localhost',
'port' => '5672',
'login' => 'guest',
'password' => 'guest'
]);
$connection->connect();
// 创建通道
$channel = new AMQPChannel($connection);
// 创建交换机
$exchange = new AMQPExchange($channel);
$exchange->setName('my_exchange');
$exchange->setType(AMQP_EX_TYPE_DIRECT); // 直连交换机
$exchange->declareExchange();
// 创建消息
$message = 'Hello, RabbitMQ';
// 发布消息
$exchange->publish($message, 'my_routing_key');
// 关闭连接
$connection->disconnect();
?>上記のコードでは、最初に接続を作成し、次にチャネルとスイッチを作成し、スイッチのタイプを宣言します。次に、メッセージを作成し、指定されたルーティング キーを使用して公開しました。実際のニーズに基づいて、適切なスイッチ タイプとルーティング キーを選択できます。
次に、メッセージを消費するための PHP スクリプトを作成する必要があります。具体的なコード例は次のとおりです。
<?php
// 创建连接
$connection = new AMQPConnection([
'host' => 'localhost',
'port' => '5672',
'login' => 'guest',
'password' => 'guest'
]);
$connection->connect();
// 创建通道
$channel = new AMQPChannel($connection);
// 创建交换机
$exchange = new AMQPExchange($channel);
$exchange->setName('my_exchange');
$exchange->setType(AMQP_EX_TYPE_DIRECT); // 直连交换机
$exchange->declareExchange();
// 创建队列
$queue = new AMQPQueue($channel);
$queue->setName('my_queue');
$queue->declareQueue();
$queue->bind('my_exchange', 'my_routing_key');
// 消费消息
while ($message = $queue->get()) {
$message->ack();
// 处理消息的代码
// ...
}
?>上記のコードでは、最初に接続を作成し、次にチャネルとスイッチを作成し、スイッチのタイプを宣言します。次に、キューを作成し、そのキューをスイッチにバインドしました。最後に、ループ内のキュー内のメッセージを消費し、各メッセージを処理します。
結論:
上記のコード例を通じて、PHP および MySQL のメッセージ フィルタリングとメッセージ ミドルウェアにおけるキュー テクノロジの応用がわかります。メッセージ フィルタリングは、保留中のメッセージを効率的に処理し、アプリケーションのパフォーマンスを向上させるのに役立ちます。メッセージ ミドルウェアは、分散システムでの非同期通信とメッセージ配信の実装に役立ちます。もちろん、上記のサンプル コードは単なる基礎であり、独自のニーズに応じて最適化および拡張できます。この記事がお役に立てば幸いです!
以上がPHP および MySQL のメッセージ フィルタリングおよびメッセージ ミドルウェアにおけるキュー テクノロジの応用の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。
![[Web フロントエンド] Node.js クイック スタート](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
