Français
Français
introduction:
Redis est une base de données en mémoire haute performance qui prend en charge les fonctions publiques / sub (pub / sub). À l'aide du mécanisme d'abonnement aux messages de Redis, la livraison de messages en temps réel et le traitement entre les applications peuvent être réalisées. Cet article présentera comment écouter en continu l'abonnement des messages de Redis à l'aide de PHP et traiter efficacement les messages reçus.
Tout d'abord, assurez-vous que Redis est installé et fonctionne correctement. S'il n'a pas été installé, vous pouvez visiter le site Web officiel de Redis pour obtenir des instructions détaillées sur l'installation et la configuration.
Pour utiliser Redis dans PHP, vous devez installer l'extension PHP Redis. Le code d'extension et la méthode d'installation se trouvent sur sa page GitHub officielle.
// PrésentéRedisgentil
require 'path_to_redis/autoload.php';
<p>use Redis;</p>
<p>// créerRedisExemple<br>
$redis = new Redis();</p>
<p>// Se connecter àRedisserveur<br>
$redis->connect('127.0.0.1', 6379);</p>
<p>// Abonnez-vous au nom du canal<br>
$channel = 'my_channel';</p>
<p>// Surveiller en continu l'abonnement aux messages<br>
while (true) {<br>
// Bloquer la réception des messages<br>
$message = $redis->brPop($channel, 0);</p>
processMessage($message);
}
// Fonctions personnalisées pour le traitement des messages
fonction processMessage ($ message) {
// Ajouter une logique de traitement des messages personnalisé ici
Echo "Message reçu:". $ message [1]. "\ n";
}
Description: Le code ci-dessus crée d'abord le client Redis et se connecte au serveur, puis bloque en continu le message en spécifiant le nom du canal. Après avoir reçu le message, il est traité via une fonction personnalisée et les utilisateurs peuvent ajouter une logique métier à la fonction en fonction de leurs besoins.
// PrésentéRedisgentil
require 'path_to_redis/autoload.php';
<p>use Redis;</p>
<p>// créerRedisExemple<br>
$redis = new Redis();</p>
<p>// Se connecter àRedis<br>
$redis->connect('127.0.0.1', 6379);</p>
<p>// Nom de canal<br>
$channel = 'my_channel';</p>
<p>// Publier un message sur la chaîne<br>
$redis->publish($channel, 'Hello, Redis!');<br>
Après avoir exécuté ce code de test, le script écoutant le canal sortira en temps réel:
<span class="fun">Message reçu: Bonjour, redis!</span>
Grâce aux étapes ci-dessus, vous pouvez utiliser PHP pour écouter en continu les abonnements Redis Messages pour obtenir une réception en temps réel et un traitement des messages. Cela fournit une solution simple et pratique pour construire des systèmes de files d'attente de messages efficaces et publier / abonner des architectures. J'espère que cet article vous aidera à mieux comprendre et appliquer la fonction d'abonnement Redis Message.
