日本語
日本語
インターネット システムの規模が拡大し続けるにつれて、バックグラウンド サービスは同時に多数のメッセージ タスクを処理する必要があります。システムのブロッキングを回避し、同時実行パフォーマンスを向上させるために、キュー メカニズムを導入することが一般的なソリューションになっています。 PHP とメッセージキューテクノロジーを組み合わせることで、タスクの非同期かつ効率的な処理を容易に実現でき、システムの安定性と応答速度が大幅に向上します。
現在、PHP エコシステムでは、Beanstalkd、Redis Queue、RabbitMQ など、さまざまな成熟したキュー システムが利用可能です。その中でも、Beanstalkd は、軽量で効率的かつ簡単に導入できるという特徴により、中小規模のプロジェクトでよく使用されます。この記事では、Beanstalkd と Pheanstalk ライブラリを組み合わせた例を使用して、具体的な実装手順を説明します。
Beanstalkd をサーバーにインストールした後、サービスを開始すると利用可能になります。
sudo apt-get Beanstalkd をインストールする sudoサービスBeanstalkdの始める
正常に起動すると、Beanstalkd はデフォルトでポート 127.0.0.1:11300 をリッスンします。
プロジェクトのルート ディレクトリにcomposer.jsonファイルを作成し、次のコンテンツを追加します。
{
"必要とする"： {
"pda/鶏の茎": "^3.1"
}
}次に、次のコマンドを実行して依存関係をインストールします。
コンポーザーのインストール
インストールしたら、次のサンプル コードを使用して Beanstalkd に接続できます。
require_once 'vendor/autoload.php'; Pheanstalk\Pheanstalk を使用します。 $pheanstalk = Pheanstalk::create('127.0.0.1');
この時点で、PHP プログラムはキュー サービスに正常に接続しました。
非同期で処理する必要があるタスクは、JSON 形式でキューにプッシュできます。
$data = [
'メッセージ' => 'こんにちは、世界!'
];
$pheanstalk->useTube('my-tube')->put(json_encode($data));この例では、メッセージの内容を含む JSON 文字列をmy-tubeという名前のキューにプッシュします。
コンシューマは、キューからメッセージを削除し、対応するロジックを実行する責任があります。例は次のとおりです。
require_once 'vendor/autoload.php';
Pheanstalk\Pheanstalk を使用します。
$pheanstalk = Pheanstalk::create('127.0.0.1');
while (true) {
$job = $pheanstalk->watch('my-tube')->reserve();
$data = json_decode($job->getData(), true);
// メッセージ データを処理します echo $data['message'] 。 "\n";
// 処理されたメッセージを削除 $pheanstalk->delete($job);
}このスクリプトは指定されたキューの監視を継続し、新しいタスクが発生するとすぐに実行され、キュー内のメッセージが繰り返し消費されないように処理されたメッセージを削除します。
PHP を Beanstalkd キュー システムと組み合わせて使用すると、メッセージ処理の効率とシステムの応答速度が大幅に向上します。 Pheanstalk ライブラリのシンプルなカプセル化により、開発者はタスクの非同期化、メッセージ配布、バックグラウンド処理を迅速に実装でき、それによって全体的なアーキテクチャのパフォーマンスを最適化できます。ログ収集、電子メール送信、注文処理、データ同期のいずれであっても、キュー メカニズムはプロジェクトに高い信頼性と拡張性をもたらします。
