Maison > Article > base de données > Fonction de notification en temps réel via PHP et Redis : comment gérer les messages des utilisateurs

Fonction de notification en temps réel via PHP et Redis : comment gérer les messages des utilisateurs

WBOYoriginal: 2023-07-30 15:21:231405parcourir

Utiliser PHP et Redis pour implémenter la fonction de notification en temps réel : Comment traiter les messages des utilisateurs

Introduction :
Dans les applications Internet modernes, la fonction de notification en temps réel est devenue une exigence très importante. Qu'il s'agisse d'une application de réseau social, d'une application de chat instantané ou d'une application d'achat en ligne, les utilisateurs souhaitent être informés instantanément des messages. Dans cet article, nous utiliserons PHP et Redis pour implémenter une simple fonction de notification en temps réel afin de répondre aux besoins des utilisateurs en matière de transmission de messages instantanés. Avant de commencer, assurez-vous que PHP et Redis sont installés dans votre environnement de développement.

1. Présentation
Notre fonction de notification en temps réel sera implémentée sur la base du modèle de publication/abonnement (pub/sub). Lorsqu'un utilisateur envoie un message, le programme PHP stockera le contenu du message dans Redis et transmettra le message à tous les utilisateurs abonnés à ce type de message via la fonction de publication de Redis. Les utilisateurs abonnés recevront des notifications en temps réel et pourront afficher des messages pertinents sur la page frontale.

2. Préparation

Installation de Redis
Veuillez vous référer au tutoriel d'installation fourni par le site officiel de Redis pour terminer l'installation de Redis et démarrer le service Redis.
PHP se connecte à Redis
Il est très simple de se connecter à Redis en utilisant PHP. Tout d'abord, vous devez introduire l'extension Redis dans le code PHP. Ensuite, connectez-vous au serveur Redis via un objet instancié de la classe Redis. Voici un exemple de code :

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

3. Publication de messages et abonnement

Publication de messages
Lorsque l'utilisateur envoie un message, le programme PHP stocke le contenu du message dans Redis et le transmet à tous les abonnés. Voici un exemple de code :

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

Dans l'exemple de code ci-dessus, nous encapsulons une fonction publierMessage pour publier des messages. Cette fonction accepte deux paramètres : le type de message et le contenu du message. Tout d'abord, nous stockons le type et le contenu du message dans un tableau ; ensuite, utilisons la fonction de publication de Redis pour sérialiser le message au format JSON et le transmettre au canal nommé « notifications ».

Abonnement aux messages
Les utilisateurs peuvent choisir de s'abonner à différents types de messages. Nous devons créer un canal d'abonnement distinct pour chaque utilisateur et, une fois l'abonnement réussi, envoyer le message à l'utilisateur en temps réel. Voici un exemple de code :

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

Dans l'exemple de code ci-dessus, nous encapsulons une fonction SubscribeChannel pour vous abonner aux messages du canal spécifié. Cette fonction accepte deux paramètres : le nom du canal et la fonction de rappel pour le traitement des messages. Nous utilisons la fonction d'abonnement de Redis pour nous abonner au canal spécifié et traiter les messages reçus via la fonction de rappel.

4. Traitement des messages et affichage frontal
Lorsqu'un utilisateur s'abonne à un type de message spécifié, les nouveaux messages seront transmis à l'utilisateur en temps réel lorsqu'ils seront publiés. Nous devons traiter le message en conséquence et l'afficher. la page d'accueil. Voici un exemple de code :

<!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>

Dans l'exemple de code ci-dessus, nous utilisons Vue.js pour afficher la page frontale et établir une connexion persistante avec le backend via WebSocket. Une fois la page chargée, nous appelons la fonction SubscribeChannel pour vous abonner au canal nommé « notifications ». Lorsqu'un nouveau message arrive, le message est reçu via WebSocket et la fonction de rappel est exécutée, et le contenu du message est ajouté à la liste des messages du composant Vue pour réaliser l'affichage des notifications en temps réel.

5. Résumé
Grâce aux étapes ci-dessus, nous avons implémenté avec succès un exemple d'application qui utilise PHP et Redis pour implémenter des fonctions de notification en temps réel. En publiant un message, les utilisateurs peuvent transmettre le message à tous les utilisateurs abonnés à ce type de message en temps réel. De cette façon, nous pouvons répondre aux besoins des utilisateurs en matière de notifications en temps réel. Bien entendu, il ne s’agit que d’un simple exemple. Les applications réelles peuvent nécessiter une logique métier et des mécanismes de sécurité plus complexes, mais les idées de base de mise en œuvre sont similaires.

J'espère que cet article vous sera utile pour mettre en œuvre la fonction de notification en temps réel !

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

php json vue.js 封装回调函数 JS 对象 redis websocket

Déclaration：

Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn

Article précédent：Opérations bitmap avec Redis et PHP : comment obtenir des fonctions statistiques précisesArticle suivant：Opérations bitmap avec Redis et PHP : comment obtenir des fonctions statistiques précises

Articles Liés

Voir plus