Bagaimana untuk menggunakan PHP untuk terus mendengar langganan mesej Redis dan memproses mesej daripada berbilang pelayan?

Cara menggunakan PHP untuk terus memantau langganan mesej Redis dan memproses mesej daripada berbilang pelayan

Dengan pembangunan aplikasi Internet yang berterusan, push mesej masa nyata telah menjadi keperluan untuk banyak aplikasi. Sebagai pangkalan data cache berprestasi tinggi, model penerbitan/langganan Redis boleh memenuhi permintaan ini dengan baik. Artikel ini akan memperkenalkan cara menggunakan PHP untuk melanggan dan memproses mesej Redis, dan menyelesaikan masalah berbilang pelayan mendengar mesej pada masa yang sama.

Pertama, kita perlu memastikan bahawa pangkalan data Redis dan sambungan Redis untuk PHP dipasang dan dikonfigurasikan dengan betul. Jika sambungan Redis dan Redis tidak dipasang, anda boleh merujuk kepada dokumentasi yang berkaitan untuk memasangnya.

Seterusnya, kami mengambil aplikasi bilik sembang ringkas sebagai contoh untuk menunjukkan cara menggunakan PHP untuk terus memantau langganan mesej Redis dan memproses mesej daripada berbilang pelayan.

1. Buat fail PHP bernama subscriber.php untuk melanggan mesej Redis.

<?php

$redis = new Redis();
$redis->connect('127.0.0.1', 6379); // Redis服务器地址和端口号
$redis->subscribe(['chat-room'], 'processMessage'); // 订阅名为chat-room的频道，并指定回调函数processMessage

function processMessage($redis, $channel, $message)
{
    // 处理接收到的消息，例如将消息推送给聊天室的在线用户
    echo "Received message from channel {$channel}: {$message}
";
    // 在这里实现将消息推送给聊天室的在线用户的逻辑
}

subscriber.php，用于订阅Redis消息。

<?php

$redis = new Redis();
$redis->connect('127.0.0.1', 6379); // Redis服务器地址和端口号
$redis->publish('chat-room', 'Hello, world!'); // 向名为chat-room的频道发布一条消息

2. 创建一个PHP文件，命名为publisher.php，用于向Redis发布消息。

<?php

$redis = new Redis();
$redis->connect('127.0.0.1', 6379); // Redis服务器地址和端口号
$redis->subscribe(['chat-room'], 'processMessage');

function processMessage($redis, $channel, $message)
{
    // 处理接收到的消息，例如将消息推送给聊天室的在线用户
    echo "Received message from channel {$channel}: {$message}
";
    
    // 向其他服务器发送消息
    $curl = curl_init();
    curl_setopt($curl, CURLOPT_URL, 'http://other-server/process-message.php');
    curl_setopt($curl, CURLOPT_POST, true);
    curl_setopt($curl, CURLOPT_POSTFIELDS, [
        'channel' => $channel,
        'message' => $message,
    ]);
    curl_exec($curl);
    curl_close($curl);
}

通过上述代码，我们实现了一个简单的 Redis 消息订阅和发布功能。可运行subscriber.php来监听Redis的消息，并运行publisher.php向Redis发布一条消息。当收到消息时，processMessage回调函数会被调用，我们可以在该函数中实现对消息的处理逻辑。

然而，如果我们使用多台服务器来处理消息，每台服务器上都运行一个subscriber.php来持续监听Redis的消息，就会导致消息被多次处理，从而出现重复操作的问题。

为了解决这个问题，我们可以借助Redis的PUBLISH/SUBSCRIBE功能。我们可以创建一个额外的服务器，专门用于订阅Redis消息，并将处理消息的逻辑转发给其他服务器。下面是修改后的代码示例：

1. 修改subscriber.php文件。

<?php

$channel = $_POST['channel'];
$message = $_POST['message'];

// 在这里实现将消息推送给聊天室的在线用户的逻辑
echo "Received message from channel {$channel}: {$message}
";

2. 创建一个新的PHP文件，命名为process-message.php，用于处理接收到的消息。

在上述代码中，我们修改了 subscriber.php 文件，添加了向其他服务器发送消息的逻辑。当收到消息时，它将通过 HTTP POST 请求将消息发送到其他服务器的 process-message.php 文件，后者负责进一步处理接收到的消息。

通过这种方式，我们可以实现多台服务器同时监听Redis消息，并确保每条消息只被处理一次。只要其他服务器的 process-message.phpBuat fail PHP bernama publisher.php untuk menerbitkan mesej kepada Redis. rrreee

🎜Buat fail PHP baharu bernama process-message.php untuk memproses mesej yang diterima.

Atas ialah kandungan terperinci Bagaimana untuk menggunakan PHP untuk terus mendengar langganan mesej Redis dan memproses mesej daripada berbilang pelayan?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!