Comment PHP peut-il écouter en permanence les abonnements aux messages Redis et envoyer des notifications push ?

Comment PHP peut-il écouter en permanence les abonnements aux messages Redis et envoyer des notifications push ?

Avec le développement rapide d'Internet, les notifications en temps réel sont devenues une fonction nécessaire pour de nombreuses applications. En tant que base de données de stockage clé-valeur hautes performances, les fonctions de publication et d'abonnement de Redis peuvent bien répondre à cette demande. Cet article explique comment utiliser PHP pour surveiller en permanence les messages Redis et envoyer des messages aux utilisateurs via des notifications push.

Avant de commencer, vous devez vous assurer que l'extension Redis a été installée. Vous pouvez l'installer avec la commande suivante :

pecl install redis

1. Connectez-vous au serveur Redis

Tout d'abord, vous devez vous connecter au serveur Redis. . Utilisez la classe Redis pour vous connecter au serveur et utilisez la méthode Redis::connect pour spécifier l'hôte et le port. L'exemple ici utilise localhost et le port par défaut 6379 : Redis类来连接服务器，并使用Redis::connect方法来指定主机和端口。这里的示例使用本地主机和默认端口6379：

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

2. 订阅消息

接下来，可以使用Redis::subscribe方法来订阅一个或多个频道的消息。该方法以一个数组作为参数，其中包含了所有要订阅的频道名称。这里示范订阅一个名为notifications的频道：

$redis->subscribe(['notifications'], function ($redis, $channel, $message) {
    // 在这里处理收到的消息
});

在上述的回调函数中，可以根据业务需要来处理接收到的消息。例如，可以发送推送通知给用户。

3. 发送推送通知

为了发送推送通知，可以使用各种第三方推送服务（如FCM或APNs）或者直接使用Websocket等技术来实现。这里以使用FCM（Firebase Cloud Messaging）来发送推送通知为例。

请确保已经安装了Firebase Admin SDK。可以通过Composer来安装：

composer require kreait/firebase-tokens
composer require kreait/firebase-admin

首先，导入所需的类并初始化Firebase Admin SDK：

use KreaitFirebaseFactory;
use KreaitFirebaseMessagingCloudMessage;
use KreaitFirebaseMessagingNotification;

$factory = (new Factory)->withServiceAccount('/path/to/serviceAccountKey.json');
$messaging = $factory->createMessaging();

然后，在接收到消息后，可以编写代码来发送推送通知：

$redis->subscribe(['notifications'], function ($redis, $channel, $message) use ($messaging) {
    // 处理收到的消息

    // 构建推送通知
    $notification = Notification::create('标题', '内容');

    // 构建消息
    $message = CloudMessage::fromArray([
        'token' => '设备的推送令牌',
        'notification' => $notification,
    ]);

    // 发送推送通知
    $messaging->send($message);
});

以上示例中的设备的推送令牌需要被替换为实际设备的推送令牌，可参考FCM或APNs的文档获取。

4. 启动监听

最后，调用Redis::subscribe方法来启动监听：

$redis->subscribe(['notifications'], function ($redis, $channel, $message) use ($messaging) {
    // 处理收到的消息

    // 构建推送通知
    $notification = Notification::create('标题', '内容');

    // 构建消息
    $message = CloudMessage::fromArray([
        'token' => '设备的推送令牌',
        'notification' => $notification,
    ]);

    // 发送推送通知
    $messaging->send($message);
});

以上代码将会持续监听Redis服务器，当有新的消息发布到notificationsrrreee

Abonnez-vous aux messages

Ensuite, vous pouvez utiliser la méthode Redis::subscribe pour vous abonner à un ou plusieurs messages de chaîne. Cette méthode prend comme paramètre un tableau qui contient les noms de toutes les chaînes auxquelles s'abonner. Voici un exemple d'abonnement à un canal nommé notifications :

rrreee🎜Dans la fonction de rappel ci-dessus, les messages reçus peuvent être traités en fonction des besoins de l'entreprise. Par exemple, des notifications push peuvent être envoyées aux utilisateurs. 🎜
🎜Envoyer des notifications push🎜🎜🎜Pour envoyer des notifications push, vous pouvez utiliser divers services push tiers (tels que FCM ou APN) ou utiliser directement des technologies telles que Websocket. Ici, nous prenons comme exemple l'utilisation de FCM (Firebase Cloud Messaging) pour envoyer des notifications push. 🎜🎜Veuillez vous assurer que vous avez installé le SDK d'administration Firebase. Il peut être installé via Composer : 🎜rrreee🎜 Tout d'abord, importez les classes requises et initialisez le SDK Firebase Admin : 🎜rrreee🎜 Ensuite, après avoir reçu le message, vous pouvez écrire le code pour envoyer la notification push : 🎜rrreee🎜Le jeton push de l'appareil doit être remplacé par le jeton push de l'appareil réel, qui peut être obtenu en se référant à la documentation du FCM ou des APN. 🎜
🎜Démarrer la surveillance🎜🎜🎜Enfin, appelez la méthode Redis::subscribe pour démarrer la surveillance : 🎜rrreee🎜Le code ci-dessus continuera à surveiller le serveur Redis Quand. il y a un nouveau Lorsqu'un message est publié sur le canal notifications, des notifications seront reçues et des notifications push seront envoyées à l'utilisateur. 🎜🎜Résumé🎜🎜Cet article explique comment utiliser PHP pour surveiller en permanence les messages Redis et envoyer des messages aux utilisateurs via des notifications push. En utilisant les fonctions de publication et d'abonnement de Redis, des fonctions de notification en temps réel peuvent être réalisées et l'expérience utilisateur peut être améliorée. Dans le même temps, combinée à des services push tiers, la fonction de notification push des messages peut être facilement mise en œuvre. J'espère que cet article sera utile à tout le monde. 🎜

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!