Comment PHP écoute-t-il en permanence les abonnements aux messages Redis et les traite-t-il ?

Comment PHP peut-il écouter en permanence les abonnements aux messages Redis et les traiter ?

Redis est une base de données en mémoire open source largement utilisée dans le cache, la file d'attente, l'abonnement aux messages et d'autres scénarios. Dans le développement réel, nous devons souvent mettre en œuvre une surveillance et un traitement continus des messages Redis. Cet article explique comment utiliser PHP pour s'abonner et traiter les messages Redis, et fournit des exemples de code.

Tout d'abord, nous devons nous assurer que l'extension Redis a été installée. Vous pouvez installer l'extension Redis avec la commande suivante :

$ pecl install redis

Une fois l'installation terminée, introduisez l'extension Redis dans le code PHP :

<?php
    // 引入Redis扩展
    extension_loaded('redis') || dl('redis.so');
?>

Ici. est un exemple simple qui montre comment s'abonner et traiter les messages Redis :

<?php
    // 连接Redis服务器
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);

    // 订阅频道
    $redis->subscribe(['channel'], function ($redis, $channel, $message) {
        // 处理消息
        echo "收到来自频道 {$channel} 的消息：{$message}
";

        // 当收到"quit"消息时结束订阅
        if ($message == 'quit') {
            $redis->unsubscribe();
        }
    });

    // 关闭连接
    $redis->close();
?>

Dans l'exemple ci-dessus, nous nous connectons d'abord au serveur Redis via la méthode connect. Ensuite, abonnez-vous à une ou plusieurs chaînes via la méthode subscribe. Dans la fonction de rappel, nous pouvons gérer le message reçu. Lorsqu'un message spécifique (tel que « quitter ») est reçu, appelez la méthode unsubscribe pour mettre fin à l'abonnement. Enfin, utilisez la méthode close pour fermer la connexion au serveur Redis. connect方法连接Redis服务器。接下来，通过subscribe方法订阅一个或多个频道。在回调函数中，我们可以处理收到的消息。当收到特定消息（如"quit"）时，调用unsubscribe方法结束订阅。最后，使用close方法关闭与Redis服务器的连接。

如果我们需要订阅多个频道，可以在subscribe方法中传入一个频道数组：

$redis->subscribe(['channel1', 'channel2'], function ($redis, $channel, $message) {
    // 处理消息
});

需要注意的是，Redis采用的是发布/订阅模式，而非队列模式。当我们发布一条消息时，所有订阅了该频道的客户端都将收到这条消息。而对于未订阅的客户端，将无法接收到之前发布的消息。

除了使用回调函数处理消息，我们还可以通过创建一个子进程来实现并行处理。以下是一个示例：

<?php
    // 创建子进程
    $pid = pcntl_fork();

    if ($pid == -1) {
        // 创建失败
        die('Fork failed');
    } elseif ($pid == 0) {
        // 子进程
        $redis = new Redis();
        $redis->connect('127.0.0.1', 6379);

        $redis->subscribe(['channel'], function ($redis, $channel, $message) {
            // 处理消息
            echo "子进程收到来自频道 {$channel} 的消息：{$message}
";

            // 当收到"quit"消息时结束订阅
            if ($message == 'quit') {
                $redis->unsubscribe();
            }
        });

        $redis->close();
    } else {
        // 父进程
        pcntl_waitpid($pid, $status);
    }
?>

在上述示例中，我们通过pcntl_fork函数创建了一个子进程。子进程中的代码与前面的示例相同。父进程通过pcntl_waitpid

rrreee

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!