Sistem Beratur Mesej dalam PHP

Dengan pembangunan Internet yang berterusan, permintaan orang ramai terhadap skalabiliti aplikasi web juga semakin tinggi. Dalam kes ini, cara membuat aplikasi web menyokong konkurensi yang tinggi dan trafik yang besar telah menjadi masalah yang mesti dihadapi oleh setiap pengaturcara web. Dalam masalah ini, sistem baris gilir mesej jelas menjadi peranan yang sangat diperlukan. Artikel ini akan memperkenalkan cara untuk mengintegrasikan sistem baris gilir mesej dalam PHP dan mengoptimumkan aplikasi web untuk meningkatkan kebolehskalaan aplikasi.

Apakah itu sistem baris gilir mesej?

Sistem baris gilir mesej ialah kaedah komunikasi tak segerak, proses silang dan silang pelayan. Ia memisahkan dan mempercepatkan proses dengan menghantar mesej antara pelbagai sistem, mempercepatkan pemprosesan. Sistem baris gilir mesej ialah mekanisme yang membolehkan aplikasi berinteraksi secara tidak segerak dengan aplikasi lain. Dalam erti kata lain, aplikasi web anda boleh menghantar mesej ke baris gilir mesej, dan kemudian aplikasi lain boleh membaca mesej daripada baris gilir mesej.

Mengapa menggunakan sistem baris gilir mesej?

Aplikasi web perlu mengendalikan pelbagai permintaan, ada yang perlu diproses, dan ada yang boleh ditangguhkan. Sistem aplikasi tradisional perlu menunggu pra-pemprosesan selesai sebelum memproses kumpulan permintaan seterusnya. Melakukannya akan menyebabkan banyak pembaziran sumber pelayan.

Pada masa ini, baris gilir mesej boleh membantu kami menyelesaikan masalah ini. Apabila kami mempunyai baris gilir mesej dan baris gilir mempunyai berbilang pengguna, kami boleh menyerahkan pemprosesan permintaan kepada pengguna. Aplikasi web hanya menolak permintaan ke baris gilir mesej dan kemudian mengumumkan bahawa tugas itu selesai.

Dalam kes ini, aplikasi anda hanya perlu memfokuskan pada tugas penjanaan, manakala pengguna perlu menumpukan pada tugasan pemprosesan. Ini sangat memudahkan keseluruhan proses pemprosesan, meningkatkan kecekapan pemprosesan dan menjimatkan sumber pelayan.

Bagaimana untuk melaksanakan sistem baris gilir mesej dalam PHP?

Untuk melaksanakan sistem baris gilir mesej dalam PHP, anda perlu memilih enjin baris gilir mesej dan penyelesaian baris gilir mesej PHP. Tiga penyelesaian baris gilir mesej PHP yang popular disediakan di bawah:

1 Beanstalkd

Beanstalkd ialah sistem baris gilir mesej yang mudah, pantas dan ringan. Beanstalkd boleh mengagihkan tugas di antara ratusan proses yang memakan, menjadikannya penyelesaian yang sangat berkuasa.

Untuk menggunakan Beanstalkd dalam PHP, kita boleh menggunakan perpustakaan 'Pheanstalk'. Perpustakaan ini menyediakan kaedah yang mudah digunakan untuk berkomunikasi dengan pelayan Beanstalkd.

// 创建连接
$pheanstalk = new PheanstalkPheanstalk('127.0.0.1');
// 推送任务
$pheanstalk->useTube('mytube')->put('hello world');
// 获取任务
$job = $pheanstalk->watch('mytube')->ignore('default')->reserve();
echo $job->getData();

2. RabbitMQ

RabbitMQ ialah sistem baris gilir mesej AMQP (Advanced Message Queue Protocol). RabbitMQ mempunyai mekanisme penghalaan mesej yang sangat berkuasa dan berskala. Ia menyokong berbilang bahasa pengaturcaraan dan mempunyai dokumentasi yang sangat baik dan sokongan komuniti.

Tidak seperti Beanstalkd, RabbitMQ ialah enjin baris gilir mesej yang perlu dipasang pada pelayan. Pustaka 'php-amqplib' digunakan untuk berkomunikasi dengan PHP Kodnya adalah seperti berikut:

// 建立连接
$connection = new PhpAmqpLibConnectionAMQPStreamConnection('localhost', 5672, 'guest', 'guest');
// 创建通道
$channel = $connection->channel();
// 声明队列
$channel->queue_declare('myqueue', false, false, false, false);
// 发送消息
$msg = new PhpAmqpLibMessageAMQPMessage('Hello World!');
$channel->basic_publish($msg, '', 'myqueue');
// 获取消息
$callback = function ($msg) {
    echo $msg->body;
};
$channel->basic_consume('myqueue', '', false, true, false, false, $callback);
while (count($channel->callbacks)) {
    $channel->wait();
}

3. Redis Queue Service

Redis boleh digunakan sebagai perkhidmatan giliran 'senarai' struktur data Redis, kami Baris gilir boleh dilaksanakan dengan mudah. Dalam PHP kita boleh berkomunikasi dengan Redis menggunakan perpustakaan 'Predis' pra-dibuat.

// 初始化 Redis
$redis = new PredisClient([
    'scheme' => 'tcp',
    'host' => '127.0.0.1',
    'port' => 6379
]);
// 推送任务
$redis->rpush('myqueue', 'hello world');
// 获取任务
echo $redis->blpop('myqueue', 0)[1];

Ringkasan

Seperti yang dapat dilihat daripada artikel ini, sistem baris gilir mesej ialah penyelesaian yang sangat berkuasa dan boleh digunakan yang boleh meningkatkan skalabiliti dan prestasi tapak web. Tidak kira apa saiz beban kerja yang anda hadapi, anda boleh mengendalikan pelbagai operasi dengan mudah menggunakan sistem baris gilir mesej dalam PHP. Menggunakan enjin baris gilir mesej yang betul dan penyelesaian baris gilir mesej PHP boleh mempercepatkan pemprosesan dan memberikan skalabiliti yang lebih baik untuk aplikasi web anda.

Atas ialah kandungan terperinci Sistem Beratur Mesej dalam PHP. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!