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

PHPz
リリース: 2023-08-12 10:13:10
オリジナル
2314 人が閲覧しました

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 サイトの他の関連記事を参照してください。

ソース:php.cn
このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
人気のチュートリアル
詳細>
最新のダウンロード
詳細>
ウェブエフェクト
公式サイト
サイト素材
フロントエンドテンプレート