Bagaimana untuk melaksanakan corak publish-subscribe pengundian panjang menggunakan PHP

Dalam pembangunan Web moden, komunikasi masa nyata telah menjadi keperluan yang sangat penting, dan model baris gilir mesej dan publish-subscribe telah menjadi penyelesaian standard untuk merealisasikan komunikasi masa nyata dalam aplikasi Web. Dalam artikel ini, kami akan memperkenalkan cara menggunakan PHP untuk melaksanakan mod langgan-terbitkan undian panjang.

Apakah pengundian panjang?

Dalam aplikasi web tradisional, pelanggan menghantar permintaan kepada pelayan dan pelayan mengembalikan respons serta-merta selepas menerima permintaan. Tinjauan panjang adalah seni bina aplikasi web yang lebih maju yang membolehkan pelayan menunggu untuk tempoh masa selepas menerima permintaan pelanggan untuk menentukan sama ada terdapat mesej baru Jika tiada mesej baru, sambungan akan dikekalkan sehingga terdapat a mesej baharu. Apabila mesej baharu tiba, respons dikembalikan kepada klien.

Oleh itu, pelaksanaan tinjauan panjang adalah lebih cekap daripada mod tindak balas permintaan tradisional, menjimatkan sumber pelayan dan lebih selaras dengan keperluan komunikasi masa nyata.

Bagaimana untuk melaksanakan tinjauan panjang menggunakan PHP?

Di bawah ini kami akan memperkenalkan cara menggunakan PHP dan baris gilir mesej untuk melaksanakan pengundian yang panjang.

1. Pasang Message Queue

Sebelum menggunakan PHP untuk melaksanakan pengundian yang panjang, kita perlu memasang Message Queue. Barisan gilir mesej yang popular pada masa ini termasuk RabbitMQ, ZeroMQ dan Beanstalkd. Dalam artikel ini, kami akan menggunakan Beanstalkd untuk melaksanakan baris gilir mesej.

Pertama, kita perlu memuat turun dan memasang Beanstalkd. Dalam sistem Ubuntu, anda boleh menggunakan arahan berikut untuk memasang:

sudo apt-get install beanstalkd

Jika anda menggunakan sistem pengendalian lain, anda boleh memuat turun versi yang sesuai dari tapak web rasmi Beanstalkd untuk memasang.

Selepas pemasangan selesai, kita boleh menggunakan arahan berikut untuk memulakan Beanstalkd:

perkhidmatan sudo beanstalkd mula

2. Tulis kod PHP

Di bawah, kami akan menggunakan contoh untuk menunjukkan cara menggunakan Beanstalkd untuk melaksanakan tinjauan panjang dalam PHP.

Mula-mula, sambungkan Beanstalkd dalam fail PHP:

$beanstalk = new Pheanstalk('127.0.0.1');

Kemudian, kita perlu mentakrifkan Fungsi penerbitan mesej :

fungsi publish($channel, $message){

global $beanstalk;
$data = json_encode(array('channel' => $channel, 'message' => $message));
$beanstalk->useTube("pubsub")
          ->put($data, Pheanstalk::DEFAULT_PRIORITY, 0, 10);

}

Fungsi fungsi ini adalah untuk menghantar mesej ke paip bernama "pubsub" tengah. Kami boleh menghantar mesej ke paip yang berbeza mengikut keperluan.

Kemudian, kita perlu mentakrifkan fungsi untuk melanggan mesej:

fungsi melanggan($channel, $callback){

global $beanstalk;
$beanstalk->watch($channel);
while (true) {
    $job = $beanstalk->reserve();
    if ($job) {
        $data = json_decode($job->getData(), true);
        if ($data['channel'] == $channel) {
            call_user_func($callback, $data['message']);
            $beanstalk->delete($job);
            break;
        } else {
            $beanstalk->bury($job);
        }
    }
}

}

Ini Fungsinya adalah untuk mendengar paip yang ditentukan Apabila mesej tiba, laksanakan fungsi $callback dan padamkan mesej daripada baris gilir.

Seterusnya, kita perlu menggunakan kod JavaScript pada bahagian pelanggan untuk melaksanakan tinjauan panjang.

3. Kod JavaScript pelanggan

Dalam klien, kita perlu menentukan dua fungsi. Satu ialah fungsi yang menghantar mesej, dan satu lagi ialah fungsi yang menerima mesej. Berikut ialah contoh kod:

fungsi terbitkan(saluran, mesej){

// 发送消息
$.ajax({
    type: 'POST',
    url: 'publish.php',
    data: {channel: channel, message: message},
    success: function(data){}
});

}

fungsi langgan(saluran, panggil balik){

// 接收消息
function poll(){
    $.ajax({
        type: 'GET',
        url: 'subscribe.php',
        data: 'channel=' + channel,
        dataType: 'json',
        success: function(data){
            if (data && data.message){
                callback(data.message);
            }
            poll();
        },
        error: function(){
            setTimeout(poll, 5000);
        }
    });
}
poll();

}

Dalam contoh ini, kami menggunakan jQuery untuk menghantar permintaan POST untuk menghantar mesej dan GET permintaan untuk menerima mesej.

Perlu diambil perhatian bahawa dalam tinjauan panjang, pelanggan akan kekal berhubung sehingga respons diterima. Agar pelayan tidak menutup sambungan apabila ia melahu, kami perlu menambah kod berikut pada halaman untuk mengelakkan tamat masa:

Dalam contoh ini, halaman akan dimuat semula setiap 600 saat.

Kesimpulan

Menggunakan PHP dan baris gilir mesej, kami boleh melaksanakan model langgan-terbitkan tinjauan panjang dengan mudah untuk mencapai keperluan komunikasi masa nyata. Kaedah ini sangat biasa digunakan dalam pertukaran data dan komunikasi masa nyata dalam aplikasi Web. Ia boleh mengurangkan penggunaan pengundian dan kaedah lain untuk menggunakan prestasi pelayan dalam aplikasi, dan meningkatkan kebolehskalaan aplikasi Web.

Atas ialah kandungan terperinci Bagaimana untuk melaksanakan corak publish-subscribe pengundian panjang menggunakan PHP. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!