ThinkPHP6 はプッシュ通知を送信します: ユーザー メッセージ プッシュの実装

ThinkPHP6 プッシュ通知の送信: ユーザー メッセージ プッシュの実装

はじめに:
現代の Web アプリケーションでは、メッセージ プッシュはリアルタイムの通知を提供する手段となっており、即時更新 重要な機能の 1 つ。ユーザーは操作中にタイムリーなメッセージ リマインダーを受け取り、ユーザー エクスペリエンスと対話性が向上します。この記事では、ThinkPHP6 フレームワークにユーザー メッセージ プッシュ機能を実装する方法をコード例とともに紹介します。

1. 準備

1. ThinkPHP6 フレームワークがインストールされ、設定されていることを確認します。

2. 拡張機能パッケージをインストールします:

   composer require topthink/think-swoole

2. プッシュ サービスを設定します

1. config/swoole を開きます。 php ファイルで、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. public/index.php ファイルを変更し、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 . メッセージ プッシュ コントロールの作成

1. コントローラー ファイル app/controller/Push.php を作成し、次のコードを記述します:

   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. メッセージを実装しますコントローラーのプッシュ関数 ：

   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. メッセージ プッシュ関数を使用する
メッセージ プッシュ関数を使用する必要があるコントローラーまたはビジネス ロジックでは、Push クラスをインスタンス化し、対応するメソッドを呼び出してメッセージを送信します。

use appcontrollerPush;

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

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

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

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

概要:
この記事では、ThinkPHP6 フレームワークにユーザー メッセージ プッシュ機能を実装する方法を紹介します。 Swoole サービスを構成し、Swoole の WebSocket 機能と関連拡張パッケージを使用することで、メッセージ プッシュ コントローラーを作成し、指定したユーザー、複数のユーザー、およびブロードキャストにメッセージを送信するためのメソッドを提供しました。開発者は、実際のニーズに応じて拡張および最適化して、より優れたリアルタイム メッセージング エクスペリエンスをユーザーに提供できます。

以上がThinkPHP6 はプッシュ通知を送信します: ユーザー メッセージ プッシュの実装の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。