PHPとRedisを利用したリアルタイム通知機能：ユーザーメッセージの扱い方-Redis-php.cn

PHPとRedisを利用したリアルタイム通知機能：ユーザーメッセージの扱い方

WBOY

リリース： 2023-07-30 15:21:23

オリジナル

1391 人が閲覧しました

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

はじめに:
現代のインターネットアプリケーションでは、リアルタイム通知機能が非常に重要な要件になっています。ソーシャルメディアアプリ、インスタントチャットアプリ、オンラインショッピングアプリのいずれであっても、ユーザーはメッセージの通知を即座に受け取りたいと考えています。この記事では、PHP と Redis を使用して、ユーザーのインスタントメッセージプッシュのニーズを満たす簡単なリアルタイム通知機能を実装します。開始する前に、PHP と Redis が開発環境にインストールされていることを確認してください。

1. 概要
リアルタイム通知機能は、パブリッシュ/サブスクライブ (pub/sub) モデルに基づいて実装されます。ユーザーがメッセージを送信すると、PHP プログラムはメッセージの内容を Redis に保存し、Redis の公開機能を通じてそのメッセージタイプを購読しているすべてのユーザーにメッセージをプッシュします。購読ユーザーはリアルタイムで通知を受け取り、フロントエンドページに関連メッセージを表示できます。

2. 準備

Redis のインストール
Redis 公式 Web サイトが提供するインストールチュートリアルを参照して、Redis のインストールを完了し、Redis サービスを開始してください。
PHP は Redis に接続します
PHP を使用して Redis に接続するのは非常に簡単です。まず、PHP コードに Redis 拡張機能を導入する必要があります。次に、Redis クラスのインスタンス化されたオブジェクトを介して Redis サーバーに接続します。以下はサンプルコードです:

<?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379); // 连接Redis服务器
$redis->select(0); // 选择Redis数据库
?>

ログイン後にコピー

3. メッセージの発行とサブスクリプション

メッセージの発行
ユーザーがメッセージを送信すると、PHP プログラムは次の場所に保存します。 Redis とすべてのサブスクライバーにプッシュします。以下にサンプルコードを示します。

<?php
function publishMessage($messageType, $messageContent) {
    global $redis;
    $message = array('type' => $messageType, 'content' => $messageContent);
    $redis->publish('notifications', json_encode($message));
}
?>

ログイン後にコピー

上記のサンプルコードでは、メッセージを公開するためのpublishMessage 関数をカプセル化します。この関数は、メッセージタイプとメッセージコンテンツの 2 つのパラメータを受け入れます。まず、メッセージタイプとメッセージコンテンツを配列に保存し、次に Redis のパブリッシュ機能を使用してメッセージを JSON 形式でシリアル化し、「notifications」という名前のチャネルにプッシュします。

メッセージの購読
ユーザーは、さまざまな種類のメッセージを購読することを選択できます。ユーザーごとに個別のサブスクリプションチャネルを作成する必要があり、サブスクリプションが成功したら、メッセージをリアルタイムでユーザーにプッシュします。以下はサンプルコードです:

<?php
function subscribeChannel($channel, $callback) {
    global $redis;
    
    $redis->subscribe(array($channel), function ($redis, $channel, $message) use ($callback) {
        $callback($message); // 执行回调函数，处理收到的消息
    });
}
?>

ログイン後にコピー

上記のサンプルコードでは、指定されたチャネルからのメッセージをサブスクライブするための submitChannel 関数をカプセル化します。この関数は、チャネル名とメッセージ処理用のコールバック関数の 2 つのパラメータを受け入れます。 Redis の submit 関数を使用して、指定されたチャネルにサブスクライブし、コールバック関数を通じて受信したメッセージを処理します。

4. メッセージ処理とフロントエンド表示
ユーザーが指定された種類のメッセージを購読すると、新しいメッセージがリリースされるとリアルタイムでユーザーにプッシュされます。それに応じてメッセージを作成し、ページのフロントエンドに表示します。以下はサンプルコードです:

<!DOCTYPE html>
<html>
<head>
    <title>实时通知</title>
    <script src="https://cdn.jsdelivr.net/npm/vue/dist/vue.js"></script>
</head>
<body>
    <div id="app">
        <h1>消息通知</h1>
        <ul>
            <li v-for="message in messages">{{ message.content }}</li>
        </ul>
    </div>

    <script>
    var app = new Vue({
        el: '#app',
        data: {
            messages: []
        },
        mounted: function() {
            var self = this;
            
            // 订阅消息
            subscribeChannel('notifications', function(message) {
                self.messages.push(JSON.parse(message));
            });
        }
    });

    // 消息订阅函数
    function subscribeChannel(channel, callback) {
        var socket = new WebSocket('ws://localhost:8080/' + channel);

        socket.onmessage = function(event) {
            callback(event.data);
        };

        // 可选：在WebSocket关闭时重新连接
        socket.onclose = function(event) {
            setTimeout(function() {
                subscribeChannel(channel, callback);
            }, 1000);
        };
    }
    </script>
</body>
</html>

ログイン後にコピー

上記のサンプルコードでは、Vue.js を使用してフロントエンドページをレンダリングし、WebSocket を介してバックエンドとの永続的な接続を確立します。ページが読み込まれた後、subscribeChannel 関数を呼び出して、「notifications」という名前のチャネルを購読します。新しいメッセージが到着すると、WebSocket経由でメッセージを受信してコールバック関数を実行し、Vueコンポーネントのメッセージリストにメッセージ内容を追加することでリアルタイム通知の表示を実現します。

5. 概要
上記の手順により、PHP と Redis を使用してリアルタイム通知機能を実装するサンプルアプリケーションを正常に実装できました。メッセージを公開すると、ユーザーはこのタイプのメッセージを購読しているすべてのユーザーにメッセージをリアルタイムでプッシュできます。このようにして、リアルタイム通知に対するユーザーの要求を満たすことができます。もちろん、これは単なる例であり、実際のアプリケーションではより複雑なビジネスロジックやセキュリティメカニズムが必要になる場合がありますが、基本的な実装の考え方は同様です。

この記事がリアルタイム通知機能の実装に役立つと幸いです。

以上がPHPとRedisを利用したリアルタイム通知機能：ユーザーメッセージの扱い方の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。