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
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);
接下来,可以使用Redis::subscribe
方法来订阅一个或多个频道的消息。该方法以一个数组作为参数,其中包含了所有要订阅的频道名称。这里示范订阅一个名为notifications
的频道:
$redis->subscribe(['notifications'], function ($redis, $channel, $message) { // 在这里处理收到的消息 });
在上述的回调函数中,可以根据业务需要来处理接收到的消息。例如,可以发送推送通知给用户。
为了发送推送通知,可以使用各种第三方推送服务(如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的文档获取。
最后,调用Redis::subscribe
方法来启动监听:
$redis->subscribe(['notifications'], function ($redis, $channel, $message) use ($messaging) { // 处理收到的消息 // 构建推送通知 $notification = Notification::create('标题', '内容'); // 构建消息 $message = CloudMessage::fromArray([ 'token' => '设备的推送令牌', 'notification' => $notification, ]); // 发送推送通知 $messaging->send($message); });
以上代码将会持续监听Redis服务器,当有新的消息发布到notifications
rrreee
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
:
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. 🎜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!