Bagaimanakah PHP secara berterusan mendengar langganan mesej Redis dan memproses sejumlah besar mesej?

Bagaimanakah PHP boleh terus mendengar langganan mesej Redis dan memproses sejumlah besar mesej?

Ikhtisar:
Redis ialah pangkalan data nilai kunci berasaskan memori berprestasi tinggi yang digunakan secara meluas dalam cache, baris gilir, penerbitan mesej dan langganan serta senario lain. Dalam PHP, kami boleh menggunakan fungsi yang disediakan oleh sambungan Redis untuk terus memantau langganan mesej Redis dan memproses sejumlah besar mesej. Artikel ini akan menerangkan cara menggunakan sambungan PHP untuk mencapai fungsi ini, dengan contoh kod.

1. Pasang sambungan Redis
Sebelum menggunakan sambungan Redis, kita perlu memasangnya terlebih dahulu. Anda boleh memasang sambungan Redis melalui PECL dan jalankan arahan berikut:

pecl install redis

Selepas pemasangan berjaya, tambah baris berikut dalam fail php.ini:

extension=redis.so

Mulakan semula perkhidmatan PHP dan sambungan Redis boleh digunakan seperti biasa.

2. Langganan dan pemprosesan mesej Redis
Redis menyediakan dua arahan, melanggan dan menerbitkan, masing-masing untuk melanggan dan menerbitkan mesej. Dalam PHP, kita boleh menggunakan arahan langgan untuk terus mendengar langganan mesej Redis dan memproses mesej yang diterima melalui fungsi panggil balik.

Berikut ialah contoh yang menunjukkan cara menggunakan sambungan PHP untuk melaksanakan langganan dan pemprosesan mesej Redis:

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

$redis->subscribe(['channel'], function ($redis, $channel, $message) {
    // 处理收到的消息
    echo "Received message from channel {$channel}: {$message}
";
});

Dalam kod di atas, kami mula-mula mencipta contoh Redis dan menyambung ke pelayan Redis melalui kaedah sambungan. Kemudian gunakan kaedah langgan untuk melanggan saluran bernama 'saluran' dan masukkan fungsi tanpa nama sebagai fungsi panggil balik. Apabila mesej diterbitkan ke saluran, fungsi panggil balik akan dipanggil, menghantar contoh Redis, nama saluran dan kandungan mesej sebagai parameter.

3 Memproses sebilangan besar mesej secara serentak
Kod di atas hanya boleh memproses satu mesej dalam satu proses Jika sebilangan besar mesej diterbitkan ke Redis, kelajuan pemprosesan satu proses mungkin tidak dapat memenuhi permintaan . Untuk memproses sebilangan besar mesej secara serentak, kita boleh menggunakan berbilang proses untuk mencipta berbilang pengguna, setiap pengguna bertanggungjawab untuk memproses sebahagian daripada mesej tersebut.

Berikut ialah contoh kod yang menunjukkan cara mendengar mesej Redis dalam berbilang proses pada masa yang sama untuk mencapai pemprosesan serentak:

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

// 创建进程数，根据实际需求调整
$numWorkers = 4;

// 创建多个子进程
for ($i = 0; $i < $numWorkers; $i++) {
    $pid = pcntl_fork();
    if ($pid == -1) {
        die("Could not fork");
    } elseif ($pid) {
        // 父进程，继续创建下一个子进程
        continue;
    } else {
        // 子进程，执行订阅和处理逻辑
        $redis->subscribe(['channel'], function ($redis, $channel, $message) {
            // 处理收到的消息
            echo "Received message from channel {$channel}: {$message}
";
        });
        break;
    }
}

// 等待子进程退出
while (pcntl_waitpid(0, $status) != -1) {}

Dalam kod di atas, kami menggunakan fungsi pcntl_fork untuk mencipta berbilang proses anak dan melaksanakannya dalam kanak-kanak itu memproses Logik untuk melanggan dan memproses mesej. Proses ibu bapa terus mencipta proses anak seterusnya. Dengan cara ini, kami boleh mencipta berbilang proses pengguna pada masa yang sama untuk berkongsi beban pemprosesan mesej.

Perlu diingatkan bahawa kerana sambungan Redis menggunakan IO yang tidak menyekat, anda perlu memberi perhatian kepada penguncian apabila menggunakannya dalam persekitaran pelbagai proses untuk mengelakkan berlakunya keadaan perlumbaan. Ini tidak dikendalikan dalam kod contoh di atas Dalam aplikasi sebenar, ia perlu dikendalikan dengan sewajarnya mengikut keadaan tertentu.

Ringkasan:
Artikel ini memperkenalkan cara menggunakan sambungan PHP untuk terus mendengar langganan mesej Redis dan memproses sejumlah besar mesej. Melalui perintah langgan dan fungsi panggil balik, kami boleh memantau mesej dalam Redis dengan mudah dan memprosesnya mengikut keperluan sebenar. Pada masa yang sama, dengan mencipta berbilang pengguna dalam berbilang proses, kami boleh mencapai keperluan untuk memproses sejumlah besar mesej secara serentak. Saya harap artikel ini akan membantu anda memahami dan menggunakan langganan mesej Redis.

Atas ialah kandungan terperinci Bagaimanakah PHP secara berterusan mendengar langganan mesej Redis dan memproses sejumlah besar mesej?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!