Bagaimanakah PHP boleh terus mendengar langganan mesej Redis dan menghantar pemberitahuan tolak?-tutorial php-php.cn

Bagaimanakah PHP boleh terus mendengar langganan mesej Redis dan menghantar pemberitahuan tolak?

WBOY

Lepaskan： 2023-09-05 11:34:01

asal

1037 orang telah melayarinya

Bagaimanakah PHP boleh terus mendengar langganan mesej Redis dan menghantar pemberitahuan tolak?

Dengan perkembangan pesat Internet, pemberitahuan masa nyata telah menjadi fungsi yang diperlukan untuk banyak aplikasi. Sebagai pangkalan data storan nilai kunci berprestasi tinggi, fungsi penerbitan dan langganan Redis dapat memenuhi permintaan ini dengan baik. Artikel ini akan memperkenalkan cara menggunakan PHP untuk memantau mesej Redis secara berterusan dan menghantar mesej kepada pengguna melalui pemberitahuan tolak.

Sebelum anda memulakan, anda perlu memastikan sambungan Redis telah dipasang Anda boleh memasangnya dengan arahan berikut:

pecl install redis

Salin selepas log masuk

Sambung ke pelayan Redis

Pertama, anda perlu menyambung ke pelayan Redis. . Gunakan kelas Redis untuk menyambung ke pelayan dan gunakan kaedah Redis::connect untuk menentukan hos dan port. Contoh di sini menggunakan localhost dan port lalai 6379: Redis类来连接服务器，并使用Redis::connect方法来指定主机和端口。这里的示例使用本地主机和默认端口6379：

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

Salin selepas log masuk

订阅消息

接下来，可以使用Redis::subscribe方法来订阅一个或多个频道的消息。该方法以一个数组作为参数，其中包含了所有要订阅的频道名称。这里示范订阅一个名为notifications的频道：

$redis->subscribe(['notifications'], function ($redis, $channel, $message) {
    // 在这里处理收到的消息
});

Salin selepas log masuk

在上述的回调函数中，可以根据业务需要来处理接收到的消息。例如，可以发送推送通知给用户。

发送推送通知

为了发送推送通知，可以使用各种第三方推送服务（如FCM或APNs）或者直接使用Websocket等技术来实现。这里以使用FCM（Firebase Cloud Messaging）来发送推送通知为例。

请确保已经安装了Firebase Admin SDK。可以通过Composer来安装：

composer require kreait/firebase-tokens
composer require kreait/firebase-admin

Salin selepas log masuk

首先，导入所需的类并初始化Firebase Admin SDK：

use KreaitFirebaseFactory;
use KreaitFirebaseMessagingCloudMessage;
use KreaitFirebaseMessagingNotification;

$factory = (new Factory)->withServiceAccount('/path/to/serviceAccountKey.json');
$messaging = $factory->createMessaging();

Salin selepas log masuk

然后，在接收到消息后，可以编写代码来发送推送通知：

$redis->subscribe(['notifications'], function ($redis, $channel, $message) use ($messaging) {
    // 处理收到的消息

    // 构建推送通知
    $notification = Notification::create('标题', '内容');

    // 构建消息
    $message = CloudMessage::fromArray([
        'token' => '设备的推送令牌',
        'notification' => $notification,
    ]);

    // 发送推送通知
    $messaging->send($message);
});

Salin selepas log masuk

以上示例中的设备的推送令牌需要被替换为实际设备的推送令牌，可参考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);
});

Salin selepas log masuk

以上代码将会持续监听Redis服务器，当有新的消息发布到notificationsrrreee

Seterusnya, anda boleh menggunakan kaedah Redis::subscribe untuk melanggan satu atau lebih banyak mesej Saluran. Kaedah ini mengambil tatasusunan sebagai parameter, yang mengandungi nama semua saluran untuk dilanggan. Berikut ialah contoh melanggan saluran bernama pemberitahuan:

Token tolak perantiperlu digantikan dengan token tolak peranti sebenar, yang boleh diperolehi dengan merujuk kepada dokumentasi FCM atau APN. 🎜

Redis::subscribe

notifications

Atas ialah kandungan terperinci Bagaimanakah PHP boleh terus mendengar langganan mesej Redis dan menghantar pemberitahuan tolak?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!