Detailed explanation of the steps to implement message queue with PHP+MySQL

This time I will bring you a detailed explanation of the steps of implementing message queue in PHP MySQL Queue , what are the precautions for implementing message queue in PHP MySQL, 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, //手机号
content //短信内容

Copy after login

Store the text messages and mobile phone numbers that need to be sent into the sms table middle.

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[&#39;phone&#39;],$item[&#39;content&#39;]); //发送短信
  if($res){
    $db->deleteFristRecord(); //删除发送成功的记录
    echo $item[&#39;phone&#39;].&#39;发送成功&#39;;
  }else{
    echo $item[&#39;phone&#39;].&#39;发送失败，稍后继续尝试&#39;；
  }
  sleep(10); //每隔十秒循环一次
}
echo &#39;发送完毕！&#39;;
?>

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:

Detailed explanation of the steps to implement the drag and drop function using Vue

detailed explanation of the steps to create a WeChat personal account robot using node

The above is the detailed content of Detailed explanation of the steps to implement message queue with PHP+MySQL. For more information, please follow other related articles on the PHP Chinese website!