PHP と Redis を使用したリアルタイム ユーザー通知システムの実装: メッセージ プッシュの処理方法

PHP と Redis を使用してリアルタイム ユーザー通知システムを実装する: メッセージ プッシュを処理する方法

はじめに:
インターネットの発展に伴い、リアルタイム通知は不可欠なものの 1 つになりました。最新のアプリケーションで機能します。リアルタイム通知により、重要な情報をユーザーにタイムリーに送信できるため、ユーザー エクスペリエンスが向上し、アプリケーションの価値が高まります。この記事では、PHP と Redis を使用して、シンプルで強力なリアルタイム ユーザー通知システムを構築する方法を紹介します。

環境の準備:
リアルタイムユーザー通知機能を実装するには、まず以下の環境をインストールおよび設定する必要があります。

1. PHP 環境 (PHP 7 または上記を推奨します)
2. Redis サービス

Redis は、キャッシュ、キューイング、パブリッシュとサブスクリプションなどの機能を実装するために広く使用されている高性能インメモリ データベースです。この記事では、Redis のパブリッシュとサブスクライブ機能を使用して、メッセージ プッシュを実装します。

ステップ 1: Redis に接続する
まず、PHP を使用して Redis サービスに接続する必要があります。これは、シンプルで強力な API を提供する Redis クライアント ライブラリである PHP の Predis 拡張機能を使用して実現できます。 composer を通じて Predis ライブラリをインストールできます:

composer require predis/predis

次に、PHP スクリプトで次のコードを使用して Redis に接続します:

<?php
require 'vendor/autoload.php'; // 如果使用composer安装Predis库，需要引入autoload文件

$redis = new PredisClient([
    'scheme' => 'tcp',
    'host'   => '127.0.0.1',
    'port'   => 6379,
]);

// 测试连接是否成功
try {
    $redis->connect();
    echo "Redis连接成功！";
} catch (Exception $e) {
    echo "Redis连接失败：" . $e->getMessage();
}

## をインポートしてください。#Predis ライブラリの前に、composer が正しくインストールされ、composer install が実行されています。

ステップ 2: メッセージ プッシュ機能の実装

次に、メッセージ プッシュの実装方法を示す簡単な例を実装します。単純な Web アプリケーションを例に挙げます。ユーザーがページ上でメッセージを送信すると、そのメッセージはリアルタイムですべてのオンライン ユーザーにプッシュされます。

まず、Redis チャネルにメッセージをパブリッシュするための PHP スクリプトを作成する必要があります。

publisher.php というファイルを作成し、次のコードをファイルにコピーします。

<?php
require 'vendor/autoload.php'; // 如果使用composer安装Predis库，需要引入autoload文件

$redis = new PredisClient([
    'scheme' => 'tcp',
    'host'   => '127.0.0.1',
    'port'   => 6379,
]);

$message = $_POST['message']; // 从表单中获取用户提交的消息

$redis->publish('notification', $message); // 发布消息到Redis频道

echo "消息发布成功！";

上記のコードでは、最初に

$_POST スーパーグローバルを渡します。ユーザーがフォームを通じて送信したメッセージを、$redis->publish() メソッドを使用して、notification という名前の Redis チャネルに公開します。

次に、Redis チャネル メッセージを受信し、すべてのオンライン ユーザーにプッシュする PHP スクリプトを作成する必要があります。

subscriber.php というファイルを作成し、次のコードをファイルにコピーします。

<?php
require 'vendor/autoload.php'; // 如果使用composer安装Predis库，需要引入autoload文件

$redis = new PredisClient([
    'scheme' => 'tcp',
    'host'   => '127.0.0.1',
    'port'   => 6379,
]);

$redis->subscribe(['notification'], function ($redis, $channel, $message) {
    // 推送消息给所有在线用户
    // 你可以在这里编写自定义的推送逻辑，如使用WebSocket或长轮询等方式
    echo "收到新消息：" . $message . PHP_EOL;
});

// 注意：上述代码将阻塞进程，将一直监听Redis频道的消息，直到进程手动停止

上記のコードでは、

$redis->subscribe() を使用します。 # メソッドは、notification という名前の Redis チャネルにサブスクライブし、受信したメッセージをコールバック関数で処理します。 WebSocket やロングポーリングを使用してすべてのオンライン ユーザーにメッセージをプッシュするなど、独自のニーズに応じてコールバック関数にカスタム プッシュ ロジックを作成できます。 ステップ 3: サンプルを実行する

これで、メッセージのパブリッシュとサブスクリプションのコードが完成しました。 Web アプリケーションでフォームを作成すると、ユーザーがメッセージを送信し、

publisher.php
スクリプトを使用してメッセージを公開できるようになります。次に、subscriber.php スクリプトを使用して Redis チャネル メッセージを受信し、すべてのオンライン ユーザーにプッシュします。 コマンド ラインから

subscriber.php

スクリプトを実行し、スクリプトが存在するディレクトリに移動して次のコマンドを実行します。 <pre class='brush:php;toolbar:false;'>php subscriber.php</pre>次に、 Web アプリケーションにアクセスし、フォームに記入してメッセージを送信します。コマンド ラインに次の出力が表示されます。

收到新消息：用户提交的消息内容

これは、メッセージが Redis チャネルに正常に投稿され、

subscriber.php

スクリプトによって受信されたことを示します。 概要:

PHP と Redis を使用してリアルタイムのユーザー通知システムを構築することで、メッセージのリアルタイム プッシュ機能を簡単に実装できます。 Redis のパブリッシュおよびサブスクライブ機能を使用して、多数のメッセージ プッシュ タスクを迅速かつ効率的に処理します。実際のアプリケーションでは、WebSocket やロングポーリングなどのテクノロジを使用してユーザーとリアルタイムの双方向通信を行うなど、ニーズに応じてプッシュ ロジックをカスタマイズできます。この記事で紹介した例が、より優れたリアルタイム ユーザー通知システムの構築に役立つことを願っています。

以上がPHP と Redis を使用したリアルタイム ユーザー通知システムの実装: メッセージ プッシュの処理方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。