PHP+MySQL creates message queue function (with code)

This time I will bring you the message queue function of PHP MySQL (with code), what are the precautions for PHP MySQL to make the message queue function, the following is a practical case , let’s take a look.

Recently encountered a need to send text messages in batches. The text message interface is provided by a third party. At first I thought, after getting the mobile phone number, wouldn't it be enough to call the interface in a loop to send it?

But the problem was quickly discovered: when the number of text messages is large, it is not only time-consuming, but also the success rate is very low.

So I thought of using PHP and MySQL to implement a message queue and send text messages one by one. The specific implementation method is introduced below:

First, create a data table sms, including the following fields:

id,
phone, //Mobile phone number
content / /SMS content

Store the text messages and mobile phone numbers to be sent in the sms table.

Next, you need to use PHP to implement a timer to read a record regularly and send a text message:

<?php
$db = new Db();
$sms = new Sms();
while(true){
  $item = $db->getFirstRecord(); //获取数据表第一条记录
  if(!$item){
    //如果队列中没有数据，则结束定时器
    break;
  }
  $res = $sms->send($item['phone'],$item['content']); //发送短信
  if($res){
    $db->deleteFristRecord(); //删除发送成功的记录
    echo $item['phone'].'发送成功';
  }else{
    echo $item['phone'].'发送失败，稍后继续尝试'；
  }
  sleep(10); //每隔十秒循环一次
}
echo '发送完毕！';
?>

Save the code as timer_sms.php and open the command OK, execute the timer:

php timer_sms.php

Okay, the php timer will automatically complete the task of sending text messages according to the set time interval (here it is set to 10 seconds). After the task is completed, the timer will automatically exit and no longer occupy server resources.

According to my tests, the PHP timer does not occupy many resources and will not put pressure on the server. Moreover, accessing the database asynchronously will not affect the operation of the database.

The advantages of this method are:

1. Running in the background, no need to wait in the front desk

2. High success rate, failed records will be automatically Re-send until successful

I believe you have mastered the method after reading the case in this article. For more exciting information, please pay attention to other related articles on the php Chinese website!

Recommended reading:

Puppeteer entry-level code

Vue data monitoring watch usage instructions

The above is the detailed content of PHP+MySQL creates message queue function (with code). For more information, please follow other related articles on the PHP Chinese website!