Bagaimana untuk menggunakan baris gilir untuk memproses tugas penghantaran SMS tak segerak dalam PHP?

Bagaimana untuk menggunakan baris gilir untuk memproses tugas penghantaran SMS tak segerak dalam PHP?

Dengan perkembangan Internet dan populariti terminal mudah alih, mesej teks telah menjadi salah satu cara penting untuk orang ramai berkomunikasi dalam kehidupan seharian. Dalam sesetengah perniagaan, kami mungkin perlu menghantar sejumlah besar mesej teks dalam kelompok Walau bagaimanapun, menghantar sejumlah besar mesej teks pada satu masa boleh memberi tekanan pada pelayan dan menjejaskan pengalaman pengguna. Untuk menyelesaikan masalah ini, kami boleh menggunakan baris gilir untuk mengendalikan tugas menghantar mesej teks secara tidak segerak.

Barisan ialah struktur data masuk dahulu keluar (FIFO) yang boleh mencapai pemprosesan tugas yang teratur. Dalam PHP, kami boleh menggunakan perpustakaan pihak ketiga seperti Beanstalkd, RabbitMQ, dll. untuk melaksanakan fungsi baris gilir Di sini kami menggunakan Beanstalkd sebagai contoh untuk menunjukkan cara menggunakan baris gilir dalam PHP untuk memproses tugasan penghantaran SMS tak segerak.

1. Pasang Beanstalkd

Pertama, kita perlu memasang Beanstalkd pada pelayan. Ia boleh dipasang dalam sistem Ubuntu melalui arahan berikut:

$ sudo apt-get install beanstalkd

2. Pasang dan gunakan sambungan Beanstalkd untuk PHP

Seterusnya, kita perlu menggunakan sambungan Beanstalkd dalam PHP untuk berinteraksi dengan Beanstalkd. Sambungan Beanstalkd boleh dipasang menggunakan arahan berikut:

$ pecl install beanstalk

Selepas pemasangan selesai, tambah baris berikut dalam fail php.ini untuk membolehkan sambungan:

extension=beanstalk.so

Mulakan semula perkhidmatan PHP-FPM untuk pengubahsuaian berkuat kuasa .

3. Tulis kod pengeluar

Seterusnya, kita perlu menulis kod pengeluar untuk menghantar tugasan SMS ke baris gilir Beanstalkd. Contoh kod berikut boleh digunakan:

<?php

require_once 'pheanstalk/pheanstalk_init.php';

// 创建连接
$beanstalk = new Pheanstalk('127.0.0.1');

// 设置短信内容
$message = '这里是短信内容';

// 设置发送手机号码，可以是一个数组
$phoneNumbers = ['1234567890', '9876543210'];

// 将短信任务发送到队列中
foreach ($phoneNumbers as $phoneNumber) {
    $jobData = [
        'phone' => $phoneNumber,
        'message' => $message,
    ];
    $beanstalk->useTube('sms')->put(json_encode($jobData));
}

// 关闭连接
$beanstalk->getConnection()->disconnect();

4. Menulis kod pengguna

Kemudian, kita perlu menulis kod pengguna untuk mengambil tugas SMS dari baris gilir Beanstalkd dan menghantar SMS. Contoh kod berikut boleh digunakan:

<?php

require_once 'pheanstalk/pheanstalk_init.php';

// 创建连接
$beanstalk = new Pheanstalk('127.0.0.1');

// 监听队列
$beanstalk->watch('sms');

while (true) {
    // 取出短信任务
    $job = $beanstalk->reserve();

    // 处理短信任务
    $jobData = json_decode($job->getData(), true);
    sendSMS($jobData['phone'], $jobData['message']);

    // 删除任务
    $beanstalk->delete($job);
}

// 关闭连接
$beanstalk->getConnection()->disconnect();

// 发送短信函数
function sendSMS($phone, $message)
{
    // 在这里编写发送短信的代码
}

Dalam kod pengguna, kami menggunakan gelung tak terhingga untuk terus mengeluarkan tugasan SMS daripada baris gilir Beanstalkd. Selepas mengambil tugas, kita boleh merangkum fungsi untuk menghantar mesej teks berdasarkan keperluan sebenar untuk melaksanakan logik menghantar mesej teks.

5. Jalankan kod

Akhir sekali, kita perlu menjalankan kod pengeluar dan kod pengguna secara berasingan untuk menghantar tugasan SMS dan memproses tugasan. Anda boleh menjalankan arahan berikut dalam baris arahan:

$ php producer.php
$ php consumer.php

Melalui langkah di atas, kita boleh menggunakan baris gilir untuk memproses tugas penghantaran SMS secara tak segerak. Pengeluar menghantar tugasan SMS ke baris gilir, manakala pengguna mengambil tugas dari baris gilir dan menghantar SMS. Dengan cara ini, kita boleh mengelakkan tekanan pada pelayan yang disebabkan oleh menghantar sejumlah besar mesej teks pada satu masa dan meningkatkan kestabilan dan ketersediaan pelayan.

Sudah tentu, kod di atas hanyalah contoh mudah, dan pelaksanaan khusus perlu diselaraskan mengikut logik perniagaan anda sendiri. Saya harap artikel ini akan membantu anda memahami cara menggunakan baris gilir untuk memproses tugasan penghantaran SMS tak segerak dalam PHP.

Atas ialah kandungan terperinci Bagaimana untuk menggunakan baris gilir untuk memproses tugas penghantaran SMS tak segerak dalam PHP?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!