ThinkPHP6 sends push notifications: implementing user message push

ThinkPHP6 Sending Push Notifications: Implementing User Message Push

Introduction:
In modern web applications, message push has become a way to provide real-time notifications and instant updates One of the important functions. Users will receive timely message reminders during the operation, improving user experience and interactivity. This article will introduce how to implement the user message push function in the ThinkPHP6 framework, with code examples.

1. Preparation

1. Make sure that the ThinkPHP6 framework has been installed and configured.

2. Install the extension package:

   composer require topthink/think-swoole

   Copy after login

2. Configure push service

1. Open the config/swoole.php file , configure the Swoole service:

   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,
       ],
   ];

   Copy after login

2. Modify the public/index.php file and introduce the Swoole startup file:

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

   Copy after login

3. Create message push control

1. Create the controller file app/controller/Push.php and write the following code:

   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)
       {
           // 连接关闭时触发
       }
   }

   Copy after login

2. Implement the message push function in the controller ：

   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 "消息推送成功";
       }
   }

   Copy after login

4. Use the message push function
In any controller or business logic that needs to use the message push function, just instantiate the Push class and call the corresponding method to send messages.

use appcontrollerPush;

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

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

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

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

Summary:
This article introduces how to implement the user message push function in the ThinkPHP6 framework. By configuring the Swoole service and using Swoole's WebSocket function and related extension packages, we created a message push controller and provided methods for sending messages to specified users, multiple users, and broadcasts. Developers can expand and optimize according to actual needs to provide users with a better real-time messaging experience.

The above is the detailed content of ThinkPHP6 sends push notifications: implementing user message push. For more information, please follow other related articles on the PHP Chinese website!