ThinkPHP6 envoie des notifications push : implémentation du push des messages utilisateur

ThinkPHP6 Envoi de notifications push : implémentation du message push utilisateur

Introduction :
Dans les applications Web modernes, le push de message est devenu l'une des fonctions importantes pour fournir des notifications en temps réel et des mises à jour instantanées. Les utilisateurs recevront des rappels de messages en temps opportun pendant l'opération, améliorant ainsi l'expérience utilisateur et l'interactivité. Cet article présentera comment implémenter la fonction push de message utilisateur dans le framework ThinkPHP6, avec des exemples de code.

1. Préparation

1. Assurez-vous que le framework ThinkPHP6 a été installé et configuré.

2. Installez le pack d'extension :

   composer require topthink/think-swoole

2. Configurez le service push

1. Ouvrez le fichier config/swoole.php et configurez le service Swoole :

   return [
       // ...
       'swoole' => [
           'enable' => true, // 启用Swoole
           'type' => 'http',
           'host' => '0.0.0.0',
           'port' => 9501, // 自定义端口号
           'worker_num' => 1,
           'pid_file' => app()->getRuntimePath() . 'swoole.pid',
           'log_file' => app()->getRuntimePath() . 'swoole.log',
           'document_root' => app()->getPublicPath(),
           'static_handler_locations' => [],
           'enable_static_handler' => false,
       ],
   ];

2. Modifiez le fichier public/index.php et Présentation du fichier de démarrage Swoole ：

   // ...
   // 启动框架（自动生成）
   if (PHP_SAPI == 'cli' && isset($argv[1]) && $argv[1] == 'swoole') {
       $think = require dirname(__DIR__) . '/thinkphp/base.php';
       $swoole = new     hinkswooleServer(app());
       $swoole->start();
   } else {
       // ...
   }
   // ...

3. Créez un contrôleur push de message

1. Créez le fichier du contrôleur app/controller/Push.php et écrivez le code suivant :

   namespace appcontroller;
   
   use swoole_websocket_server;
   use thinkswoolewebsocketsocketioHandlerInterface;
   use thinkswoolewebsocketsocketioSocketio;
   use thinkswoolewebsocketsocketioSocketIos2;
   use thinkswoolewebsocketsocketioSocketioFrame;
   use thinkswoolewebsocketsocketiohandlerConnect;
   use thinkswoolewebsocketsocketiohandlerDisconnect;
   use thinkswoolewebsocketsocketiohandlerEvents;
   use thinkswoolewebsocketsocketioPacket;
   use thinkswoolewebsocketsocketioStreamResponse;
   use thinkswoolewebsocketsocketioWebSocket;
   use thinkswoolewebsocketsocketioWebsocketFrame;
   use thinkswoolewebsocketsocketioHandlerLoader;
   
   class Push implements HandlerInterface
   {
       public function onOpen(WebSocket $websocket, Request $request)
       {
           // 连接成功时触发
       }
   
       public function onMessage(WebSocket $websocket, WebsocketFrame $frame)
       {
           // 接收到消息时触发
       }
   
       public function onClose(WebSocket $websocket, $fd, $reactorId)
       {
           // 连接关闭时触发
       }
   }

2. Implémentez la fonction message push dans le contrôleur :

   namespace appcontroller;
   
   use appmodelUser;
   use thinkacadeDb;
   use thinkacadeRequest;
   use thinkpushPusher;
   
   class Push
   {
       // 发送消息给指定用户
       public function pushToUser($userId, $message)
       {
           $user = User::find($userId);
           if ($user) {
               $push = new Pusher();
               $push->setConnection('pusher'); // 设置推送连接名
               $push->setContent($message);
               $push->to($user->push_channel)->send();
               return "消息推送成功";
           } else {
               return "用户不存在";
           }
       }
   
       // 发送消息给多个用户
       public function pushToUsers($userIds, $message)
       {
           $users = User::whereIn('id', $userIds)->select();
           if ($users) {
               $push = new Pusher();
               $push->setConnection('pusher'); // 设置推送连接名
               
               foreach ($users as $user) {
                   $push->setContent($message);
                   $push->to($user->push_channel)->send();
               }
               
               return "消息推送成功";
           } else {
               return "用户不存在";
           }
       }
   
       // 发送广播消息
       public function broadcast($message)
       {
           $push = new Pusher();
           $push->setConnection('pusher'); // 设置推送连接名
           $push->channel('public-channel')->setContent($message)->broadcast();
           return "消息推送成功";
       }
   }

4. Utilisez la fonction push de message
Dans tout contrôleur ou logique métier qui doit utiliser la fonction push de message, instanciez simplement la classe Push et appelez la méthode correspondante pour envoyer le message.

use appcontrollerPush;

function sendPushNotification()
{
    $push = new Push();

    // 发送消息给指定用户
    $push->pushToUser($userId, $message);

    // 发送消息给多个用户
    $push->pushToUsers($userIds, $message);

    // 发送广播消息
    $push->broadcast($message);
}

Résumé :
Cet article présente comment implémenter la fonction push de message utilisateur dans le framework ThinkPHP6. En configurant le service Swoole et en utilisant la fonction WebSocket de Swoole et les packages d'extension associés, nous avons créé un contrôleur push de messages et fourni des méthodes pour envoyer des messages à des utilisateurs spécifiés, à plusieurs utilisateurs et à des diffusions. Les développeurs peuvent développer et optimiser en fonction des besoins réels pour offrir aux utilisateurs une meilleure expérience de messagerie 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!