Analysis of the method of implementing message queue with PHP+MySQL

This article mainly introduces the method of implementing message queue in PHP MySQL, and analyzes the related operation skills of PHP MySQL to build a message queue and use timer to send information intermittently in the form of examples. Friends in need can refer to it

The examples in this article describe how PHP MySQL implements message queues. Share it with everyone for your reference, the details are as follows:

Recently I 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[&#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, open the command line, execute the timer:

php timer_sms.php

Okay, the php timer will be based on the set time interval (set here is 10 seconds) to automatically complete the task of sending text messages. 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 Resend until successful

Related recommendations:

Related knowledge about php mysql fuzzy query function

html before and after completion with php MySQL Terminal interaction

The above is the detailed content of Analysis of the method of implementing message queue with PHP+MySQL. For more information, please follow other related articles on the PHP Chinese website!