Bagaimana untuk terus mendengar langganan mesej Redis dan mengemas kini status pengguna dalam PHP?

Bagaimana untuk melaksanakan pemantauan berterusan langganan mesej Redis dan mengemas kini status pengguna dalam PHP?

Ikhtisar:
Redis ialah pangkalan data dalam memori sumber terbuka yang digunakan secara meluas yang menyokong fungsi langganan dan penerbitan mesej. Apabila membangunkan aplikasi web, kami sering menghadapi keperluan untuk mengemas kini status pengguna dalam masa nyata, seperti sistem sembang dalam talian, paparan data masa nyata, dsb. Artikel ini akan memperkenalkan cara menggunakan PHP untuk melaksanakan fungsi memantau langganan mesej Redis secara berterusan dan mengemas kini status pengguna.

Langkah:

1. Pasang sambungan Redis: Pertama, pastikan anda telah memasang sambungan Redis dalam persekitaran PHP anda. Anda boleh memasangnya melalui perintah pecl install redis atau tambahkan extension=redis.so pada fail konfigurasi PHP untuk mendayakan sambungan. pecl install redis命令来安装，或者在PHP配置文件中添加extension=redis.so来启用扩展。
2. 连接Redis服务器：在PHP代码中，使用Redis类来连接Redis服务器。可以通过$redis = new Redis()来创建一个Redis实例，然后通过$redis->connect($host, $port)方法连接到Redis服务器。 $host和$port参数分别代表Redis服务器的主机和端口。

代码示例：

<?php
$redis = new Redis();
$redis->connect("localhost", 6379);

3. 订阅消息：使用$redis->subscribe($channels, $callback)方法订阅Redis的消息。$channels是一个数组，可以指定一个或多个频道来订阅消息。$callback是一个回调函数，用于处理接收到的消息。

代码示例：

<?php
function handleMessage($redis, $channel, $message) {
    // 在此处处理接收到的消息
    // 可以更新用户状态或执行其他相关操作
    echo "Received message: $message
";
}

$redis->subscribe(["channel1", "channel2"], "handleMessage");

4. 监听消息：使用$redis->psubscribe($patterns, $callback)方法可以监听多个频道的消息。与订阅消息类似，$patterns
Sambung ke pelayan Redis: Dalam kod PHP, gunakan kelas Redis untuk menyambung ke pelayan Redis. Anda boleh mencipta instance Redis melalui $redis = new Redis(), dan kemudian menyambung ke pelayan Redis melalui $redis->connect($host, $port) kaedah. Parameter $host dan $port masing-masing mewakili hos dan port pelayan Redis.

Contoh kod:

<?php
function handleMessage($redis, $pattern, $channel, $message) {
    // 在此处处理接收到的消息
    // 可以更新用户状态或执行其他相关操作
    echo "Received message on channel $channel: $message
";
}

$redis->psubscribe(["channel:*"], "handleMessage");

Langgan mesej: Gunakan kaedah $redis->subscribe($channels, $callback) untuk melanggan mesej Redis. $channels ialah tatasusunan yang boleh menentukan satu atau lebih saluran untuk melanggan mesej. $callback ialah fungsi panggil balik yang digunakan untuk memproses mesej yang diterima.




Contoh kod:

<?php
function updateUserStatus($redis, $channel, $message) {
    // 更新用户在线状态
    $userId = $channel;
    $status = $message;
    
    // 在此处执行相关操作，如更新数据库记录等
    echo "User $userId is $status
";
}

// 用户登录时订阅消息
function userLogin($userId) {
    global $redis;
    $redis->subscribe(["user:$userId"], "updateUserStatus");
}

// 用户退出登录时取消订阅消息
function userLogout($userId) {
    global $redis;
    $redis->unsubscribe(["user:$userId"]);
}

$user = "123"; // 用户ID
userLogin($user); // 用户登录

// 模拟用户状态更新
$redis->publish("user:$user", "online");
sleep(3); // 假设有其他操作需要处理

$userLogout($user); // 用户退出登录

Mendengar mesej: Gunakan kaedah $redis->psubscribe($patterns, $callback) untuk mendengar mesej daripada berbilang saluran. Sama seperti melanggan mesej, $patterns ialah tatasusunan yang menentukan satu atau lebih corak untuk mendengar mesej.

Contoh kod:

<?php
// 监听用户状态更新
function handleUserStatus($redis, $pattern, $channel, $message) {
    echo "User $channel is now $message
";
}

// 监听所有用户状态更新
$redis->psubscribe(["user:*"], "handleUserStatus");

Nota: Apabila melanggan atau mendengar mesej, kod PHP akan menyekat dalam fungsi panggil balik dan tidak akan meneruskan pelaksanaan sehingga mesej diterima. Oleh itu, anda perlu menggunakan sambungan panjang atau multi-threading dalam skrip PHP untuk mencapai pendengaran berterusan.


Contoh aplikasi: 🎜Dalam aplikasi bilik sembang dalam talian yang mudah, kami boleh menggunakan Redis untuk mengemas kini status dalam talian pengguna dalam masa nyata. 🎜🎜Apabila pengguna log masuk, permintaan mesej langganan dihantar ke pelayan Redis, dan saluran itu boleh menggunakan pengecam unik pengguna. Nyahlanggan daripada mesej apabila pengguna log keluar. 🎜🎜Contoh kod sisi pelayan: 🎜rrreee🎜Contoh kod sisi pelanggan: 🎜rrreee🎜Ringkasan: 🎜Dengan menggunakan fungsi langganan dan penerbitan mesej Redis dan mekanisme pemprosesan tak segerak PHP, kami boleh terus memantau mesej Redis dan mengemas kini mesej pengguna dalam keadaan masa nyata. Ini sangat berguna untuk membangunkan aplikasi web dengan prestasi masa nyata yang tinggi. Saya harap artikel ini dapat membantu anda memahami cara memantau langganan mesej Redis secara berterusan dan mengemas kini status pengguna dalam PHP. 🎜

Atas ialah kandungan terperinci Bagaimana untuk terus mendengar langganan mesej Redis dan mengemas kini status pengguna dalam PHP?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!