PHPを使用してRedisメッセージサブスクリプションを実装し、レイテンシタスクを効率的に処理する方法

M66 2025-06-13

Redisメッセージサブスクリプションを継続的に聴き、PHPの遅延タスクを処理する方法

最新のWeb開発では、遅延タスク処理は非常に一般的な要件です。効率的なインメモリデータベースとして、Redisは強力なサブスクリプション/パブリッシングメカニズムを提供し、効率的なレイテンシタスクシステムを簡単に実装できるようにします。この記事では、PHPでRedisのサブスクリプションメカニズムを使用してメッセージを継続的にリッスンし、遅延したタスクを処理する方法について詳しく説明します。

1。概要

開始する前に、いくつかの基本的な概念を理解する必要があります。

Redis：キャッシュ、キュー、遅延タスクなどのアプリケーションシナリオで一般的に使用されるメモリベースの高性能キー価値データベース。
サブスクリプション/パブリッシングメカニズム（PUB/SUB）：クライアントがチャネルを介してデータを交換できるようにするRedisのメッセージングメカニズム。
遅延タスク：通常は非同期タスクのスケジューリングに使用される指定された時間にトリガーする必要があるタスク。

2。準備

メッセージサブスクリプションにRedisの使用を開始する前に、まずPHPにRedis拡張機能がインストールされていることを確認する必要があります。次のコマンドを使用してインストールできます。

$ peclインストールredis

実装

次に、Redisのメッセージサブスクリプションを継続的に聴き、遅延したタスクを処理する方法を段階的に実装します。

1. Redisに接続します

まず、Redisサーバーに接続する必要があります。ここに接続コードがあります。

<?php
$redis = new Redis();
$redis->connect（ &#39;127.0.0.1&#39;、6379）;

2。遅延タスクを公開します

次に、Redisに遅延したタスクを公開する必要があります。タスクを投稿するためのコードは次のとおりです。

<?php
// タスクデータを定義します
$taskData = [
    'taskId' => 1、
    &#39;taskname&#39; => &#39;遅延タスクの例&#39;、
    // ...その彼のフィールド];
<p>//タスクのトリガー時間を計算しますします（今の時間から602番であると仮定）<br>
$ triggertime = time（） + 60;</p>
<p>//タスクデータをJSON形状にシリアル変化し、指定されたチャネルに公共します<br>
$ redis-> publish（ &#39;delayed-tasks&#39;、json_encode（$ taskdata））;</p>
<p>//タスクのトリガー時間をスコアとして保存し、タスクデータは注文されたコレクションの値として保存します<br>
$ redis-> zadd（ &#39;Scheduled-Tasks&#39;、$ triggertime、json_encode（$ taskdata））;<br>

3. Redisメッセージを聞き、遅延したタスクを処理します

Redisのサブスクリプションメカニズムにより、メッセージを継続的にリッスンし、メッセージが届くと遅延したタスクを処理できます。これがコードの例です。

<?php
// コールバック関数を定義します，受信したメッセージを処理するために使用されます
function handleMessage($channel, $message) {
    $taskData = json_decode($message, true); // タスクデータを分析します
    // 遅延タスクを処理します
    // ...
    echo "受信チャネル {$channel} ニュース：{$message}";
}
<p>// Redisサブスクリプションオブジェクトを作成します<br>
$ subscriber = new Redis（）;<br>
$ subscribe-> subscribe（[&#39;delayed-tasks&#39;]、 &#39;handlemessage&#39;）; //指定されたチャネルのメッセージをサブスクライブします</p>
<p>//メッセージを継続的に監視します<br>
while（$ subscriber-> pubsubloop（））{<br>
//動作しますをポジティブに実行する必要はありません、pubsubloopはメッセージが章くとコールバック関数を電話び外します<br>
}<br>

4。概要

このチュートリアルを通して、PHPでRedisのサブスクリプションメカニズムを使用して、メッセージを継続的にリッスンし、遅延したタスクを処理する方法を理解しています。 Redisの効率的なメッセージングメカニズムを使用して、信頼できる遅延タスクスケジューリングシステムを構築して、PHPアプリケーションに強力なタスク処理機能を提供できます。この記事の導入を通じて、さまざまな遅延タスクを処理するために、PHPとRedisをより適切に適用できることを願っています。